RocketMQ代码优化

framework-rocketmq/src/main/java/com/chelvc/framework/rocketmq/config/RocketMQConfigurer.java

@@ -5,9 +5,9 @@ import java.util.concurrent.atomic.AtomicLong;
 
 import com.chelvc.framework.rocketmq.annotation.RocketMQConsumer;
 import com.chelvc.framework.rocketmq.consumer.MultipleRocketMQListenerContainer;
+import com.chelvc.framework.rocketmq.consumer.RocketMQListener;
 import com.chelvc.framework.rocketmq.consumer.RocketMQListenerContainer;
 import com.chelvc.framework.rocketmq.consumer.SingleRocketMQListenerContainer;
-import com.chelvc.framework.rocketmq.interceptor.RocketMQListener;
 import com.chelvc.framework.rocketmq.producer.DefaultRocketMQProducerFactory;
 import com.chelvc.framework.rocketmq.producer.RocketMQProducerFactory;
 import lombok.RequiredArgsConstructor;

framework-rocketmq/src/main/java/com/chelvc/framework/rocketmq/consumer/MultipleRocketMQListenerContainer.java

@@ -13,7 +13,6 @@ import com.chelvc.framework.common.util.ThreadUtils;
 import com.chelvc.framework.rocketmq.annotation.RocketMQConsumer;
 import com.chelvc.framework.rocketmq.config.RocketMQProperties;
 import com.chelvc.framework.rocketmq.context.RocketMQContextHolder;
-import com.chelvc.framework.rocketmq.interceptor.RocketMQListener;
 import lombok.NonNull;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.client.apis.ClientConfiguration;

framework-rocketmq/src/main/java/com/chelvc/framework/rocketmq/interceptor/RocketMQListener.java → framework-rocketmq/src/main/java/com/chelvc/framework/rocketmq/consumer/RocketMQListener.java

@@ -1,10 +1,11 @@
-package com.chelvc.framework.rocketmq.interceptor;
+package com.chelvc.framework.rocketmq.consumer;
 
 import java.util.List;
 
 /**
  * RocketMQ消息消费监听接口
  *
+ * @param <T> 消息类型
  * @author Woody
  * @date 2023/1/1
  */

framework-rocketmq/src/main/java/com/chelvc/framework/rocketmq/consumer/RocketMQListenerContainer.java

@@ -2,7 +2,6 @@ package com.chelvc.framework.rocketmq.consumer;
 
 import com.chelvc.framework.rocketmq.annotation.RocketMQConsumer;
 import com.chelvc.framework.rocketmq.config.RocketMQProperties;
-import com.chelvc.framework.rocketmq.interceptor.RocketMQListener;
 import org.apache.rocketmq.client.apis.ClientConfiguration;
 import org.apache.rocketmq.client.apis.ClientServiceProvider;
 import org.springframework.beans.factory.DisposableBean;

framework-rocketmq/src/main/java/com/chelvc/framework/rocketmq/consumer/SingleRocketMQListenerContainer.java

@@ -9,7 +9,6 @@ import com.chelvc.framework.common.util.StringUtils;
 import com.chelvc.framework.rocketmq.annotation.RocketMQConsumer;
 import com.chelvc.framework.rocketmq.config.RocketMQProperties;
 import com.chelvc.framework.rocketmq.context.RocketMQContextHolder;
-import com.chelvc.framework.rocketmq.interceptor.RocketMQListener;
 import lombok.NonNull;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.tuple.Pair;