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

Skip to content

L
liquidnet-bus-v1
Commit 8c0a260e authored by jiangxiulong's avatar jiangxiulong
Browse files
Options

Merge remote-tracking branch 'origin/dev_nft_411' into dev_nft_411

parents a5b5e352 f04fa48b
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/config/RedisStreamConfig.java
View file @ 8c0a260e
...@@ -56,7 +56,7 @@ public class RedisStreamConfig { ...@@ -56,7 +56,7 @@ public class RedisStreamConfig {
StreamMessageListenerContainer.StreamMessageListenerContainerOptions<String, MapRecord<String, String, String>> options = StreamMessageListenerContainer.StreamMessageListenerContainerOptions StreamMessageListenerContainer.StreamMessageListenerContainerOptions<String, MapRecord<String, String, String>> options = StreamMessageListenerContainer.StreamMessageListenerContainerOptions
.builder() .builder()
// 一次性最多拉取多少条消息 // 一次性最多拉取多少条消息
.batchSize(10) .batchSize(1)
// 执行消息轮询的执行器 // 执行消息轮询的执行器
// .executor(this.threadPoolTaskExecutor) // .executor(this.threadPoolTaskExecutor)
// 消息消费异常的handler // 消息消费异常的handler
......
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