client.rb in logstash-input-zeromq-3.0.0

- old
+ new

@@ -11,11 +11,11 @@
     @context = ZMQ::Context.new(1)
     @requester = context.socket(ZMQ::PUB)
     @requester.connect("tcp://#{addr}:#{port}")
   end
 
-  def send(data)
-    @requester.send_string(data)
+  def send(data, flags=0)
+    @requester.send_string(data, flags)
   end
 
   def close
     @requester.close
     @context.terminate