删除 template/common/src/main/java/{{.packagePath}}/common/rocketmq/RocketMQServiceImpl.java
This commit is contained in:
@@ -1,34 +0,0 @@
|
|||||||
package {{ .package }}.common.rocketmq;
|
|
||||||
|
|
||||||
import lombok.Synchronized;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
|
|
||||||
import org.apache.rocketmq.client.exception.MQClientException;
|
|
||||||
|
|
||||||
import java.util.Map;
|
|
||||||
import java.util.concurrent.ConcurrentHashMap;
|
|
||||||
|
|
||||||
@Slf4j
|
|
||||||
public class RocketMQServiceImpl implements RocketMQService {
|
|
||||||
private String serverAddr = null;
|
|
||||||
|
|
||||||
public RocketMQServiceImpl(String serverAddr) {
|
|
||||||
this.serverAddr = serverAddr;
|
|
||||||
}
|
|
||||||
|
|
||||||
Map<String, DefaultMQPushConsumer> consumerMap = new ConcurrentHashMap<>();
|
|
||||||
|
|
||||||
@Override
|
|
||||||
@Synchronized
|
|
||||||
public DefaultMQPushConsumer getConsumer(String consumerGroup) {
|
|
||||||
DefaultMQPushConsumer defaultMQPushConsumer = consumerMap.get(consumerGroup);
|
|
||||||
if (defaultMQPushConsumer != null) {
|
|
||||||
return defaultMQPushConsumer;
|
|
||||||
}
|
|
||||||
DefaultMQPushConsumer instance = new DefaultMQPushConsumer(consumerGroup);
|
|
||||||
instance.setNamesrvAddr(this.serverAddr);
|
|
||||||
this.consumerMap.put(consumerGroup, instance);
|
|
||||||
return instance;
|
|
||||||
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Reference in New Issue
Block a user