调整Redis stream逻辑包结构

framework-redis/src/main/java/com/chelvc/framework/redis/config/RedisMQListenerRegistry.java

@@ -7,9 +7,9 @@ import com.chelvc.framework.common.util.AssertUtils;
 import com.chelvc.framework.common.util.ObjectUtils;
 import com.chelvc.framework.common.util.StringUtils;
 import com.chelvc.framework.redis.annotation.RedisMQConsumer;
-import com.chelvc.framework.redis.stream.DefaultRedisMQListenerContainer;
-import com.chelvc.framework.redis.stream.RedisMQListener;
-import com.chelvc.framework.redis.stream.RedisMQListenerContainer;
+import com.chelvc.framework.redis.queue.DefaultRedisMQListenerContainer;
+import com.chelvc.framework.redis.queue.RedisMQListener;
+import com.chelvc.framework.redis.queue.RedisMQListenerContainer;
 import lombok.NonNull;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.aop.framework.AopProxyUtils;

framework-redis/src/main/java/com/chelvc/framework/redis/stream/ConsumerPendingCleaner.java → framework-redis/src/main/java/com/chelvc/framework/redis/queue/ConsumerPendingCleaner.java

@@ -1,4 +1,4 @@
-package com.chelvc.framework.redis.stream;
+package com.chelvc.framework.redis.queue;
 
 import java.util.concurrent.Executor;
 import java.util.concurrent.Executors;

framework-redis/src/main/java/com/chelvc/framework/redis/stream/DefaultRedisMQListenerContainer.java → framework-redis/src/main/java/com/chelvc/framework/redis/queue/DefaultRedisMQListenerContainer.java

@@ -1,4 +1,4 @@
-package com.chelvc.framework.redis.stream;
+package com.chelvc.framework.redis.queue;
 
 import java.lang.reflect.Type;
 import java.util.Objects;

framework-redis/src/main/java/com/chelvc/framework/redis/stream/MessageStreamListener.java → framework-redis/src/main/java/com/chelvc/framework/redis/queue/MessageStreamListener.java

@@ -1,4 +1,4 @@
-package com.chelvc.framework.redis.stream;
+package com.chelvc.framework.redis.queue;
 
 import java.lang.reflect.Type;
 import java.util.Collections;

framework-redis/src/main/java/com/chelvc/framework/redis/stream/RedisMQListener.java → framework-redis/src/main/java/com/chelvc/framework/redis/queue/RedisMQListener.java

@@ -1,4 +1,4 @@
-package com.chelvc.framework.redis.stream;
+package com.chelvc.framework.redis.queue;
 
 /**
  * Redis Stream 消息消费监听接口

framework-redis/src/main/java/com/chelvc/framework/redis/stream/RedisMQListenerContainer.java → framework-redis/src/main/java/com/chelvc/framework/redis/queue/RedisMQListenerContainer.java

@@ -1,4 +1,4 @@
-package com.chelvc.framework.redis.stream;
+package com.chelvc.framework.redis.queue;
 
 import java.lang.reflect.Type;
 import java.util.concurrent.ExecutorService;