|
@@ -86,7 +86,7 @@ class AliyunRocketMQQueueBackend(MessageQueueBackend):
|
|
|
return None
|
|
|
rmq_message = messages[0]
|
|
|
body = rmq_message.body.decode('utf-8')
|
|
|
- logger.debug("[{}]recv message body: {}".format(self.topic, body))
|
|
|
+ logger.debug(f"[{self.topic}]recv message, group[{rmq_message.message_group}], body: {body}")
|
|
|
try:
|
|
|
message = MqMessage.from_json(body)
|
|
|
message._rmq_message = rmq_message
|