-
Notifications
You must be signed in to change notification settings - Fork 87
Open
Description
使用 KeyAffinityExecutor.newSerializingExecutor(IntSupplier parallelism, IntSupplier queueBufferSize,
String threadName) 返回的对象 没有设置并发参数方法
然后我尝试创建一个 KeyAffinityExecutorBuilder affinityExecutor = KeyAffinityExecutor.newKeyAffinityExecutor();
affinityExecutor.parallelism(this.mqttProperties::getConsumer)
.executor(KeyAffinityExecutorUtils.executor("mqtt-async-service-%d", () -> this.mqttProperties.getBlockingQueue()))
.usingRandom(it -> it > RANDOM_THRESHOLD)
.build();
可KeyAffinityExecutorUtils.executor方法是defalut 我无法使用 ,
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
No labels