diff --git a/template/common/src/main/java/{{.packagePath}}/common/rocketmq/RocketMQServiceImpl.java b/template/common/src/main/java/{{.packagePath}}/common/rocketmq/RocketMQServiceImpl.java
deleted file mode 100644
index 5321d2c..0000000
--- a/template/common/src/main/java/{{.packagePath}}/common/rocketmq/RocketMQServiceImpl.java
+++ /dev/null
@@ -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;
-
-    }
-}
\ No newline at end of file