lib/pigato/client.rb in pigato-0.2.22 vs lib/pigato/client.rb in pigato-0.2.23

@@ -85,17 +85,32 @@
       @sockets[tid].close
       @sockets.delete(tid)
     end
   end
 
+  def setctx
+    @ctx = ZMQ::Context.new
+    @ctx.linger = 0
+    $PIGATO_zmq_ctx = @ctx
+  end
+
   def reconnect_to_broker
     stop
-    if $PIGATO_zmq_ctx == nil
-      $PIGATO_zmq_ctx = ZMQ::Context.new
-      $PIGATO_zmq_ctx.linger = 0
+
+    @ctx = $PIGATO_zmq_ctx
+
+    if @ctx == nil
+      setctx
     end
-    socket = $PIGATO_zmq_ctx.socket ZMQ::DEALER
+
+    socket = @ctx.socket ZMQ::DEALER
     socket.identity = SecureRandom.uuid
     socket.connect @broker
     @sockets[get_thread_id()] = socket
+  rescue ZMQ::Error => e
+    puts e
+    if e.include? 'ZMQ::Context instance belongs to another process'
+      setctx
+      reconnect_to_broker
+    end
   end
 end