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

Commit 9c16b2c0 authored by sunyuntian's avatar sunyuntian

修改bug

parent 221c6def
...@@ -35,32 +35,32 @@ public class ConsumerSweetPosterRdsReceiverConfig { ...@@ -35,32 +35,32 @@ public class ConsumerSweetPosterRdsReceiverConfig {
/* /*
*活动海报 *活动海报
* */ * */
private Subscription posterSqlRemind(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) { private Subscription receiveSqlPoster(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
return listenerContainer.receiveAutoAck( return listenerContainer.receiveAutoAck(
Consumer.from(SWEET_POSTER.getGroup(), SWEET_POSTER.name() + t), Consumer.from(SWEET_POSTER.getGroup(), SWEET_POSTER.name() + t),
StreamOffset.create(SWEET_POSTER.getKey(), ReadOffset.lastConsumed()), consumerSweetPosterRdsReceiver StreamOffset.create(SWEET_POSTER.getKey(), ReadOffset.lastConsumed()), consumerSweetPosterRdsReceiver
); );
} }
@Bean @Bean
public Subscription subscriptionSqlRemind(RedisConnectionFactory factory) { public Subscription subscriptionSqlPoster(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = posterSqlRemind(listenerContainer, 1); var subscription = receiveSqlPoster(listenerContainer, 1);
listenerContainer.start(); listenerContainer.start();
return subscription; return subscription;
} }
@Bean @Bean
public Subscription subscriptionSqlRemind2(RedisConnectionFactory factory) { public Subscription subscriptionSqlPoster2(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = posterSqlRemind(listenerContainer, 1); var subscription = receiveSqlPoster(listenerContainer, 1);
listenerContainer.start(); listenerContainer.start();
return subscription; return subscription;
} }
@Bean @Bean
public Subscription subscriptionSqlRemind3(RedisConnectionFactory factory) { public Subscription subscriptionSqlPoster3(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory); var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = posterSqlRemind(listenerContainer, 1); var subscription = receiveSqlPoster(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