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);