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

Skip to content

L
liquidnet-bus-v1
Commit d6234e4c authored by anjiabin's avatar anjiabin
Browse files
Options

修改通知逻辑

parent 64f59d22
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 4 deletions
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-dragon/src/main/java/com/liquidnet/service/consumer/dragon/service/config/RedisStreamConfig.java
View file @ d6234e4c
...@@ -147,8 +147,8 @@ public class RedisStreamConfig { ...@@ -147,8 +147,8 @@ public class RedisStreamConfig {
.pollTimeout(Duration.ofMillis(1)) .pollTimeout(Duration.ofMillis(1))
.build(); .build();
var listenerContainer = StreamMessageListenerContainer.create(factory, options); var listenerContainer = StreamMessageListenerContainer.create(factory, options);
var subscription = listenerContainer.receiveAutoAck(Consumer.from(DragonConstant.MysqlRedisQueueEnum.DRAGON_PAY_NOTIFY_GROUP.getCode(), "pay-mch-notify-fail-0"), var subscription = listenerContainer.receiveAutoAck(Consumer.from(DragonConstant.MysqlRedisQueueEnum.PAY_MCH_NOTIFY_ERROR_GROUP.getCode(), "pay-mch-notify-fail-0"),
StreamOffset.create(DragonConstant.MysqlRedisQueueEnum.DRAGON_PAY_NOTIFY_KEY.getCode(), ReadOffset.lastConsumed()), redisPayNotifyReceiver); StreamOffset.create(DragonConstant.MysqlRedisQueueEnum.PAY_MCH_NOTIFY_ERROR_KEY.getCode(), ReadOffset.lastConsumed()), redisMchNotifyFailReceiver);
listenerContainer.start(); listenerContainer.start();
return subscription; return subscription;
} }
...@@ -161,8 +161,8 @@ public class RedisStreamConfig { ...@@ -161,8 +161,8 @@ public class RedisStreamConfig {
.pollTimeout(Duration.ofMillis(1)) .pollTimeout(Duration.ofMillis(1))
.build(); .build();
var listenerContainer = StreamMessageListenerContainer.create(factory, options); var listenerContainer = StreamMessageListenerContainer.create(factory, options);
var subscription = listenerContainer.receiveAutoAck(Consumer.from(DragonConstant.MysqlRedisQueueEnum.DRAGON_PAY_NOTIFY_GROUP.getCode(), "pay-mch-notify-fail-1"), var subscription = listenerContainer.receiveAutoAck(Consumer.from(DragonConstant.MysqlRedisQueueEnum.PAY_MCH_NOTIFY_ERROR_GROUP.getCode(), "pay-mch-notify-fail-1"),
StreamOffset.create(DragonConstant.MysqlRedisQueueEnum.DRAGON_PAY_NOTIFY_KEY.getCode(), ReadOffset.lastConsumed()), redisPayNotifyReceiver); StreamOffset.create(DragonConstant.MysqlRedisQueueEnum.PAY_MCH_NOTIFY_ERROR_KEY.getCode(), ReadOffset.lastConsumed()), redisMchNotifyFailReceiver);
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