|
@@ -48,6 +48,7 @@ public class RabbitMqListener {
|
|
|
log.info("开始消费消息,id:{},queue:{},content:{}", messageId, downloadTourVideoQueue, msg);
|
|
|
DownloadTourVideo downloadTourVideo = JSON.parseObject(msg, DownloadTourVideo.class);
|
|
|
downloadTourVideoService.transferTourVideo(downloadTourVideo);
|
|
|
+ log.info("deliverTag:" + message.getMessageProperties().getDeliveryTag());
|
|
|
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
|
|
|
log.info("结束消费消息,id:{}", messageId);
|
|
|
}
|