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

Skip to content

L
liquidnet-bus-v1
Commit 69b979a8 authored by zhanggb's avatar zhanggb
Browse files
Options

~consumer-order:queue.listener;

parent 9f59d7f4
Show whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-order/src/main/java/com/liquidnet/service/consumer/order/config/ConsumerKylinSqlPerformanceLackRedisStreamConfig.java
View file @ 69b979a8
...@@ -60,7 +60,7 @@ public class ConsumerKylinSqlPerformanceLackRedisStreamConfig extends RedisStrea ...@@ -60,7 +60,7 @@ public class ConsumerKylinSqlPerformanceLackRedisStreamConfig extends RedisStrea
List<Subscription> subscriptionList = new ArrayList<>(); List<Subscription> subscriptionList = new ArrayList<>();
MQConst.KylinQueue stream = MQConst.KylinQueue.SQL_PERFORMANCE_LACK; MQConst.KylinQueue stream = MQConst.KylinQueue.SQL_PERFORMANCE_LACK;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup()); this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
for (int i = 0; i < 1; i++) { for (int i = 0; i < 50; i++) {
StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory); StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
subscriptionList.add(listenerContainer.receiveAutoAck( subscriptionList.add(listenerContainer.receiveAutoAck(
Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)), Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
......
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