记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit 4d7797ec authored by jiangxiulong's avatar jiangxiulong
Browse files
Options

Consumer

parent d25f1fef
Hide whitespace changes
Inline Side-by-side
Showing with 1042 additions and 875 deletions
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerCommonSqlRedisStreamConfig.java
View file @ 4d7797ec
...@@ -102,7 +102,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig { ...@@ -102,7 +102,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
List<Subscription> subscriptionList = new ArrayList<>(); List<Subscription> subscriptionList = new ArrayList<>();
MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_NFT_ORDER; MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_NFT_ORDER;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup()); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 3; i++) { for (int i = 0; i < 10; i++) {
StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory); StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
subscriptionList.add(listenerContainer.receiveAutoAck( subscriptionList.add(listenerContainer.receiveAutoAck(
Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)), Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
......
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerOrderCloseRedisStreamConfig.java
View file @ 4d7797ec
...@@ -12,11 +12,17 @@ import org.springframework.data.redis.connection.stream.Consumer; ...@@ -12,11 +12,17 @@ import org.springframework.data.redis.connection.stream.Consumer;
import org.springframework.data.redis.connection.stream.MapRecord; import org.springframework.data.redis.connection.stream.MapRecord;
import org.springframework.data.redis.connection.stream.ReadOffset; import org.springframework.data.redis.connection.stream.ReadOffset;
import org.springframework.data.redis.connection.stream.StreamOffset; import org.springframework.data.redis.connection.stream.StreamOffset;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.stream.StreamMessageListenerContainer; import org.springframework.data.redis.stream.StreamMessageListenerContainer;
import org.springframework.data.redis.stream.Subscription; import org.springframework.data.redis.stream.Subscription;
import java.util.ArrayList;
import java.util.List;
@Configuration @Configuration
public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig { public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig {
@Autowired
StringRedisTemplate stringRedisTemplate;
@Autowired @Autowired
ConsumerOrderClose0RdsReceiver consumerOrderClose0RdsReceiver; ConsumerOrderClose0RdsReceiver consumerOrderClose0RdsReceiver;
@Autowired @Autowired
...@@ -38,877 +44,1038 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig { ...@@ -38,877 +44,1038 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig {
@Autowired @Autowired
ConsumerOrderClose9RdsReceiver consumerOrderClose9RdsReceiver; ConsumerOrderClose9RdsReceiver consumerOrderClose9RdsReceiver;
private Subscription receiveOrderClose0(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) { @Bean// 订单超时关闭
return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_UN_PAY_0.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_UN_PAY_0.name() + t)), public List<Subscription> subscriptionBizOrderClose0(RedisConnectionFactory factory) {
StreamOffset.create(MQConst.GoblinQueue.GOBLIN_UN_PAY_0.getKey(), ReadOffset.lastConsumed()), consumerOrderClose0RdsReceiver); List<Subscription> subscriptionList = new ArrayList<>();
} MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_0;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
private Subscription receiveOrderClose1(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) { for (int i = 0; i < 20; i++) {
return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_UN_PAY_1.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_UN_PAY_1.name() + t)), StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
StreamOffset.create(MQConst.GoblinQueue.GOBLIN_UN_PAY_1.getKey(), ReadOffset.lastConsumed()), consumerOrderClose1RdsReceiver); subscriptionList.add(listenerContainer.receiveAutoAck(
} Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerOrderClose0RdsReceiver
private Subscription receiveOrderClose2(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) { ));
return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_UN_PAY_2.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_UN_PAY_2.name() + t)), listenerContainer.start();
StreamOffset.create(MQConst.GoblinQueue.GOBLIN_UN_PAY_2.getKey(), ReadOffset.lastConsumed()), consumerOrderClose2RdsReceiver); }
} return subscriptionList;
}
private Subscription receiveOrderClose3(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_UN_PAY_3.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_UN_PAY_3.name() + t)), @Bean// 订单超时关闭
StreamOffset.create(MQConst.GoblinQueue.GOBLIN_UN_PAY_3.getKey(), ReadOffset.lastConsumed()), consumerOrderClose3RdsReceiver); public List<Subscription> subscriptionBizOrderClose1(RedisConnectionFactory factory) {
} List<Subscription> subscriptionList = new ArrayList<>();
MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_1;
private Subscription receiveOrderClose4(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) { this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_UN_PAY_4.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_UN_PAY_4.name() + t)), for (int i = 0; i < 20; i++) {
StreamOffset.create(MQConst.GoblinQueue.GOBLIN_UN_PAY_4.getKey(), ReadOffset.lastConsumed()), consumerOrderClose4RdsReceiver); StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
} subscriptionList.add(listenerContainer.receiveAutoAck(
Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
private Subscription receiveOrderClose5(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) { StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerOrderClose1RdsReceiver
return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_UN_PAY_5.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_UN_PAY_5.name() + t)), ));
StreamOffset.create(MQConst.GoblinQueue.GOBLIN_UN_PAY_5.getKey(), ReadOffset.lastConsumed()), consumerOrderClose5RdsReceiver); listenerContainer.start();
} }
return subscriptionList;
private Subscription receiveOrderClose6(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) { }
return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_UN_PAY_6.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_UN_PAY_6.name() + t)),
StreamOffset.create(MQConst.GoblinQueue.GOBLIN_UN_PAY_6.getKey(), ReadOffset.lastConsumed()), consumerOrderClose6RdsReceiver); @Bean// 订单超时关闭
} public List<Subscription> subscriptionBizOrderClose2(RedisConnectionFactory factory) {
List<Subscription> subscriptionList = new ArrayList<>();
private Subscription receiveOrderClose7(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) { MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_2;
return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_UN_PAY_7.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_UN_PAY_7.name() + t)), this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
StreamOffset.create(MQConst.GoblinQueue.GOBLIN_UN_PAY_7.getKey(), ReadOffset.lastConsumed()), consumerOrderClose7RdsReceiver); for (int i = 0; i < 20; i++) {
} StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
subscriptionList.add(listenerContainer.receiveAutoAck(
private Subscription receiveOrderClose8(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) { Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_UN_PAY_8.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_UN_PAY_8.name() + t)), StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerOrderClose2RdsReceiver
StreamOffset.create(MQConst.GoblinQueue.GOBLIN_UN_PAY_8.getKey(), ReadOffset.lastConsumed()), consumerOrderClose8RdsReceiver); ));
} listenerContainer.start();
}
private Subscription receiveOrderClose9(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) { return subscriptionList;
return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_UN_PAY_9.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_UN_PAY_9.name() + t)), }
StreamOffset.create(MQConst.GoblinQueue.GOBLIN_UN_PAY_9.getKey(), ReadOffset.lastConsumed()), consumerOrderClose9RdsReceiver);
} @Bean// 订单超时关闭
public List<Subscription> subscriptionBizOrderClose3(RedisConnectionFactory factory) {
/* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */ List<Subscription> subscriptionList = new ArrayList<>();
MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_3;
/* -------------------------------------------------------- ｜ 订单关闭 */ this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 20; i++) {
@Bean StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
public Subscription subscriptionOrderClose000(RedisConnectionFactory factory) { subscriptionList.add(listenerContainer.receiveAutoAck(
var listenerContainer = this.buildStreamMessageListenerContainer(factory); Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
var subscription = receiveOrderClose0(listenerContainer, 0); StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerOrderClose3RdsReceiver
listenerContainer.start(); ));
return subscription; listenerContainer.start();
} }
return subscriptionList;
@Bean }
public Subscription subscriptionOrderClose100(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); @Bean// 订单超时关闭
var subscription = receiveOrderClose1(listenerContainer, 0); public List<Subscription> subscriptionBizOrderClose4(RedisConnectionFactory factory) {
listenerContainer.start(); List<Subscription> subscriptionList = new ArrayList<>();
return subscription; MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_4;
} this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 20; i++) {
@Bean StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
public Subscription subscriptionOrderClose200(RedisConnectionFactory factory) { subscriptionList.add(listenerContainer.receiveAutoAck(
var listenerContainer = this.buildStreamMessageListenerContainer(factory); Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
var subscription = receiveOrderClose2(listenerContainer, 0); StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerOrderClose4RdsReceiver
listenerContainer.start(); ));
return subscription; listenerContainer.start();
} }
return subscriptionList;
@Bean }
public Subscription subscriptionOrderClose300(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); @Bean// 订单超时关闭
var subscription = receiveOrderClose3(listenerContainer, 0); public List<Subscription> subscriptionBizOrderClose5(RedisConnectionFactory factory) {
listenerContainer.start(); List<Subscription> subscriptionList = new ArrayList<>();
return subscription; MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_5;
} this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 20; i++) {
@Bean StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
public Subscription subscriptionOrderClose400(RedisConnectionFactory factory) { subscriptionList.add(listenerContainer.receiveAutoAck(
var listenerContainer = this.buildStreamMessageListenerContainer(factory); Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
var subscription = receiveOrderClose4(listenerContainer, 0); StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerOrderClose5RdsReceiver
listenerContainer.start(); ));
return subscription; listenerContainer.start();
} }
return subscriptionList;
@Bean }
public Subscription subscriptionOrderClose500(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); @Bean// 订单超时关闭
var subscription = receiveOrderClose5(listenerContainer, 0); public List<Subscription> subscriptionBizOrderClose6(RedisConnectionFactory factory) {
listenerContainer.start(); List<Subscription> subscriptionList = new ArrayList<>();
return subscription; MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_6;
} this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 20; i++) {
@Bean StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
public Subscription subscriptionOrderClose600(RedisConnectionFactory factory) { subscriptionList.add(listenerContainer.receiveAutoAck(
var listenerContainer = this.buildStreamMessageListenerContainer(factory); Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
var subscription = receiveOrderClose6(listenerContainer, 0); StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerOrderClose6RdsReceiver
listenerContainer.start(); ));
return subscription; listenerContainer.start();
} }
return subscriptionList;
@Bean }
public Subscription subscriptionOrderClose700(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); @Bean// 订单超时关闭
var subscription = receiveOrderClose7(listenerContainer, 0); public List<Subscription> subscriptionBizOrderClose7(RedisConnectionFactory factory) {
listenerContainer.start(); List<Subscription> subscriptionList = new ArrayList<>();
return subscription; MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_7;
} this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 20; i++) {
@Bean StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
public Subscription subscriptionOrderClose800(RedisConnectionFactory factory) { subscriptionList.add(listenerContainer.receiveAutoAck(
var listenerContainer = this.buildStreamMessageListenerContainer(factory); Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
var subscription = receiveOrderClose8(listenerContainer, 0); StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerOrderClose7RdsReceiver
listenerContainer.start(); ));
return subscription; listenerContainer.start();
} }
return subscriptionList;
@Bean }
public Subscription subscriptionOrderClose900(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); @Bean// 订单超时关闭
var subscription = receiveOrderClose9(listenerContainer, 0); public List<Subscription> subscriptionBizOrderClose8(RedisConnectionFactory factory) {
listenerContainer.start(); List<Subscription> subscriptionList = new ArrayList<>();
return subscription; MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_8;
} this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 20; i++) {
/* -------------------------------------------------------- ｜ */ StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
subscriptionList.add(listenerContainer.receiveAutoAck(
@Bean Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
public Subscription subscriptionOrderClose001(RedisConnectionFactory factory) { StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerOrderClose8RdsReceiver
var listenerContainer = this.buildStreamMessageListenerContainer(factory); ));
var subscription = receiveOrderClose0(listenerContainer, 1); listenerContainer.start();
listenerContainer.start(); }
return subscription; return subscriptionList;
} }
@Bean @Bean// 订单超时关闭
public Subscription subscriptionOrderClose101(RedisConnectionFactory factory) { public List<Subscription> subscriptionBizOrderClose9(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); List<Subscription> subscriptionList = new ArrayList<>();
var subscription = receiveOrderClose1(listenerContainer, 1); MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_9;
listenerContainer.start(); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
return subscription; for (int i = 0; i < 20; i++) {
} StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
subscriptionList.add(listenerContainer.receiveAutoAck(
@Bean Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
public Subscription subscriptionOrderClose201(RedisConnectionFactory factory) { StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerOrderClose9RdsReceiver
var listenerContainer = this.buildStreamMessageListenerContainer(factory); ));
var subscription = receiveOrderClose2(listenerContainer, 1); listenerContainer.start();
listenerContainer.start(); }
return subscription; return subscriptionList;
} }
@Bean
public Subscription subscriptionOrderClose301(RedisConnectionFactory factory) { // private Subscription receiveOrderClose0(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_UN_PAY_0.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_UN_PAY_0.name() + t)),
var subscription = receiveOrderClose3(listenerContainer, 1); // StreamOffset.create(MQConst.GoblinQueue.GOBLIN_UN_PAY_0.getKey(), ReadOffset.lastConsumed()), consumerOrderClose0RdsReceiver);
listenerContainer.start(); // }
return subscription; //
} // private Subscription receiveOrderClose1(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
// return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_UN_PAY_1.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_UN_PAY_1.name() + t)),
@Bean // StreamOffset.create(MQConst.GoblinQueue.GOBLIN_UN_PAY_1.getKey(), ReadOffset.lastConsumed()), consumerOrderClose1RdsReceiver);
public Subscription subscriptionOrderClose401(RedisConnectionFactory factory) { // }
var listenerContainer = this.buildStreamMessageListenerContainer(factory); //
var subscription = receiveOrderClose4(listenerContainer, 1); // private Subscription receiveOrderClose2(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
listenerContainer.start(); // return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_UN_PAY_2.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_UN_PAY_2.name() + t)),
return subscription; // StreamOffset.create(MQConst.GoblinQueue.GOBLIN_UN_PAY_2.getKey(), ReadOffset.lastConsumed()), consumerOrderClose2RdsReceiver);
} // }
//
@Bean // private Subscription receiveOrderClose3(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
public Subscription subscriptionOrderClose501(RedisConnectionFactory factory) { // return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_UN_PAY_3.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_UN_PAY_3.name() + t)),
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // StreamOffset.create(MQConst.GoblinQueue.GOBLIN_UN_PAY_3.getKey(), ReadOffset.lastConsumed()), consumerOrderClose3RdsReceiver);
var subscription = receiveOrderClose5(listenerContainer, 1); // }
listenerContainer.start(); //
return subscription; // private Subscription receiveOrderClose4(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
} // return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_UN_PAY_4.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_UN_PAY_4.name() + t)),
// StreamOffset.create(MQConst.GoblinQueue.GOBLIN_UN_PAY_4.getKey(), ReadOffset.lastConsumed()), consumerOrderClose4RdsReceiver);
@Bean // }
public Subscription subscriptionOrderClose601(RedisConnectionFactory factory) { //
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // private Subscription receiveOrderClose5(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
var subscription = receiveOrderClose6(listenerContainer, 1); // return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_UN_PAY_5.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_UN_PAY_5.name() + t)),
listenerContainer.start(); // StreamOffset.create(MQConst.GoblinQueue.GOBLIN_UN_PAY_5.getKey(), ReadOffset.lastConsumed()), consumerOrderClose5RdsReceiver);
return subscription; // }
} //
// private Subscription receiveOrderClose6(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
@Bean // return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_UN_PAY_6.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_UN_PAY_6.name() + t)),
public Subscription subscriptionOrderClose701(RedisConnectionFactory factory) { // StreamOffset.create(MQConst.GoblinQueue.GOBLIN_UN_PAY_6.getKey(), ReadOffset.lastConsumed()), consumerOrderClose6RdsReceiver);
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // }
var subscription = receiveOrderClose7(listenerContainer, 1); //
listenerContainer.start(); // private Subscription receiveOrderClose7(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
return subscription; // return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_UN_PAY_7.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_UN_PAY_7.name() + t)),
} // StreamOffset.create(MQConst.GoblinQueue.GOBLIN_UN_PAY_7.getKey(), ReadOffset.lastConsumed()), consumerOrderClose7RdsReceiver);
// }
@Bean //
public Subscription subscriptionOrderClose801(RedisConnectionFactory factory) { // private Subscription receiveOrderClose8(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_UN_PAY_8.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_UN_PAY_8.name() + t)),
var subscription = receiveOrderClose8(listenerContainer, 1); // StreamOffset.create(MQConst.GoblinQueue.GOBLIN_UN_PAY_8.getKey(), ReadOffset.lastConsumed()), consumerOrderClose8RdsReceiver);
listenerContainer.start(); // }
return subscription; //
} // private Subscription receiveOrderClose9(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
// return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_UN_PAY_9.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_UN_PAY_9.name() + t)),
@Bean // StreamOffset.create(MQConst.GoblinQueue.GOBLIN_UN_PAY_9.getKey(), ReadOffset.lastConsumed()), consumerOrderClose9RdsReceiver);
public Subscription subscriptionOrderClose901(RedisConnectionFactory factory) { // }
var listenerContainer = this.buildStreamMessageListenerContainer(factory); //
var subscription = receiveOrderClose9(listenerContainer, 1); // /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
listenerContainer.start(); //
return subscription; // /* -------------------------------------------------------- ｜ 订单关闭 */
} //
// @Bean
/* -------------------------------------------------------- ｜ */ // public Subscription subscriptionOrderClose000(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose0(listenerContainer, 0);
public Subscription subscriptionOrderClose002(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose0(listenerContainer, 2); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose100(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose1(listenerContainer, 0);
public Subscription subscriptionOrderClose102(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose1(listenerContainer, 2); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose200(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose2(listenerContainer, 0);
public Subscription subscriptionOrderClose202(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose2(listenerContainer, 2); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose300(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose3(listenerContainer, 0);
public Subscription subscriptionOrderClose302(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose3(listenerContainer, 2); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose400(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose4(listenerContainer, 0);
public Subscription subscriptionOrderClose402(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose4(listenerContainer, 2); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose500(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose5(listenerContainer, 0);
public Subscription subscriptionOrderClose502(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose5(listenerContainer, 2); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose600(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose6(listenerContainer, 0);
public Subscription subscriptionOrderClose602(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose6(listenerContainer, 2); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose700(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose7(listenerContainer, 0);
public Subscription subscriptionOrderClose702(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose7(listenerContainer, 2); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose800(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose8(listenerContainer, 0);
public Subscription subscriptionOrderClose802(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose8(listenerContainer, 2); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose900(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose9(listenerContainer, 0);
public Subscription subscriptionOrderClose902(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose9(listenerContainer, 2); // }
listenerContainer.start(); //
return subscription; // /* -------------------------------------------------------- ｜ */
} //
// @Bean
/* -------------------------------------------------------- ｜ */ // public Subscription subscriptionOrderClose001(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose0(listenerContainer, 1);
public Subscription subscriptionOrderClose003(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose0(listenerContainer, 3); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose101(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose1(listenerContainer, 1);
public Subscription subscriptionOrderClose103(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose1(listenerContainer, 3); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose201(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose2(listenerContainer, 1);
public Subscription subscriptionOrderClose203(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose2(listenerContainer, 3); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose301(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose3(listenerContainer, 1);
public Subscription subscriptionOrderClose303(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose3(listenerContainer, 3); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose401(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose4(listenerContainer, 1);
public Subscription subscriptionOrderClose403(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose4(listenerContainer, 3); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose501(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose5(listenerContainer, 1);
public Subscription subscriptionOrderClose503(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose5(listenerContainer, 3); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose601(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose6(listenerContainer, 1);
public Subscription subscriptionOrderClose603(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose6(listenerContainer, 3); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose701(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose7(listenerContainer, 1);
public Subscription subscriptionOrderClose703(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose7(listenerContainer, 3); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose801(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose8(listenerContainer, 1);
public Subscription subscriptionOrderClose803(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose8(listenerContainer, 3); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose901(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose9(listenerContainer, 1);
public Subscription subscriptionOrderClose903(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose9(listenerContainer, 3); // }
listenerContainer.start(); //
return subscription; // /* -------------------------------------------------------- ｜ */
} //
// @Bean
/* -------------------------------------------------------- ｜ */ // public Subscription subscriptionOrderClose002(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose0(listenerContainer, 2);
public Subscription subscriptionOrderClose004(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose0(listenerContainer, 4); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose102(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose1(listenerContainer, 2);
public Subscription subscriptionOrderClose104(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose1(listenerContainer, 4); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose202(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose2(listenerContainer, 2);
public Subscription subscriptionOrderClose204(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose2(listenerContainer, 4); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose302(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose3(listenerContainer, 2);
public Subscription subscriptionOrderClose304(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose3(listenerContainer, 4); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose402(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose4(listenerContainer, 2);
public Subscription subscriptionOrderClose404(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose4(listenerContainer, 4); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose502(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose5(listenerContainer, 2);
public Subscription subscriptionOrderClose504(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose5(listenerContainer, 4); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose602(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose6(listenerContainer, 2);
public Subscription subscriptionOrderClose604(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose6(listenerContainer, 4); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose702(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose7(listenerContainer, 2);
public Subscription subscriptionOrderClose704(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose7(listenerContainer, 4); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose802(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose8(listenerContainer, 2);
public Subscription subscriptionOrderClose804(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose8(listenerContainer, 4); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose902(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose9(listenerContainer, 2);
public Subscription subscriptionOrderClose904(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose9(listenerContainer, 4); // }
listenerContainer.start(); //
return subscription; // /* -------------------------------------------------------- ｜ */
} //
// @Bean
/* -------------------------------------------------------- ｜ */ // public Subscription subscriptionOrderClose003(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose0(listenerContainer, 3);
public Subscription subscriptionOrderClose005(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose0(listenerContainer, 5); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose103(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose1(listenerContainer, 3);
public Subscription subscriptionOrderClose105(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose1(listenerContainer, 5); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose203(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose2(listenerContainer, 3);
public Subscription subscriptionOrderClose205(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose2(listenerContainer, 5); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose303(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose3(listenerContainer, 3);
public Subscription subscriptionOrderClose305(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose3(listenerContainer, 5); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose403(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose4(listenerContainer, 3);
public Subscription subscriptionOrderClose405(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose4(listenerContainer, 5); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose503(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose5(listenerContainer, 3);
public Subscription subscriptionOrderClose505(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose5(listenerContainer, 5); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose603(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose6(listenerContainer, 3);
public Subscription subscriptionOrderClose605(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose6(listenerContainer, 5); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose703(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose7(listenerContainer, 3);
public Subscription subscriptionOrderClose705(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose7(listenerContainer, 5); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose803(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose8(listenerContainer, 3);
public Subscription subscriptionOrderClose805(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose8(listenerContainer, 5); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose903(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose9(listenerContainer, 3);
public Subscription subscriptionOrderClose905(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose9(listenerContainer, 5); // }
listenerContainer.start(); //
return subscription; // /* -------------------------------------------------------- ｜ */
} //
// @Bean
/* -------------------------------------------------------- ｜ */ // public Subscription subscriptionOrderClose004(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose0(listenerContainer, 4);
public Subscription subscriptionOrderClose006(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose0(listenerContainer, 6); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose104(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose1(listenerContainer, 4);
public Subscription subscriptionOrderClose106(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose1(listenerContainer, 6); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose204(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose2(listenerContainer, 4);
public Subscription subscriptionOrderClose206(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose2(listenerContainer, 6); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose304(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose3(listenerContainer, 4);
public Subscription subscriptionOrderClose306(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose3(listenerContainer, 6); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose404(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose4(listenerContainer, 4);
public Subscription subscriptionOrderClose406(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose4(listenerContainer, 6); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose504(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose5(listenerContainer, 4);
public Subscription subscriptionOrderClose506(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose5(listenerContainer, 6); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose604(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose6(listenerContainer, 4);
public Subscription subscriptionOrderClose606(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose6(listenerContainer, 6); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose704(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose7(listenerContainer, 4);
public Subscription subscriptionOrderClose706(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose7(listenerContainer, 6); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose804(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose8(listenerContainer, 4);
public Subscription subscriptionOrderClose806(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose8(listenerContainer, 6); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose904(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose9(listenerContainer, 4);
public Subscription subscriptionOrderClose906(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose9(listenerContainer, 6); // }
listenerContainer.start(); //
return subscription; // /* -------------------------------------------------------- ｜ */
} //
// @Bean
/* -------------------------------------------------------- ｜ */ // public Subscription subscriptionOrderClose005(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose0(listenerContainer, 5);
public Subscription subscriptionOrderClose007(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose0(listenerContainer, 7); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose105(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose1(listenerContainer, 5);
public Subscription subscriptionOrderClose107(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose1(listenerContainer, 7); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose205(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose2(listenerContainer, 5);
public Subscription subscriptionOrderClose207(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose2(listenerContainer, 7); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose305(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose3(listenerContainer, 5);
public Subscription subscriptionOrderClose307(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose3(listenerContainer, 7); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose405(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose4(listenerContainer, 5);
public Subscription subscriptionOrderClose407(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose4(listenerContainer, 7); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose505(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose5(listenerContainer, 5);
public Subscription subscriptionOrderClose507(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose5(listenerContainer, 7); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose605(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose6(listenerContainer, 5);
public Subscription subscriptionOrderClose607(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose6(listenerContainer, 7); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose705(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose7(listenerContainer, 5);
public Subscription subscriptionOrderClose707(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose7(listenerContainer, 7); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose805(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose8(listenerContainer, 5);
public Subscription subscriptionOrderClose807(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose8(listenerContainer, 7); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose905(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose9(listenerContainer, 5);
public Subscription subscriptionOrderClose907(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose9(listenerContainer, 7); // }
listenerContainer.start(); //
return subscription; // /* -------------------------------------------------------- ｜ */
} //
// @Bean
/* -------------------------------------------------------- ｜ */ // public Subscription subscriptionOrderClose006(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose0(listenerContainer, 6);
public Subscription subscriptionOrderClose008(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose0(listenerContainer, 8); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose106(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose1(listenerContainer, 6);
public Subscription subscriptionOrderClose108(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose1(listenerContainer, 8); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose206(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose2(listenerContainer, 6);
public Subscription subscriptionOrderClose208(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose2(listenerContainer, 8); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose306(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose3(listenerContainer, 6);
public Subscription subscriptionOrderClose308(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose3(listenerContainer, 8); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose406(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose4(listenerContainer, 6);
public Subscription subscriptionOrderClose408(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose4(listenerContainer, 8); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose506(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose5(listenerContainer, 6);
public Subscription subscriptionOrderClose508(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose5(listenerContainer, 8); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose606(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose6(listenerContainer, 6);
public Subscription subscriptionOrderClose608(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose6(listenerContainer, 8); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose706(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose7(listenerContainer, 6);
public Subscription subscriptionOrderClose708(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose7(listenerContainer, 8); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose806(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose8(listenerContainer, 6);
public Subscription subscriptionOrderClose808(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose8(listenerContainer, 8); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose906(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose9(listenerContainer, 6);
public Subscription subscriptionOrderClose908(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose9(listenerContainer, 8); // }
listenerContainer.start(); //
return subscription; // /* -------------------------------------------------------- ｜ */
} //
// @Bean
/* -------------------------------------------------------- ｜ */ // public Subscription subscriptionOrderClose007(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose0(listenerContainer, 7);
public Subscription subscriptionOrderClose009(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose0(listenerContainer, 9); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose107(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose1(listenerContainer, 7);
public Subscription subscriptionOrderClose109(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose1(listenerContainer, 9); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose207(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose2(listenerContainer, 7);
public Subscription subscriptionOrderClose209(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose2(listenerContainer, 9); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose307(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose3(listenerContainer, 7);
public Subscription subscriptionOrderClose309(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose3(listenerContainer, 9); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose407(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose4(listenerContainer, 7);
public Subscription subscriptionOrderClose409(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose4(listenerContainer, 9); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose507(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose5(listenerContainer, 7);
public Subscription subscriptionOrderClose509(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose5(listenerContainer, 9); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose607(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose6(listenerContainer, 7);
public Subscription subscriptionOrderClose609(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose6(listenerContainer, 9); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose707(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose7(listenerContainer, 7);
public Subscription subscriptionOrderClose709(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose7(listenerContainer, 9); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose807(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose8(listenerContainer, 7);
public Subscription subscriptionOrderClose809(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose8(listenerContainer, 9); // }
listenerContainer.start(); //
return subscription; // @Bean
} // public Subscription subscriptionOrderClose907(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
@Bean // var subscription = receiveOrderClose9(listenerContainer, 7);
public Subscription subscriptionOrderClose909(RedisConnectionFactory factory) { // listenerContainer.start();
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // return subscription;
var subscription = receiveOrderClose9(listenerContainer, 9); // }
listenerContainer.start(); //
return subscription; // /* -------------------------------------------------------- ｜ */
} //
// @Bean
/* -------------------------------------------------------- ｜ */ // public Subscription subscriptionOrderClose008(RedisConnectionFactory factory) {
} // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveOrderClose0(listenerContainer, 8);
// listenerContainer.start();
// return subscription;
// }
//
// @Bean
// public Subscription subscriptionOrderClose108(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveOrderClose1(listenerContainer, 8);
// listenerContainer.start();
// return subscription;
// }
//
// @Bean
// public Subscription subscriptionOrderClose208(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveOrderClose2(listenerContainer, 8);
// listenerContainer.start();
// return subscription;
// }
//
// @Bean
// public Subscription subscriptionOrderClose308(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveOrderClose3(listenerContainer, 8);
// listenerContainer.start();
// return subscription;
// }
//
// @Bean
// public Subscription subscriptionOrderClose408(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveOrderClose4(listenerContainer, 8);
// listenerContainer.start();
// return subscription;
// }
//
// @Bean
// public Subscription subscriptionOrderClose508(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveOrderClose5(listenerContainer, 8);
// listenerContainer.start();
// return subscription;
// }
//
// @Bean
// public Subscription subscriptionOrderClose608(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveOrderClose6(listenerContainer, 8);
// listenerContainer.start();
// return subscription;
// }
//
// @Bean
// public Subscription subscriptionOrderClose708(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveOrderClose7(listenerContainer, 8);
// listenerContainer.start();
// return subscription;
// }
//
// @Bean
// public Subscription subscriptionOrderClose808(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveOrderClose8(listenerContainer, 8);
// listenerContainer.start();
// return subscription;
// }
//
// @Bean
// public Subscription subscriptionOrderClose908(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveOrderClose9(listenerContainer, 8);
// listenerContainer.start();
// return subscription;
// }
//
// /* -------------------------------------------------------- ｜ */
//
// @Bean
// public Subscription subscriptionOrderClose009(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveOrderClose0(listenerContainer, 9);
// listenerContainer.start();
// return subscription;
// }
//
// @Bean
// public Subscription subscriptionOrderClose109(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveOrderClose1(listenerContainer, 9);
// listenerContainer.start();
// return subscription;
// }
//
// @Bean
// public Subscription subscriptionOrderClose209(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveOrderClose2(listenerContainer, 9);
// listenerContainer.start();
// return subscription;
// }
//
// @Bean
// public Subscription subscriptionOrderClose309(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveOrderClose3(listenerContainer, 9);
// listenerContainer.start();
// return subscription;
// }
//
// @Bean
// public Subscription subscriptionOrderClose409(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveOrderClose4(listenerContainer, 9);
// listenerContainer.start();
// return subscription;
// }
//
// @Bean
// public Subscription subscriptionOrderClose509(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveOrderClose5(listenerContainer, 9);
// listenerContainer.start();
// return subscription;
// }
//
// @Bean
// public Subscription subscriptionOrderClose609(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveOrderClose6(listenerContainer, 9);
// listenerContainer.start();
// return subscription;
// }
//
// @Bean
// public Subscription subscriptionOrderClose709(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveOrderClose7(listenerContainer, 9);
// listenerContainer.start();
// return subscription;
// }
//
// @Bean
// public Subscription subscriptionOrderClose809(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveOrderClose8(listenerContainer, 9);
// listenerContainer.start();
// return subscription;
// }
//
// @Bean
// public Subscription subscriptionOrderClose909(RedisConnectionFactory factory) {
// var listenerContainer = this.buildStreamMessageListenerContainer(factory);
// var subscription = receiveOrderClose9(listenerContainer, 9);
// listenerContainer.start();
// return subscription;
// }
//
// /* -------------------------------------------------------- ｜ */
}
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment