Merge remote-tracking branch 'origin/hjc' into hjc

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerOrderCloseRedisStreamConfig.java

@@ -123,6 +123,88 @@ public class ConsumerOrderCloseRedisStreamConfig {
 
     /* -------------------------------------------------------- ｜ 订单关闭 */
 
+    @Bean
+    public Subscription subscriptionOrderClose000(RedisConnectionFactory factory) {
+        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+        var subscription = receiveOrderClose0(listenerContainer, 0);
+        listenerContainer.start();
+        return subscription;
+    }
+
+    @Bean
+    public Subscription subscriptionOrderClose100(RedisConnectionFactory factory) {
+        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+        var subscription = receiveOrderClose1(listenerContainer, 0);
+        listenerContainer.start();
+        return subscription;
+    }
+
+    @Bean
+    public Subscription subscriptionOrderClose200(RedisConnectionFactory factory) {
+        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+        var subscription = receiveOrderClose2(listenerContainer, 0);
+        listenerContainer.start();
+        return subscription;
+    }
+
+    @Bean
+    public Subscription subscriptionOrderClose300(RedisConnectionFactory factory) {
+        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+        var subscription = receiveOrderClose3(listenerContainer, 0);
+        listenerContainer.start();
+        return subscription;
+    }
+
+    @Bean
+    public Subscription subscriptionOrderClose400(RedisConnectionFactory factory) {
+        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+        var subscription = receiveOrderClose4(listenerContainer, 0);
+        listenerContainer.start();
+        return subscription;
+    }
+
+    @Bean
+    public Subscription subscriptionOrderClose500(RedisConnectionFactory factory) {
+        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+        var subscription = receiveOrderClose5(listenerContainer, 0);
+        listenerContainer.start();
+        return subscription;
+    }
+
+    @Bean
+    public Subscription subscriptionOrderClose600(RedisConnectionFactory factory) {
+        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+        var subscription = receiveOrderClose6(listenerContainer, 0);
+        listenerContainer.start();
+        return subscription;
+    }
+
+    @Bean
+    public Subscription subscriptionOrderClose700(RedisConnectionFactory factory) {
+        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+        var subscription = receiveOrderClose7(listenerContainer, 0);
+        listenerContainer.start();
+        return subscription;
+    }
+
+    @Bean
+    public Subscription subscriptionOrderClose800(RedisConnectionFactory factory) {
+        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+        var subscription = receiveOrderClose8(listenerContainer, 0);
+        listenerContainer.start();
+        return subscription;
+    }
+
+    @Bean
+    public Subscription subscriptionOrderClose900(RedisConnectionFactory factory) {
+        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+        var subscription = receiveOrderClose9(listenerContainer, 0);
+        listenerContainer.start();
+        return subscription;
+    }
+
+    /* -------------------------------------------------------- ｜  */
+
     @Bean
     public Subscription subscriptionOrderClose001(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@@ -208,7 +290,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose002(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose0(listenerContainer, 1);
+        var subscription = receiveOrderClose0(listenerContainer, 2);
         listenerContainer.start();
         return subscription;
     }
@@ -216,7 +298,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose102(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose1(listenerContainer, 1);
+        var subscription = receiveOrderClose1(listenerContainer, 2);
         listenerContainer.start();
         return subscription;
     }
@@ -224,7 +306,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose202(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose2(listenerContainer, 1);
+        var subscription = receiveOrderClose2(listenerContainer, 2);
         listenerContainer.start();
         return subscription;
     }
@@ -232,7 +314,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose302(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose3(listenerContainer, 1);
+        var subscription = receiveOrderClose3(listenerContainer, 2);
         listenerContainer.start();
         return subscription;
     }
@@ -240,7 +322,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose402(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose4(listenerContainer, 1);
+        var subscription = receiveOrderClose4(listenerContainer, 2);
         listenerContainer.start();
         return subscription;
     }
@@ -248,7 +330,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose502(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose5(listenerContainer, 1);
+        var subscription = receiveOrderClose5(listenerContainer, 2);
         listenerContainer.start();
         return subscription;
     }
@@ -256,7 +338,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose602(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose6(listenerContainer, 1);
+        var subscription = receiveOrderClose6(listenerContainer, 2);
         listenerContainer.start();
         return subscription;
     }
@@ -264,7 +346,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose702(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose7(listenerContainer, 1);
+        var subscription = receiveOrderClose7(listenerContainer, 2);
         listenerContainer.start();
         return subscription;
     }
@@ -272,7 +354,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose802(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose8(listenerContainer, 1);
+        var subscription = receiveOrderClose8(listenerContainer, 2);
         listenerContainer.start();
         return subscription;
     }
@@ -280,7 +362,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose902(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose9(listenerContainer, 1);
+        var subscription = receiveOrderClose9(listenerContainer, 2);
         listenerContainer.start();
         return subscription;
     }
@@ -290,7 +372,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose003(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose0(listenerContainer, 1);
+        var subscription = receiveOrderClose0(listenerContainer, 3);
         listenerContainer.start();
         return subscription;
     }
@@ -298,7 +380,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose103(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose1(listenerContainer, 1);
+        var subscription = receiveOrderClose1(listenerContainer, 3);
         listenerContainer.start();
         return subscription;
     }
@@ -306,7 +388,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose203(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose2(listenerContainer, 1);
+        var subscription = receiveOrderClose2(listenerContainer, 3);
         listenerContainer.start();
         return subscription;
     }
@@ -314,7 +396,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose303(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose3(listenerContainer, 1);
+        var subscription = receiveOrderClose3(listenerContainer, 3);
         listenerContainer.start();
         return subscription;
     }
@@ -322,7 +404,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose403(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose4(listenerContainer, 1);
+        var subscription = receiveOrderClose4(listenerContainer, 3);
         listenerContainer.start();
         return subscription;
     }
@@ -330,7 +412,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose503(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose5(listenerContainer, 1);
+        var subscription = receiveOrderClose5(listenerContainer, 3);
         listenerContainer.start();
         return subscription;
     }
@@ -338,7 +420,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose603(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose6(listenerContainer, 1);
+        var subscription = receiveOrderClose6(listenerContainer, 3);
         listenerContainer.start();
         return subscription;
     }
@@ -346,7 +428,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose703(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose7(listenerContainer, 1);
+        var subscription = receiveOrderClose7(listenerContainer, 3);
         listenerContainer.start();
         return subscription;
     }
@@ -354,7 +436,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose803(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose8(listenerContainer, 1);
+        var subscription = receiveOrderClose8(listenerContainer, 3);
         listenerContainer.start();
         return subscription;
     }
@@ -362,7 +444,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose903(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose9(listenerContainer, 1);
+        var subscription = receiveOrderClose9(listenerContainer, 3);
         listenerContainer.start();
         return subscription;
     }
@@ -372,7 +454,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose004(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose0(listenerContainer, 1);
+        var subscription = receiveOrderClose0(listenerContainer, 4);
         listenerContainer.start();
         return subscription;
     }
@@ -380,7 +462,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose104(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose1(listenerContainer, 1);
+        var subscription = receiveOrderClose1(listenerContainer, 4);
         listenerContainer.start();
         return subscription;
     }
@@ -388,7 +470,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose204(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose2(listenerContainer, 1);
+        var subscription = receiveOrderClose2(listenerContainer, 4);
         listenerContainer.start();
         return subscription;
     }
@@ -396,7 +478,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose304(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose3(listenerContainer, 1);
+        var subscription = receiveOrderClose3(listenerContainer, 4);
         listenerContainer.start();
         return subscription;
     }
@@ -404,7 +486,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose404(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose4(listenerContainer, 1);
+        var subscription = receiveOrderClose4(listenerContainer, 4);
         listenerContainer.start();
         return subscription;
     }
@@ -412,7 +494,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose504(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose5(listenerContainer, 1);
+        var subscription = receiveOrderClose5(listenerContainer, 4);
         listenerContainer.start();
         return subscription;
     }
@@ -420,7 +502,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose604(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose6(listenerContainer, 1);
+        var subscription = receiveOrderClose6(listenerContainer, 4);
         listenerContainer.start();
         return subscription;
     }
@@ -428,7 +510,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose704(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose7(listenerContainer, 1);
+        var subscription = receiveOrderClose7(listenerContainer, 4);
         listenerContainer.start();
         return subscription;
     }
@@ -436,7 +518,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose804(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose8(listenerContainer, 1);
+        var subscription = receiveOrderClose8(listenerContainer, 4);
         listenerContainer.start();
         return subscription;
     }
@@ -444,7 +526,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose904(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose9(listenerContainer, 1);
+        var subscription = receiveOrderClose9(listenerContainer, 4);
         listenerContainer.start();
         return subscription;
     }
@@ -454,7 +536,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose005(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose0(listenerContainer, 1);
+        var subscription = receiveOrderClose0(listenerContainer, 5);
         listenerContainer.start();
         return subscription;
     }
@@ -462,7 +544,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose105(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose1(listenerContainer, 1);
+        var subscription = receiveOrderClose1(listenerContainer, 5);
         listenerContainer.start();
         return subscription;
     }
@@ -470,7 +552,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose205(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose2(listenerContainer, 1);
+        var subscription = receiveOrderClose2(listenerContainer, 5);
         listenerContainer.start();
         return subscription;
     }
@@ -478,7 +560,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose305(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose3(listenerContainer, 1);
+        var subscription = receiveOrderClose3(listenerContainer, 5);
         listenerContainer.start();
         return subscription;
     }
@@ -486,7 +568,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose405(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose4(listenerContainer, 1);
+        var subscription = receiveOrderClose4(listenerContainer, 5);
         listenerContainer.start();
         return subscription;
     }
@@ -494,7 +576,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose505(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose5(listenerContainer, 1);
+        var subscription = receiveOrderClose5(listenerContainer, 5);
         listenerContainer.start();
         return subscription;
     }
@@ -502,7 +584,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose605(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose6(listenerContainer, 1);
+        var subscription = receiveOrderClose6(listenerContainer, 5);
         listenerContainer.start();
         return subscription;
     }
@@ -510,7 +592,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose705(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose7(listenerContainer, 1);
+        var subscription = receiveOrderClose7(listenerContainer, 5);
         listenerContainer.start();
         return subscription;
     }
@@ -518,7 +600,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose805(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose8(listenerContainer, 1);
+        var subscription = receiveOrderClose8(listenerContainer, 5);
         listenerContainer.start();
         return subscription;
     }
@@ -526,7 +608,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose905(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose9(listenerContainer, 1);
+        var subscription = receiveOrderClose9(listenerContainer, 5);
         listenerContainer.start();
         return subscription;
     }
@@ -536,7 +618,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose006(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose0(listenerContainer, 1);
+        var subscription = receiveOrderClose0(listenerContainer, 6);
         listenerContainer.start();
         return subscription;
     }
@@ -544,7 +626,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose106(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose1(listenerContainer, 1);
+        var subscription = receiveOrderClose1(listenerContainer, 6);
         listenerContainer.start();
         return subscription;
     }
@@ -552,7 +634,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose206(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose2(listenerContainer, 1);
+        var subscription = receiveOrderClose2(listenerContainer, 6);
         listenerContainer.start();
         return subscription;
     }
@@ -560,7 +642,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose306(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose3(listenerContainer, 1);
+        var subscription = receiveOrderClose3(listenerContainer, 6);
         listenerContainer.start();
         return subscription;
     }
@@ -568,7 +650,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose406(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose4(listenerContainer, 1);
+        var subscription = receiveOrderClose4(listenerContainer, 6);
         listenerContainer.start();
         return subscription;
     }
@@ -576,7 +658,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose506(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose5(listenerContainer, 1);
+        var subscription = receiveOrderClose5(listenerContainer, 6);
         listenerContainer.start();
         return subscription;
     }
@@ -584,7 +666,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose606(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose6(listenerContainer, 1);
+        var subscription = receiveOrderClose6(listenerContainer, 6);
         listenerContainer.start();
         return subscription;
     }
@@ -592,7 +674,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose706(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose7(listenerContainer, 1);
+        var subscription = receiveOrderClose7(listenerContainer, 6);
         listenerContainer.start();
         return subscription;
     }
@@ -600,7 +682,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose806(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose8(listenerContainer, 1);
+        var subscription = receiveOrderClose8(listenerContainer, 6);
         listenerContainer.start();
         return subscription;
     }
@@ -608,7 +690,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose906(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose9(listenerContainer, 1);
+        var subscription = receiveOrderClose9(listenerContainer, 6);
         listenerContainer.start();
         return subscription;
     }
@@ -618,7 +700,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose007(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose0(listenerContainer, 1);
+        var subscription = receiveOrderClose0(listenerContainer, 7);
         listenerContainer.start();
         return subscription;
     }
@@ -626,7 +708,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose107(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose1(listenerContainer, 1);
+        var subscription = receiveOrderClose1(listenerContainer, 7);
         listenerContainer.start();
         return subscription;
     }
@@ -634,7 +716,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose207(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose2(listenerContainer, 1);
+        var subscription = receiveOrderClose2(listenerContainer, 7);
         listenerContainer.start();
         return subscription;
     }
@@ -642,7 +724,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose307(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose3(listenerContainer, 1);
+        var subscription = receiveOrderClose3(listenerContainer, 7);
         listenerContainer.start();
         return subscription;
     }
@@ -650,7 +732,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose407(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose4(listenerContainer, 1);
+        var subscription = receiveOrderClose4(listenerContainer, 7);
         listenerContainer.start();
         return subscription;
     }
@@ -658,7 +740,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose507(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose5(listenerContainer, 1);
+        var subscription = receiveOrderClose5(listenerContainer, 7);
         listenerContainer.start();
         return subscription;
     }
@@ -666,7 +748,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose607(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose6(listenerContainer, 1);
+        var subscription = receiveOrderClose6(listenerContainer, 7);
         listenerContainer.start();
         return subscription;
     }
@@ -674,7 +756,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose707(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose7(listenerContainer, 1);
+        var subscription = receiveOrderClose7(listenerContainer, 7);
         listenerContainer.start();
         return subscription;
     }
@@ -682,7 +764,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose807(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose8(listenerContainer, 1);
+        var subscription = receiveOrderClose8(listenerContainer, 7);
         listenerContainer.start();
         return subscription;
     }
@@ -690,7 +772,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose907(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose9(listenerContainer, 1);
+        var subscription = receiveOrderClose9(listenerContainer, 7);
         listenerContainer.start();
         return subscription;
     }
@@ -700,7 +782,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose008(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose0(listenerContainer, 1);
+        var subscription = receiveOrderClose0(listenerContainer, 8);
         listenerContainer.start();
         return subscription;
     }
@@ -708,7 +790,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose108(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose1(listenerContainer, 1);
+        var subscription = receiveOrderClose1(listenerContainer, 8);
         listenerContainer.start();
         return subscription;
     }
@@ -716,7 +798,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose208(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose2(listenerContainer, 1);
+        var subscription = receiveOrderClose2(listenerContainer, 8);
         listenerContainer.start();
         return subscription;
     }
@@ -724,7 +806,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose308(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose3(listenerContainer, 1);
+        var subscription = receiveOrderClose3(listenerContainer, 8);
         listenerContainer.start();
         return subscription;
     }
@@ -732,7 +814,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose408(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose4(listenerContainer, 1);
+        var subscription = receiveOrderClose4(listenerContainer, 8);
         listenerContainer.start();
         return subscription;
     }
@@ -740,7 +822,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose508(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose5(listenerContainer, 1);
+        var subscription = receiveOrderClose5(listenerContainer, 8);
         listenerContainer.start();
         return subscription;
     }
@@ -748,7 +830,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose608(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose6(listenerContainer, 1);
+        var subscription = receiveOrderClose6(listenerContainer, 8);
         listenerContainer.start();
         return subscription;
     }
@@ -756,7 +838,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose708(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose7(listenerContainer, 1);
+        var subscription = receiveOrderClose7(listenerContainer, 8);
         listenerContainer.start();
         return subscription;
     }
@@ -764,7 +846,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose808(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose8(listenerContainer, 1);
+        var subscription = receiveOrderClose8(listenerContainer, 8);
         listenerContainer.start();
         return subscription;
     }
@@ -772,7 +854,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose908(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose9(listenerContainer, 1);
+        var subscription = receiveOrderClose9(listenerContainer, 8);
         listenerContainer.start();
         return subscription;
     }
@@ -782,7 +864,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose009(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose0(listenerContainer, 1);
+        var subscription = receiveOrderClose0(listenerContainer, 9);
         listenerContainer.start();
         return subscription;
     }
@@ -790,7 +872,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose109(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose1(listenerContainer, 1);
+        var subscription = receiveOrderClose1(listenerContainer, 9);
         listenerContainer.start();
         return subscription;
     }
@@ -798,7 +880,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose209(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose2(listenerContainer, 1);
+        var subscription = receiveOrderClose2(listenerContainer, 9);
         listenerContainer.start();
         return subscription;
     }
@@ -806,7 +888,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose309(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose3(listenerContainer, 1);
+        var subscription = receiveOrderClose3(listenerContainer, 9);
         listenerContainer.start();
         return subscription;
     }
@@ -814,7 +896,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose409(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose4(listenerContainer, 1);
+        var subscription = receiveOrderClose4(listenerContainer, 9);
         listenerContainer.start();
         return subscription;
     }
@@ -822,7 +904,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose509(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose5(listenerContainer, 1);
+        var subscription = receiveOrderClose5(listenerContainer, 9);
         listenerContainer.start();
         return subscription;
     }
@@ -830,7 +912,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose609(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose6(listenerContainer, 1);
+        var subscription = receiveOrderClose6(listenerContainer, 9);
         listenerContainer.start();
         return subscription;
     }
@@ -838,7 +920,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose709(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose7(listenerContainer, 1);
+        var subscription = receiveOrderClose7(listenerContainer, 9);
         listenerContainer.start();
         return subscription;
     }
@@ -846,7 +928,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose809(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose8(listenerContainer, 1);
+        var subscription = receiveOrderClose8(listenerContainer, 9);
         listenerContainer.start();
         return subscription;
     }
@@ -854,7 +936,7 @@ public class ConsumerOrderCloseRedisStreamConfig {
     @Bean
     public Subscription subscriptionOrderClose909(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveOrderClose9(listenerContainer, 1);
+        var subscription = receiveOrderClose9(listenerContainer, 9);
         listenerContainer.start();
         return subscription;
     }