From fb7bb87a51cc1a2432e0ea3d247bed1a7fb5aa32 Mon Sep 17 00:00:00 2001 From: xiaohanzi Date: Wed, 10 Jun 2020 09:38:46 +0800 Subject: [PATCH] update --- .../com/iformall/mq/impl/AliyunRocketMqMessageProducer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/mq/impl/AliyunRocketMqMessageProducer.java b/mallinkService/src/main/java/com/iformall/mq/impl/AliyunRocketMqMessageProducer.java index 6557542f6..43a32d10d 100644 --- a/mallinkService/src/main/java/com/iformall/mq/impl/AliyunRocketMqMessageProducer.java +++ b/mallinkService/src/main/java/com/iformall/mq/impl/AliyunRocketMqMessageProducer.java @@ -27,7 +27,7 @@ import com.iformall.utils.JsonUtil; * @Date: 2019-01-31 * @Description: RocketMQ消息生产者 */ -//@Service +@Service @Profile(MQConfig.Impl.ALIYUN_ROCKET_MQ) public class AliyunRocketMqMessageProducer implements MqBaseProducer { private final Logger log = LoggerFactory.getLogger(this.getClass()); @@ -53,7 +53,7 @@ public class AliyunRocketMqMessageProducer implements MqBaseProducer { private static Producer producer = null; - // @PostConstruct + @PostConstruct public void init() { Properties properties = new Properties(); properties.setProperty(PropertyKeyConst.GROUP_ID, groupId);