|
@@ -41,14 +41,14 @@ public class DeleteQueueListener implements ChannelAwareMessageListener {
|
|
|
try {
|
|
|
String msg = new String(message.getBody(), StandardCharsets.UTF_8);
|
|
|
String messageId = message.getMessageProperties().getMessageId();
|
|
|
- log.info("场景doSliceQueue开始,id:{},deliveryTag:{},消息体:{}", messageId,deliveryTag,msg);
|
|
|
+ log.info("场景DeleteQueue开始,id:{},deliveryTag:{},消息体:{}", messageId,deliveryTag,msg);
|
|
|
DeleteSceneDTO dto = JSONObject.parseObject(msg, DeleteSceneDTO.class);
|
|
|
if (dto != null && dto.getNumList() != null) {
|
|
|
workService.removeByNums(dto.getNumList());
|
|
|
}
|
|
|
}catch (Exception e){
|
|
|
e.printStackTrace();
|
|
|
- log.error("场景doSliceQueue报错{}",e.getMessage());
|
|
|
+ log.error("场景DeleteQueue报错{}",e.getMessage());
|
|
|
}finally {
|
|
|
channel.basicAck(deliveryTag, false);
|
|
|
}
|