|
|
|
@ -42,7 +42,7 @@ public class LetterQueueReceiver {
|
|
|
|
|
* @param message
|
|
|
|
|
* 发送:rabbitTemplate.convertAndSend(I3CoreQueueConfig.IMPP_MESSAGE_QUEUE, new SysMessage(....));
|
|
|
|
|
*/
|
|
|
|
|
@RabbitListener(queues = I3CoreQueueConfig.IMPP_MESSAGE_LETTER_QUEUE)
|
|
|
|
|
// @RabbitListener(queues = I3CoreQueueConfig.IMPP_MESSAGE_LETTER_QUEUE)
|
|
|
|
|
public void processImppMessage(SysMessage msg, Channel channel, Message message) {
|
|
|
|
|
try {
|
|
|
|
|
LOGGER.info("【MQ-IMPP_MESSAGE_LETTER_QUEUE】数据接收成功:{}",msg);
|
|
|
|
|