|
@@ -87,7 +87,7 @@ class Euroscope:
|
|
|
self.receiverSocket.setsockopt(zmq.SUBSCRIBE, b'')
|
|
|
self.receiverThread = ReceiverThread(self.receiverSocket, aman)
|
|
|
self.receiverThread.start()
|
|
|
- print('Listening at tcp://' + config.Address + ':' + str(config.PortReceiver))
|
|
|
+ print('Listening to tcp://' + config.Address + ':' + str(config.PortReceiver))
|
|
|
|
|
|
# initialize the notification
|
|
|
self.notificationSocket = zmq.Socket(self.context, zmq.PUB)
|
|
@@ -95,7 +95,7 @@ class Euroscope:
|
|
|
self.notificationSocket.setsockopt(zmq.CURVE_SECRETKEY, keyPair[1])
|
|
|
self.notificationSocket.setsockopt(zmq.CURVE_SERVER, True)
|
|
|
self.notificationSocket.bind('tcp://' + config.Address + ':' + str(config.PortNotification))
|
|
|
- print('Publishing at tcp://' + config.Address + ':' + str(config.PortNotification))
|
|
|
+ print('Publishing to tcp://' + config.Address + ':' + str(config.PortNotification))
|
|
|
|
|
|
def __del__(self):
|
|
|
self.receiverThread.stopThread()
|