feat:新增链路追踪的日志记录

dev
gtl 2024-05-21 22:41:40 +08:00
parent e3f02b4cf8
commit c47c396c98
1 changed files with 1 additions and 0 deletions

View File

@ -77,6 +77,7 @@ public class DataSourceConsumer {
*/
@RabbitListener(queuesToDeclare = {@Queue(name = QueueConstants.DATASOURCE_DELETE_MESSAGE)})
public void deleteConsumer(Message message, Channel channel) {
DataSource dataSource = (DataSource) messageConverter.fromMessage(message);
log.info("数据源移除消费者接收到消息,消息内容:{}", JSON.toJSONString(dataSource));
// 获取消息的id