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

Commit dc7b1baf authored by zhanggb's avatar zhanggb

~consumer:listener.count;

parent 769a017e
...@@ -30,7 +30,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig { ...@@ -30,7 +30,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 < 15; i++) { for (int i = 0; i < 20; 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)),
......
...@@ -48,7 +48,7 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig { ...@@ -48,7 +48,7 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig {
List<Subscription> subscriptionList = new ArrayList<>(); List<Subscription> subscriptionList = new ArrayList<>();
MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_0; MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_0;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup()); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 10; i++) { for (int i = 0; i < 5; 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)),
...@@ -64,7 +64,7 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig { ...@@ -64,7 +64,7 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig {
List<Subscription> subscriptionList = new ArrayList<>(); List<Subscription> subscriptionList = new ArrayList<>();
MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_1; MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_1;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup()); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 10; i++) { for (int i = 0; i < 5; 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)),
...@@ -80,7 +80,7 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig { ...@@ -80,7 +80,7 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig {
List<Subscription> subscriptionList = new ArrayList<>(); List<Subscription> subscriptionList = new ArrayList<>();
MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_2; MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_2;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup()); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 10; i++) { for (int i = 0; i < 5; 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)),
...@@ -96,7 +96,7 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig { ...@@ -96,7 +96,7 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig {
List<Subscription> subscriptionList = new ArrayList<>(); List<Subscription> subscriptionList = new ArrayList<>();
MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_3; MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_3;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup()); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 10; i++) { for (int i = 0; i < 5; 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)),
...@@ -112,7 +112,7 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig { ...@@ -112,7 +112,7 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig {
List<Subscription> subscriptionList = new ArrayList<>(); List<Subscription> subscriptionList = new ArrayList<>();
MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_4; MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_4;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup()); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 10; i++) { for (int i = 0; i < 5; 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)),
...@@ -128,7 +128,7 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig { ...@@ -128,7 +128,7 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig {
List<Subscription> subscriptionList = new ArrayList<>(); List<Subscription> subscriptionList = new ArrayList<>();
MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_5; MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_5;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup()); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 10; i++) { for (int i = 0; i < 5; 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)),
...@@ -144,7 +144,7 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig { ...@@ -144,7 +144,7 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig {
List<Subscription> subscriptionList = new ArrayList<>(); List<Subscription> subscriptionList = new ArrayList<>();
MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_6; MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_6;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup()); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 10; i++) { for (int i = 0; i < 5; 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)),
...@@ -160,7 +160,7 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig { ...@@ -160,7 +160,7 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig {
List<Subscription> subscriptionList = new ArrayList<>(); List<Subscription> subscriptionList = new ArrayList<>();
MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_7; MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_7;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup()); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 10; i++) { for (int i = 0; i < 5; 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)),
...@@ -176,7 +176,7 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig { ...@@ -176,7 +176,7 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig {
List<Subscription> subscriptionList = new ArrayList<>(); List<Subscription> subscriptionList = new ArrayList<>();
MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_8; MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_8;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup()); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 10; i++) { for (int i = 0; i < 5; 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)),
...@@ -192,7 +192,7 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig { ...@@ -192,7 +192,7 @@ public class ConsumerOrderCloseRedisStreamConfig extends RedisStreamConfig {
List<Subscription> subscriptionList = new ArrayList<>(); List<Subscription> subscriptionList = new ArrayList<>();
MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_9; MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_UN_PAY_9;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup()); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 10; i++) { for (int i = 0; i < 5; 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)),
......
...@@ -88,7 +88,7 @@ public class ConsumerCommonBizRedisStreamConfig extends RedisStreamConfig { ...@@ -88,7 +88,7 @@ public class ConsumerCommonBizRedisStreamConfig extends RedisStreamConfig {
List<Subscription> subscriptionList = new ArrayList<>(); List<Subscription> subscriptionList = new ArrayList<>();
MQConst.GoblinQueue stream = MQConst.GoblinQueue.BIZ_INTEGRAL; MQConst.GoblinQueue stream = MQConst.GoblinQueue.BIZ_INTEGRAL;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup()); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 10; i++) { for (int i = 0; i < 1; 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)),
...@@ -104,7 +104,7 @@ public class ConsumerCommonBizRedisStreamConfig extends RedisStreamConfig { ...@@ -104,7 +104,7 @@ public class ConsumerCommonBizRedisStreamConfig extends RedisStreamConfig {
List<Subscription> subscriptionList = new ArrayList<>(); List<Subscription> subscriptionList = new ArrayList<>();
MQConst.GoblinQueue stream = MQConst.GoblinQueue.BIZ_NFT_MONGO; MQConst.GoblinQueue stream = MQConst.GoblinQueue.BIZ_NFT_MONGO;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup()); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 10; i++) { for (int i = 0; i < 3; 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)),
...@@ -115,19 +115,19 @@ public class ConsumerCommonBizRedisStreamConfig extends RedisStreamConfig { ...@@ -115,19 +115,19 @@ public class ConsumerCommonBizRedisStreamConfig extends RedisStreamConfig {
return subscriptionList; return subscriptionList;
} }
// @Bean// NFT数字藏品 mongo操作 @Bean// NFT数字藏品 mongo操作
// public List<Subscription> subscriptionBizNftArtwork(RedisConnectionFactory factory) { public List<Subscription> subscriptionBizNftArtwork(RedisConnectionFactory factory) {
// List<Subscription> subscriptionList = new ArrayList<>(); List<Subscription> subscriptionList = new ArrayList<>();
// MQConst.GoblinQueue stream = MQConst.GoblinQueue.BIZ_ARTWORK_GEN; MQConst.GoblinQueue stream = MQConst.GoblinQueue.BIZ_ARTWORK_GEN;
// this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup()); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
// for (int i = 0; i < 5; i++) { for (int i = 0; i < 1; 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)),
// StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinMdbNftArtworkReceiver StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinMdbNftArtworkReceiver
// )); ));
// listenerContainer.start(); listenerContainer.start();
// } }
// return subscriptionList; return subscriptionList;
// } }
} }
...@@ -70,7 +70,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig { ...@@ -70,7 +70,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
List<Subscription> subscriptionList = new ArrayList<>(); List<Subscription> subscriptionList = new ArrayList<>();
MQConst.GoblinQueue stream = MQConst.GoblinQueue.SQL_COUPON; MQConst.GoblinQueue stream = MQConst.GoblinQueue.SQL_COUPON;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup()); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 5; i++) { for (int i = 0; i < 1; 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)),
...@@ -86,7 +86,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig { ...@@ -86,7 +86,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
List<Subscription> subscriptionList = new ArrayList<>(); List<Subscription> subscriptionList = new ArrayList<>();
MQConst.GoblinQueue stream = MQConst.GoblinQueue.SQL_ARTWORK_GEN; MQConst.GoblinQueue stream = MQConst.GoblinQueue.SQL_ARTWORK_GEN;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup()); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 5; i++) { for (int i = 0; i < 1; 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)),
......
...@@ -41,7 +41,7 @@ public class ConsumerGalaxySqlNftOrderFailLogConfig extends RedisStreamConfig { ...@@ -41,7 +41,7 @@ public class ConsumerGalaxySqlNftOrderFailLogConfig extends RedisStreamConfig {
MQConst.GalaxyQueue stream = MQConst.GalaxyQueue.SQL_NFT_ORDER_FAIL_LOG; MQConst.GalaxyQueue stream = MQConst.GalaxyQueue.SQL_NFT_ORDER_FAIL_LOG;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup()); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 10; i++) { for (int i = 0; i < 1; 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)),
......
...@@ -41,7 +41,7 @@ public class ConsumerGalaxySqlNftOrderInfoConfig extends RedisStreamConfig { ...@@ -41,7 +41,7 @@ public class ConsumerGalaxySqlNftOrderInfoConfig extends RedisStreamConfig {
MQConst.GalaxyQueue stream = MQConst.GalaxyQueue.SQL_NFT_ORDER_INFO; MQConst.GalaxyQueue stream = MQConst.GalaxyQueue.SQL_NFT_ORDER_INFO;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup()); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 10; i++) { for (int i = 0; i < 1; 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)),
......
...@@ -41,7 +41,7 @@ public class ConsumerGalaxySqlNftTradeInfoConfig extends RedisStreamConfig { ...@@ -41,7 +41,7 @@ public class ConsumerGalaxySqlNftTradeInfoConfig extends RedisStreamConfig {
MQConst.GalaxyQueue stream = MQConst.GalaxyQueue.SQL_NFT_TRADE_INFO; MQConst.GalaxyQueue stream = MQConst.GalaxyQueue.SQL_NFT_TRADE_INFO;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup()); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 10; i++) { for (int i = 0; i < 1; 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)),
......
...@@ -41,7 +41,7 @@ public class ConsumerGalaxySqlUserInfoConfig extends RedisStreamConfig { ...@@ -41,7 +41,7 @@ public class ConsumerGalaxySqlUserInfoConfig extends RedisStreamConfig {
MQConst.GalaxyQueue stream = MQConst.GalaxyQueue.SQL_USER_INFO; MQConst.GalaxyQueue stream = MQConst.GalaxyQueue.SQL_USER_INFO;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup()); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 10; i++) { for (int i = 0; i < 1; 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)),
......
...@@ -44,21 +44,21 @@ public class ConsumerGoblinOrderCRedisStreamConfig extends RedisStreamConfig { ...@@ -44,21 +44,21 @@ public class ConsumerGoblinOrderCRedisStreamConfig extends RedisStreamConfig {
return subscription; return subscription;
} }
@Bean // @Bean
public Subscription subscriptionGoblinOrderC1(RedisConnectionFactory factory) { // public Subscription subscriptionGoblinOrderC1(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveGoblinOrderCOrder(listenerContainer, 1); // var subscription = receiveGoblinOrderCOrder(listenerContainer, 1);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionGoblinOrderC2(RedisConnectionFactory factory) { // public Subscription subscriptionGoblinOrderC2(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveGoblinOrderCOrder(listenerContainer, 2); // var subscription = receiveGoblinOrderCOrder(listenerContainer, 2);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
......
...@@ -44,21 +44,21 @@ public class ConsumerGoblinSelfMarketRedisStreamConfig extends RedisStreamConfig ...@@ -44,21 +44,21 @@ public class ConsumerGoblinSelfMarketRedisStreamConfig extends RedisStreamConfig
return subscription; return subscription;
} }
@Bean // @Bean
public Subscription subscriptionGoblinSelfMarket1(RedisConnectionFactory factory) { // public Subscription subscriptionGoblinSelfMarket1(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveGoblinSelfMarket(listenerContainer, 1); // var subscription = receiveGoblinSelfMarket(listenerContainer, 1);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionGoblinSelfMarket2(RedisConnectionFactory factory) { // public Subscription subscriptionGoblinSelfMarket2(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveGoblinSelfMarket(listenerContainer, 2); // var subscription = receiveGoblinSelfMarket(listenerContainer, 2);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
/* -------------------------------------------------------- | */ /* -------------------------------------------------------- | */
} }
...@@ -39,37 +39,37 @@ public class ConsumerGoblinShopCartStreamConfig extends RedisStreamConfig { ...@@ -39,37 +39,37 @@ public class ConsumerGoblinShopCartStreamConfig extends RedisStreamConfig {
return subscription; return subscription;
} }
@Bean // @Bean
public Subscription subscriptionSqlShopCart1(RedisConnectionFactory factory) { // public Subscription subscriptionSqlShopCart1(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlShopCart(listenerContainer, 1); // var subscription = receiveSqlShopCart(listenerContainer, 1);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionSqlShopCart2(RedisConnectionFactory factory) { // public Subscription subscriptionSqlShopCart2(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlShopCart(listenerContainer, 2); // var subscription = receiveSqlShopCart(listenerContainer, 2);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionSqlShopCart3(RedisConnectionFactory factory) { // public Subscription subscriptionSqlShopCart3(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlShopCart(listenerContainer, 3); // var subscription = receiveSqlShopCart(listenerContainer, 3);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionSqlShopCart4(RedisConnectionFactory factory) { // public Subscription subscriptionSqlShopCart4(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlShopCart(listenerContainer, 4); // var subscription = receiveSqlShopCart(listenerContainer, 4);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
/* -------------------------------------------------------- | */ /* -------------------------------------------------------- | */
......
...@@ -44,21 +44,21 @@ public class ConsumerGoblinStoneMarketRedisStreamConfig extends RedisStreamConfi ...@@ -44,21 +44,21 @@ public class ConsumerGoblinStoneMarketRedisStreamConfig extends RedisStreamConfi
return subscription; return subscription;
} }
@Bean // @Bean
public Subscription subscriptionGoblinStoreMarket1(RedisConnectionFactory factory) { // public Subscription subscriptionGoblinStoreMarket1(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveGoblinStoreMarket(listenerContainer, 1); // var subscription = receiveGoblinStoreMarket(listenerContainer, 1);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionGoblinStoreMarket2(RedisConnectionFactory factory) { // public Subscription subscriptionGoblinStoreMarket2(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveGoblinStoreMarket(listenerContainer, 2); // var subscription = receiveGoblinStoreMarket(listenerContainer, 2);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
/* -------------------------------------------------------- | */ /* -------------------------------------------------------- | */
} }
...@@ -44,21 +44,21 @@ public class ConsumerGoblinStoreOrderRedisStreamConfig extends RedisStreamConfig ...@@ -44,21 +44,21 @@ public class ConsumerGoblinStoreOrderRedisStreamConfig extends RedisStreamConfig
return subscription; return subscription;
} }
@Bean // @Bean
public Subscription subscriptionGoblinStoreOrder1(RedisConnectionFactory factory) { // public Subscription subscriptionGoblinStoreOrder1(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveGoblinStoreOrder(listenerContainer, 1); // var subscription = receiveGoblinStoreOrder(listenerContainer, 1);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionGoblinStoreOrder2(RedisConnectionFactory factory) { // public Subscription subscriptionGoblinStoreOrder2(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveGoblinStoreOrder(listenerContainer, 2); // var subscription = receiveGoblinStoreOrder(listenerContainer, 2);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
/* -------------------------------------------------------- | */ /* -------------------------------------------------------- | */
} }
...@@ -44,21 +44,21 @@ public class ConsumerGoblinUserOrderRedisStreamConfig extends RedisStreamConfig ...@@ -44,21 +44,21 @@ public class ConsumerGoblinUserOrderRedisStreamConfig extends RedisStreamConfig
return subscription; return subscription;
} }
@Bean // @Bean
public Subscription subscriptionGoblinUserOrder1(RedisConnectionFactory factory) { // public Subscription subscriptionGoblinUserOrder1(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveGoblinUserOrder(listenerContainer, 1); // var subscription = receiveGoblinUserOrder(listenerContainer, 1);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionGoblinUserOrder2(RedisConnectionFactory factory) { // public Subscription subscriptionGoblinUserOrder2(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveGoblinUserOrder(listenerContainer, 2); // var subscription = receiveGoblinUserOrder(listenerContainer, 2);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
/* -------------------------------------------------------- | */ /* -------------------------------------------------------- | */
} }
...@@ -60,61 +60,61 @@ public class ConsumerKylinSmsSenderRedisStreamConfig extends RedisStreamConfig { ...@@ -60,61 +60,61 @@ public class ConsumerKylinSmsSenderRedisStreamConfig extends RedisStreamConfig {
return subscription; return subscription;
} }
@Bean // @Bean
public Subscription subscriptionSmsNotice3(RedisConnectionFactory factory) { // public Subscription subscriptionSmsNotice3(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlURegister(listenerContainer, 3); // var subscription = receiveSqlURegister(listenerContainer, 3);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionSmsNotice4(RedisConnectionFactory factory) { // public Subscription subscriptionSmsNotice4(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlURegister(listenerContainer, 4); // var subscription = receiveSqlURegister(listenerContainer, 4);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionSmsNotice5(RedisConnectionFactory factory) { // public Subscription subscriptionSmsNotice5(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlURegister(listenerContainer, 5); // var subscription = receiveSqlURegister(listenerContainer, 5);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionSmsNotice6(RedisConnectionFactory factory) { // public Subscription subscriptionSmsNotice6(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlURegister(listenerContainer, 6); // var subscription = receiveSqlURegister(listenerContainer, 6);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionSmsNotice7(RedisConnectionFactory factory) { // public Subscription subscriptionSmsNotice7(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlURegister(listenerContainer, 7); // var subscription = receiveSqlURegister(listenerContainer, 7);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionSmsNotice8(RedisConnectionFactory factory) { // public Subscription subscriptionSmsNotice8(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlURegister(listenerContainer, 8); // var subscription = receiveSqlURegister(listenerContainer, 8);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionSmsNotice9(RedisConnectionFactory factory) { // public Subscription subscriptionSmsNotice9(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlURegister(listenerContainer, 9); // var subscription = receiveSqlURegister(listenerContainer, 9);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
/* -------------------------------------------------------- | */ /* -------------------------------------------------------- | */
} }
...@@ -45,21 +45,21 @@ public class ConsumerKylinSqlOrderWithdrawRedisStreamConfig extends RedisStreamC ...@@ -45,21 +45,21 @@ public class ConsumerKylinSqlOrderWithdrawRedisStreamConfig extends RedisStreamC
return subscription; return subscription;
} }
@Bean // @Bean
public Subscription subscriptionSqlOrderWithdraw1(RedisConnectionFactory factory) { // public Subscription subscriptionSqlOrderWithdraw1(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlOrderWithdraw(listenerContainer, 1); // var subscription = receiveSqlOrderWithdraw(listenerContainer, 1);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionSqlOrderWithdraw2(RedisConnectionFactory factory) { // public Subscription subscriptionSqlOrderWithdraw2(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlOrderWithdraw(listenerContainer, 2); // var subscription = receiveSqlOrderWithdraw(listenerContainer, 2);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
// @Bean // @Bean
// public Subscription subscriptionSqlOrderWithdraw3(RedisConnectionFactory factory) { // public Subscription subscriptionSqlOrderWithdraw3(RedisConnectionFactory factory) {
......
...@@ -45,37 +45,37 @@ public class ConsumerKylinSqlStationRedisStreamConfig extends RedisStreamConfig ...@@ -45,37 +45,37 @@ public class ConsumerKylinSqlStationRedisStreamConfig extends RedisStreamConfig
return subscription; return subscription;
} }
@Bean // @Bean
public Subscription subscriptionSqlStation1(RedisConnectionFactory factory) { // public Subscription subscriptionSqlStation1(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlStation(listenerContainer, 1); // var subscription = receiveSqlStation(listenerContainer, 1);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionSqlStation2(RedisConnectionFactory factory) { // public Subscription subscriptionSqlStation2(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlStation(listenerContainer, 2); // var subscription = receiveSqlStation(listenerContainer, 2);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionSqlStation3(RedisConnectionFactory factory) { // public Subscription subscriptionSqlStation3(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlStation(listenerContainer, 3); // var subscription = receiveSqlStation(listenerContainer, 3);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionSqlStation4(RedisConnectionFactory factory) { // public Subscription subscriptionSqlStation4(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlStation(listenerContainer, 4); // var subscription = receiveSqlStation(listenerContainer, 4);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
/* -------------------------------------------------------- | */ /* -------------------------------------------------------- | */
} }
...@@ -45,21 +45,21 @@ public class ConsumerKylinSqlTransferRedisStreamConfig extends RedisStreamConfig ...@@ -45,21 +45,21 @@ public class ConsumerKylinSqlTransferRedisStreamConfig extends RedisStreamConfig
return subscription; return subscription;
} }
@Bean // @Bean
public Subscription subscriptionReceiveTransfer1(RedisConnectionFactory factory) { // public Subscription subscriptionReceiveTransfer1(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveTransfer(listenerContainer, 1); // var subscription = receiveTransfer(listenerContainer, 1);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionReceiveTransfer2(RedisConnectionFactory factory) { // public Subscription subscriptionReceiveTransfer2(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveTransfer(listenerContainer, 2); // var subscription = receiveTransfer(listenerContainer, 2);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
// @Bean // @Bean
// public Subscription subscriptionReceiveTransfer3(RedisConnectionFactory factory) { // public Subscription subscriptionReceiveTransfer3(RedisConnectionFactory factory) {
......
...@@ -45,21 +45,21 @@ public class ConsumerKylinSqlTransferResultRedisStreamConfig extends RedisStream ...@@ -45,21 +45,21 @@ public class ConsumerKylinSqlTransferResultRedisStreamConfig extends RedisStream
return subscription; return subscription;
} }
@Bean // @Bean
public Subscription subscriptionReceiveTransferResult1(RedisConnectionFactory factory) { // public Subscription subscriptionReceiveTransferResult1(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveTransferResult(listenerContainer, 1); // var subscription = receiveTransferResult(listenerContainer, 1);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionReceiveTransferResult2(RedisConnectionFactory factory) { // public Subscription subscriptionReceiveTransferResult2(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveTransferResult(listenerContainer, 2); // var subscription = receiveTransferResult(listenerContainer, 2);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
// @Bean // @Bean
// public Subscription subscriptionReceiveTransferResult3(RedisConnectionFactory factory) { // public Subscription subscriptionReceiveTransferResult3(RedisConnectionFactory factory) {
......
...@@ -44,21 +44,21 @@ public class ConsumerSlimeFieldRedisStreamConfig extends RedisStreamConfig { ...@@ -44,21 +44,21 @@ public class ConsumerSlimeFieldRedisStreamConfig extends RedisStreamConfig {
return subscription; return subscription;
} }
@Bean // @Bean
public Subscription subscriptionReceiveSqlField1(RedisConnectionFactory factory) { // public Subscription subscriptionReceiveSqlField1(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlField(listenerContainer, 1); // var subscription = receiveSqlField(listenerContainer, 1);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionReceiveSqlField2(RedisConnectionFactory factory) { // public Subscription subscriptionReceiveSqlField2(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlField(listenerContainer, 2); // var subscription = receiveSqlField(listenerContainer, 2);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
// @Bean // @Bean
// public Subscription subscriptionReceiveSqlField3(RedisConnectionFactory factory) { // public Subscription subscriptionReceiveSqlField3(RedisConnectionFactory factory) {
......
...@@ -44,21 +44,21 @@ public class ConsumerSlimeLineRedisStreamConfig extends RedisStreamConfig { ...@@ -44,21 +44,21 @@ public class ConsumerSlimeLineRedisStreamConfig extends RedisStreamConfig {
return subscription; return subscription;
} }
@Bean // @Bean
public Subscription subscriptionReceiveLine1(RedisConnectionFactory factory) { // public Subscription subscriptionReceiveLine1(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveTransferResult(listenerContainer, 1); // var subscription = receiveTransferResult(listenerContainer, 1);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionReceiveLine2(RedisConnectionFactory factory) { // public Subscription subscriptionReceiveLine2(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveTransferResult(listenerContainer, 2); // var subscription = receiveTransferResult(listenerContainer, 2);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
// @Bean // @Bean
// public Subscription subscriptionReceiveLine3(RedisConnectionFactory factory) { // public Subscription subscriptionReceiveLine3(RedisConnectionFactory factory) {
......
...@@ -44,21 +44,21 @@ public class ConsumerSlimePerformanceInsertRedisStreamConfig extends RedisStream ...@@ -44,21 +44,21 @@ public class ConsumerSlimePerformanceInsertRedisStreamConfig extends RedisStream
return subscription; return subscription;
} }
@Bean // @Bean
public Subscription subscriptionReceivePInsert1(RedisConnectionFactory factory) { // public Subscription subscriptionReceivePInsert1(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveTransferResult(listenerContainer, 1); // var subscription = receiveTransferResult(listenerContainer, 1);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionReceivePInsert2(RedisConnectionFactory factory) { // public Subscription subscriptionReceivePInsert2(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveTransferResult(listenerContainer, 2); // var subscription = receiveTransferResult(listenerContainer, 2);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
// @Bean // @Bean
// public Subscription subscriptionReceivePInsert3(RedisConnectionFactory factory) { // public Subscription subscriptionReceivePInsert3(RedisConnectionFactory factory) {
......
...@@ -44,21 +44,21 @@ public class ConsumerSlimePerformanceRedisStreamConfig extends RedisStreamConfig ...@@ -44,21 +44,21 @@ public class ConsumerSlimePerformanceRedisStreamConfig extends RedisStreamConfig
return subscription; return subscription;
} }
@Bean // @Bean
public Subscription subscriptionReceivePerformance1(RedisConnectionFactory factory) { // public Subscription subscriptionReceivePerformance1(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveTransferResult(listenerContainer, 1); // var subscription = receiveTransferResult(listenerContainer, 1);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionReceivePerformance2(RedisConnectionFactory factory) { // public Subscription subscriptionReceivePerformance2(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveTransferResult(listenerContainer, 2); // var subscription = receiveTransferResult(listenerContainer, 2);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
// @Bean // @Bean
// public Subscription subscriptionReceivePerformance3(RedisConnectionFactory factory) { // public Subscription subscriptionReceivePerformance3(RedisConnectionFactory factory) {
......
...@@ -44,21 +44,21 @@ public class ConsumerSlimeSponsorRedisStreamConfig extends RedisStreamConfig { ...@@ -44,21 +44,21 @@ public class ConsumerSlimeSponsorRedisStreamConfig extends RedisStreamConfig {
return subscription; return subscription;
} }
@Bean // @Bean
public Subscription subscriptionReceiveSqlSponsor1(RedisConnectionFactory factory) { // public Subscription subscriptionReceiveSqlSponsor1(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlSponsor(listenerContainer, 1); // var subscription = receiveSqlSponsor(listenerContainer, 1);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionReceiveSqlSponsor2(RedisConnectionFactory factory) { // public Subscription subscriptionReceiveSqlSponsor2(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlSponsor(listenerContainer, 2); // var subscription = receiveSqlSponsor(listenerContainer, 2);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
// @Bean // @Bean
// public Subscription subscriptionReceiveSqlSponsor3(RedisConnectionFactory factory) { // public Subscription subscriptionReceiveSqlSponsor3(RedisConnectionFactory factory) {
......
...@@ -44,21 +44,21 @@ public class ConsumerSlimeStep2RedisStreamConfig extends RedisStreamConfig { ...@@ -44,21 +44,21 @@ public class ConsumerSlimeStep2RedisStreamConfig extends RedisStreamConfig {
return subscription; return subscription;
} }
@Bean // @Bean
public Subscription subscriptionReceiveStep21(RedisConnectionFactory factory) { // public Subscription subscriptionReceiveStep21(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveTransferResult(listenerContainer, 1); // var subscription = receiveTransferResult(listenerContainer, 1);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionReceiveStep22(RedisConnectionFactory factory) { // public Subscription subscriptionReceiveStep22(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveTransferResult(listenerContainer, 2); // var subscription = receiveTransferResult(listenerContainer, 2);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
// @Bean // @Bean
// public Subscription subscriptionReceiveStep23(RedisConnectionFactory factory) { // public Subscription subscriptionReceiveStep23(RedisConnectionFactory factory) {
......
...@@ -44,21 +44,21 @@ public class ConsumerSlimeTicketRedisStreamConfig extends RedisStreamConfig { ...@@ -44,21 +44,21 @@ public class ConsumerSlimeTicketRedisStreamConfig extends RedisStreamConfig {
return subscription; return subscription;
} }
@Bean // @Bean
public Subscription subscriptionReceiveTicket1(RedisConnectionFactory factory) { // public Subscription subscriptionReceiveTicket1(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveTransferResult(listenerContainer, 1); // var subscription = receiveTransferResult(listenerContainer, 1);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
//
@Bean // @Bean
public Subscription subscriptionReceiveTicket2(RedisConnectionFactory factory) { // public Subscription subscriptionReceiveTicket2(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); // var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveTransferResult(listenerContainer, 2); // var subscription = receiveTransferResult(listenerContainer, 2);
listenerContainer.start(); // listenerContainer.start();
return subscription; // return subscription;
} // }
// @Bean // @Bean
// public Subscription subscriptionReceiveTicket3(RedisConnectionFactory factory) { // public Subscription subscriptionReceiveTicket3(RedisConnectionFactory factory) {
......
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