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

Commit c1f213b2 authored by 胡佳晨's avatar 胡佳晨

sweet

parent 7b5c06a9
...@@ -52,7 +52,7 @@ public class ConsumerSweetSqlUserRelationMDSKRedisStreamConfig { ...@@ -52,7 +52,7 @@ public class ConsumerSweetSqlUserRelationMDSKRedisStreamConfig {
/* -------------------------------------------------------- | 缺票登记 */ /* -------------------------------------------------------- | 缺票登记 */
@Bean @Bean
public Subscription subscriptionSqlUserRelation(RedisConnectionFactory factory) { public Subscription subscriptionSqlUserMdskRelation(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlUserMdskRelation(listenerContainer, 1); var subscription = receiveSqlUserMdskRelation(listenerContainer, 1);
listenerContainer.start(); listenerContainer.start();
...@@ -60,7 +60,7 @@ public class ConsumerSweetSqlUserRelationMDSKRedisStreamConfig { ...@@ -60,7 +60,7 @@ public class ConsumerSweetSqlUserRelationMDSKRedisStreamConfig {
} }
@Bean @Bean
public Subscription subscriptionSqlUserRelation2(RedisConnectionFactory factory) { public Subscription subscriptionSqlUserMdskRelation2(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlUserMdskRelation(listenerContainer, 1); var subscription = receiveSqlUserMdskRelation(listenerContainer, 1);
listenerContainer.start(); listenerContainer.start();
...@@ -68,7 +68,7 @@ public class ConsumerSweetSqlUserRelationMDSKRedisStreamConfig { ...@@ -68,7 +68,7 @@ public class ConsumerSweetSqlUserRelationMDSKRedisStreamConfig {
} }
@Bean @Bean
public Subscription subscriptionSqlUserRelation3(RedisConnectionFactory factory) { public Subscription subscriptionSqlUserMdskRelation3(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlUserMdskRelation(listenerContainer, 1); var subscription = receiveSqlUserMdskRelation(listenerContainer, 1);
listenerContainer.start(); listenerContainer.start();
......
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