- def _publish_response(self, topic: str, key: str, msg: dict):
- topic = topic.replace('request', 'response')
- key = key.replace('request', 'response')
- producer = Producer()
- producer.send(topic=topic, key=key, value=json.dumps(msg))
- producer.flush(timeout=5)
- producer.close()
-
-
-if __name__ == '__main__':
- Server().run()
+ async def _publish_response(self, topic: str, key: str, msg: dict):
+ log.info("Sending response %s to topic %s with key %s", json.dumps(msg), topic, key)
+ await self.msg_bus.aiowrite(topic, key, msg)