Browse Source

Merge branch 'dev_group_point' of http://git.elinkit.com.cn:7070/r/epmet-cloud into dev_temp

master
jianjun 5 years ago
parent
commit
484421b2ac
  1. 2
      epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/register/MQConsumerRegister.java

2
epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/register/MQConsumerRegister.java

@ -34,7 +34,7 @@ public abstract class MQConsumerRegister {
ConsumerConfigProperties consumerProperty = getConsumerProperty(); ConsumerConfigProperties consumerProperty = getConsumerProperty();
log.info("registerAllListeners consumers:{} success", consumerProperty); log.info("registerAllListeners consumers:{} success", consumerProperty);
//本地环境不注册 //本地环境不注册
if ("local".equals(env)) { if (!"local".equals(env)) {
try { try {
// 实例化消费者 // 实例化消费者
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(consumerProperty.getConsumerGroup()); DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(consumerProperty.getConsumerGroup());

Loading…
Cancel
Save