We could depend on Kafka messages sent by the listener, and propagate them internally via a queue, e.g: - https://github.com/European-XFEL/DAMNIT/blob/74a706928ade84ed804aec25376d6831d081c1ae/damnit/gui/kafka.py#L45-L68 - https://github.com/European-XFEL/DAMNIT/blob/74a706928ade84ed804aec25376d6831d081c1ae/damnit/backend/extract_data.py#L294-L296