From c164ffd21bd52b6c4b9b017ec350c7eb0b1cbaed Mon Sep 17 00:00:00 2001 From: Drew Michel Date: Wed, 21 Nov 2018 14:01:34 -0500 Subject: [PATCH] [pubsub] ignore events MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit don’t sent events into the metrics pipeline --- .../com/spotify/ffwd/pubsub/PubsubPluginSink.java | 11 +---------- 1 file changed, 1 insertion(+), 10 deletions(-) diff --git a/modules/pubsub/src/main/java/com/spotify/ffwd/pubsub/PubsubPluginSink.java b/modules/pubsub/src/main/java/com/spotify/ffwd/pubsub/PubsubPluginSink.java index 97a0db05..9feec884 100644 --- a/modules/pubsub/src/main/java/com/spotify/ffwd/pubsub/PubsubPluginSink.java +++ b/modules/pubsub/src/main/java/com/spotify/ffwd/pubsub/PubsubPluginSink.java @@ -90,16 +90,7 @@ public void init() { } @Override public AsyncFuture sendEvents(Collection 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(); }