lib/rzmq-enhancement.rb in rzmq-enhancement-0.0.18 vs lib/rzmq-enhancement.rb in rzmq-enhancement-0.0.19

@@ -34,11 +34,11 @@
     h = if @ctxh[name].nil?
           h = (@ctxh[name] ||= OpenStruct.new)
           h.ctx = ZMQ::Context.create(1)
           h.push_sock = h.ctx.socket(type)
           error_check(h.push_sock.setsockopt(ZMQ::LINGER, 0))
-          rc = h.push_sock.bind(endpoint)
+          rc = h.push_sock.connect(endpoint)
           error_check(rc)
           h
         else
           @ctxh[name]
         end
@@ -65,10 +65,10 @@
     init_sys
     h = (@ctxh[name] ||= OpenStruct.new)
     h.ctx = ZMQ::Context.create(1)
 
     h.server_sock = h.ctx.socket(type)
-    #error_check(h.server_sock.setsockopt(ZMQ::LINGER, 0))
+    error_check(h.server_sock.setsockopt(ZMQ::LINGER, 0))
     rc = if opts[:bind]
            h.server_sock.bind(endpoint)
          else
            h.server_sock.connect(endpoint)
          end