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(); }