From c5f11c66a29f3754399edc0119571e6e125f9ac0 Mon Sep 17 00:00:00 2001 From: luozukai Date: Tue, 10 Sep 2019 16:01:28 +0800 Subject: [PATCH] =?UTF-8?q?[=E4=BF=AE=E6=94=B9][=E7=BB=93=E7=AE=97?= =?UTF-8?q?=E5=8D=95][=E4=BF=AE=E6=94=B9=E8=B7=B3=E7=82=B9=E7=8E=87?= =?UTF-8?q?=E8=AE=A1=E7=AE=97]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/iformall/mq/MqBaseProducer.java | 2 +- .../mq/impl/RabbitMqMessageProducer.java | 26 +++++++++---------- 2 files changed, 14 insertions(+), 14 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/mq/MqBaseProducer.java b/mallinkService/src/main/java/com/iformall/mq/MqBaseProducer.java index 0494be5c8..a7994bd02 100644 --- a/mallinkService/src/main/java/com/iformall/mq/MqBaseProducer.java +++ b/mallinkService/src/main/java/com/iformall/mq/MqBaseProducer.java @@ -3,7 +3,7 @@ package com.iformall.mq; import com.iformall.domain.po.msg.BaseMsg; import org.springframework.amqp.rabbit.core.RabbitTemplate; -public interface MqBaseProducer extends RabbitTemplate.ConfirmCallback{ +public interface MqBaseProducer { void sendMessage(BaseMsg record, String topic, String tags, String keys); } diff --git a/mallinkService/src/main/java/com/iformall/mq/impl/RabbitMqMessageProducer.java b/mallinkService/src/main/java/com/iformall/mq/impl/RabbitMqMessageProducer.java index 87d94249c..036ed2b58 100644 --- a/mallinkService/src/main/java/com/iformall/mq/impl/RabbitMqMessageProducer.java +++ b/mallinkService/src/main/java/com/iformall/mq/impl/RabbitMqMessageProducer.java @@ -30,17 +30,17 @@ public class RabbitMqMessageProducer implements MqBaseProducer { private WxMsgRecordMapper wxMsgRecordMapper; @Autowired private WxMsgRecordService wxMsgRecordService; - - @Override - public void confirm(CorrelationData correlationData, boolean b, String s) { - log.info("------correlationData"+correlationData.toString()); - System.out.println(); - if(b){ - System.out.println(); - }else{ - - } - } +// +// @Override +// public void confirm(CorrelationData correlationData, boolean b, String s) { +// log.info("------correlationData"+correlationData.toString()); +// System.out.println(); +// if(b){ +// System.out.println(); +// }else{ +// +// } +// } @Override public void sendMessage(BaseMsg data, String topic, String tags, String keys) { @@ -48,8 +48,8 @@ public class RabbitMqMessageProducer implements MqBaseProducer { data.setUuid(UUID.randomUUID().toString()); wxMsgRecordService.save(data); - CorrelationData correlationData = new CorrelationData("16746324"); - rabbitTemplate.convertAndSend(topic, JsonUtil.obj2Json(data),correlationData); + //CorrelationData correlationData = new CorrelationData("16746324"); + rabbitTemplate.convertAndSend(topic, JsonUtil.obj2Json(data)); // data.setMsgStatus(EnumMsgRecordStatus.SEND_SUCC.getCode()); // wxMsgRecordMapper.update(data);