lib/logstash/outputs/zeromq.rb in logstash-output-zeromq-2.0.0 vs lib/logstash/outputs/zeromq.rb in logstash-output-zeromq-2.0.1
- old
+ new
@@ -105,10 +105,10 @@
@mode == "server"
end # def server?
public
def receive(event)
- return unless output?(event)
+
@codec.encode(event)
end # def receive
def publish(event, payload)