lib/buster/sender.rb in buster-0.1.2 vs lib/buster/sender.rb in buster-0.1.3

@@ -5,16 +5,17 @@
     end
 
     def fire(name, props = {})
       bin = MessagePack.pack(props)
       sender.send_strings([name.to_s, bin])
-      sender.close
     end
 
     private
 
     def sender
-      s = @context.socket(ZMQ::DEALER)
+      return Thread.current['sender_socket'] if Thread.current['sender_socket']
+
+      s = Thread.current['sender_socket'] = @context.socket(ZMQ::DEALER)
       s.connect("inproc://routes")
       s
     end
   end
 end