zeromq.rb in logstash-output-zeromq-0.1.2

- old
+ new

@@ -110,10 +110,10 @@
     return unless output?(event)
 
     @codec.encode(event)
   end # def receive
 
-  def publish(payload)
+  def publish(event, payload)
     @logger.debug? && @logger.debug("0mq: sending", :event => payload)
     if @topology == "pubsub"
       # TODO(sissel): Need to figure out how to fit this into the codecs system.
       #@logger.debug("0mq output: setting topic to: #{event.sprintf(@topic)}")
       #error_check(@zsocket.send_string(event.sprintf(@topic), ZMQ::SNDMORE),