|
@@ -48,7 +48,7 @@ async def on_message_received(producer, msg: IncomingMessage):
|
|
|
|
|
|
|
|
|
|
|
|
|
async def main_for_rabbitmq():
|
|
async def main_for_rabbitmq():
|
|
|
- log.info("start job. Listening queue :", source_topic, "send topic:", target_topic, "max concurrency:",
|
|
|
|
|
|
|
+ log.info("start job. Listening queue : %s , send topic: %s , max concurrency: %s", source_topic, target_topic,
|
|
|
max_concurrency)
|
|
max_concurrency)
|
|
|
|
|
|
|
|
pool = AsyncPool(max_concurrency)
|
|
pool = AsyncPool(max_concurrency)
|
许家凯