Switched bind+connect for dataStreamSocket

conf/config.py

@@ -25,6 +25,7 @@ class defaultConfigSender():
     fileEventPort       = "6060"
     # ip of dataStream-socket to push new files to
     dataStreamIp        = LOCAL_IP
+#    dataStreamIp        = "131.169.185.121"   # zitpcx19282.desy.de
     # port number of dataStream-socket to push new files to
     dataStreamPort      = "6061"
     # zmq-pull-socket ip which deletes/moves given files
@@ -66,6 +67,8 @@ class defaultConfigReceiver():
 
     # local ip to bind dataStream to
     dataStreamIp          = LOCAL_IP
+#    dataStreamIp          = "*"
+#    dataStreamIp          = "131.169.55.170"      # lsdma-lab04.desy.de
     # tcp port of data pipe"
     dataStreamPort        = "6061"
     # local ip to bind LiveViewer to

src/ZeroMQTunnel/receiver.py

@@ -74,7 +74,7 @@ class FileReceiver:
         # create pull socket
         self.zmqDataStreamSocket = self.zmqContext.socket(zmq.PULL)
         connectionStrZmqSocket = "tcp://{ip}:{port}".format(ip=self.zmqDataStreamIp, port=self.zmqDataStreamPort)
-        self.zmqDataStreamSocket.bind(connectionStrZmqSocket)
+        self.zmqDataStreamSocket.connect(connectionStrZmqSocket)
         self.log.debug("zmqDataStreamSocket started (bind) for '" + connectionStrZmqSocket + "'")
 
         self.exchangeSocket = self.zmqContext.socket(zmq.PAIR)

src/ZeroMQTunnel/sender.py

@@ -65,7 +65,7 @@ class WorkerProcess():
 
         self.zmqDataStreamSocket      = self.zmqContextForWorker.socket(zmq.PUSH)
         connectionStrDataStreamSocket = "tcp://{ip}:{port}".format(ip=self.dataStreamIp, port=self.dataStreamPort)
-        self.zmqDataStreamSocket.connect(connectionStrDataStreamSocket)
+        self.zmqDataStreamSocket.bind(connectionStrDataStreamSocket)
         self.log.debug("zmqDataStreamSocket started for '" + connectionStrDataStreamSocket + "'")
 
         # initialize sockets