use the new interfaces to receive the data

This commit is contained in:
Sven Czarnian
2021-11-13 22:54:20 +01:00
parent 22e9018807
commit eba9e2deab

View File

@@ -26,11 +26,12 @@ class ReceiverThread(Thread):
msg = self.Socket.recv(zmq.NOBLOCK) msg = self.Socket.recv(zmq.NOBLOCK)
# parse the received message # parse the received message
report = AircraftReport_pb2.AircraftReport() report = Communication_pb2.AircraftUpdate()
report.ParseFromString(msg) report.ParseFromString(msg)
# try to associate the received aircraft to an airport # try to associate the received aircrafts to airports
self.AMAN.updateAircraftReport(report) for inbound in report.reports:
self.AMAN.updateAircraftReport(inbound)
except zmq.ZMQError as error: except zmq.ZMQError as error:
if zmq.EAGAIN == error.errno: if zmq.EAGAIN == error.errno: