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

Skip to content

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

dragon 消费

parent d2daec1f
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 4 deletions
liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/config/RedisStreamConfig.java
View file @ 0c3a4d8d
...@@ -28,7 +28,7 @@ public class RedisStreamConfig { ...@@ -28,7 +28,7 @@ public class RedisStreamConfig {
var options = StreamMessageListenerContainer var options = StreamMessageListenerContainer
.StreamMessageListenerContainerOptions .StreamMessageListenerContainerOptions
.builder() .builder()
.pollTimeout(Duration.ofSeconds(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("dragon-pay-group", "dragon-pay-0"), var subscription = listenerContainer.receiveAutoAck(Consumer.from("dragon-pay-group", "dragon-pay-0"),
...@@ -42,7 +42,7 @@ public class RedisStreamConfig { ...@@ -42,7 +42,7 @@ public class RedisStreamConfig {
var options = StreamMessageListenerContainer var options = StreamMessageListenerContainer
.StreamMessageListenerContainerOptions .StreamMessageListenerContainerOptions
.builder() .builder()
.pollTimeout(Duration.ofSeconds(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("dragon-pay-group", "dragon-pay-1"), var subscription = listenerContainer.receiveAutoAck(Consumer.from("dragon-pay-group", "dragon-pay-1"),
...@@ -56,7 +56,7 @@ public class RedisStreamConfig { ...@@ -56,7 +56,7 @@ public class RedisStreamConfig {
var options = StreamMessageListenerContainer var options = StreamMessageListenerContainer
.StreamMessageListenerContainerOptions .StreamMessageListenerContainerOptions
.builder() .builder()
.pollTimeout(Duration.ofSeconds(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("dragon-refund-group", "dragon-refund-0"), var subscription = listenerContainer.receiveAutoAck(Consumer.from("dragon-refund-group", "dragon-refund-0"),
...@@ -70,7 +70,7 @@ public class RedisStreamConfig { ...@@ -70,7 +70,7 @@ public class RedisStreamConfig {
var options = StreamMessageListenerContainer var options = StreamMessageListenerContainer
.StreamMessageListenerContainerOptions .StreamMessageListenerContainerOptions
.builder() .builder()
.pollTimeout(Duration.ofSeconds(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("dragon-refund-group", "dragon-refund-1"), var subscription = listenerContainer.receiveAutoAck(Consumer.from("dragon-refund-group", "dragon-refund-1"),
......
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