Closedown

This commit is contained in:
gac-x12sa
2022-12-20 14:10:54 +01:00
parent f6f8a3c67a
commit 0dfa3c5c4d

View File

@@ -84,9 +84,11 @@ class Array10(DeviceBase, Readable, Cacheable, Readable.ReadableType):
def rx_thread(self):
self.getLogger().info("Enter rx thread");
try:
print "ENTER"
self.context = ZMQ.context(1)
self.socket = self.context.socket(self.mode)
self.socket.connect(self.address)
print "RUNNING"
while self.running:
header = self.socket.recv(ZMQ.NOBLOCK)
if (header is not None):