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

Skip to content

L
liquidnet-bus-v1
Commit 7b5c06a9 authored by 胡佳晨's avatar 胡佳晨
Browse files
Options

sweet

parent 6bd94184
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 4 deletions
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerSweetSqlUserRelationMDSKRedisStreamConfig.java
View file @ 7b5c06a9
...@@ -40,7 +40,7 @@ public class ConsumerSweetSqlUserRelationMDSKRedisStreamConfig { ...@@ -40,7 +40,7 @@ public class ConsumerSweetSqlUserRelationMDSKRedisStreamConfig {
* @param t * @param t
* @return * @return
*/ */
private Subscription receiveSqlUserRelation(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) { private Subscription receiveSqlUserMdskRelation(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
return listenerContainer.receiveAutoAck( return listenerContainer.receiveAutoAck(
Consumer.from(ARTISTS_RELATION_MDSK.getGroup(), ARTISTS_RELATION_MDSK.name() + t), Consumer.from(ARTISTS_RELATION_MDSK.getGroup(), ARTISTS_RELATION_MDSK.name() + t),
StreamOffset.create(ARTISTS_RELATION_MDSK.getKey(), ReadOffset.lastConsumed()), consumerSweetSqlUserRelationMDSKRdsReceiver StreamOffset.create(ARTISTS_RELATION_MDSK.getKey(), ReadOffset.lastConsumed()), consumerSweetSqlUserRelationMDSKRdsReceiver
...@@ -54,7 +54,7 @@ public class ConsumerSweetSqlUserRelationMDSKRedisStreamConfig { ...@@ -54,7 +54,7 @@ public class ConsumerSweetSqlUserRelationMDSKRedisStreamConfig {
@Bean @Bean
public Subscription subscriptionSqlUserRelation(RedisConnectionFactory factory) { public Subscription subscriptionSqlUserRelation(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlUserRelation(listenerContainer, 1); var subscription = receiveSqlUserMdskRelation(listenerContainer, 1);
listenerContainer.start(); listenerContainer.start();
return subscription; return subscription;
} }
...@@ -62,7 +62,7 @@ public class ConsumerSweetSqlUserRelationMDSKRedisStreamConfig { ...@@ -62,7 +62,7 @@ public class ConsumerSweetSqlUserRelationMDSKRedisStreamConfig {
@Bean @Bean
public Subscription subscriptionSqlUserRelation2(RedisConnectionFactory factory) { public Subscription subscriptionSqlUserRelation2(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlUserRelation(listenerContainer, 1); var subscription = receiveSqlUserMdskRelation(listenerContainer, 1);
listenerContainer.start(); listenerContainer.start();
return subscription; return subscription;
} }
...@@ -70,7 +70,7 @@ public class ConsumerSweetSqlUserRelationMDSKRedisStreamConfig { ...@@ -70,7 +70,7 @@ public class ConsumerSweetSqlUserRelationMDSKRedisStreamConfig {
@Bean @Bean
public Subscription subscriptionSqlUserRelation3(RedisConnectionFactory factory) { public Subscription subscriptionSqlUserRelation3(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlUserRelation(listenerContainer, 1); var subscription = receiveSqlUserMdskRelation(listenerContainer, 1);
listenerContainer.start(); listenerContainer.start();
return subscription; return subscription;
} }
......
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