Skip to content

Commit

Permalink
[pubsub] ignore events
Browse files Browse the repository at this point in the history
don’t sent events into the metrics pipeline
dmichel1 committed Nov 21, 2018
1 parent ba6b416 commit c164ffd
Showing 1 changed file with 1 addition and 10 deletions.
Original file line number Diff line number Diff line change
@@ -90,16 +90,7 @@ public void init() { }

@Override
public AsyncFuture<Void> sendEvents(Collection<Event> events) {
for (Event event : events) {
try {
publisher.publish(PubsubMessage.newBuilder()
.setData(ByteString.copyFrom(serializer.serialize(event))).build()
);
} catch (Exception e) {
log.error("Failed to publish event {}", e);
}
}

log.debug("Sending events is not supported!");
return async.resolved();
}

0 comments on commit c164ffd

Please sign in to comment.