public abstract class AbstractQueueConsumerFactory<T extends DataTypeParent>
extends java.lang.Object
implements org.apache.shenyu.disruptor.consumer.QueueConsumerFactory<T>
| 构造器和说明 |
|---|
AbstractQueueConsumerFactory() |
| 限定符和类型 | 方法和说明 |
|---|---|
AbstractQueueConsumerFactory<T> |
addSubscribers(ExecutorSubscriber<T> subscriber)
Add subscribers abstract queue consumer factory.
|
java.util.Set<ExecutorSubscriber<T>> |
getSubscribers()
Gets subscribers.
|
public AbstractQueueConsumerFactory<T> addSubscribers(ExecutorSubscriber<T> subscriber)
subscriber - the subscriberpublic java.util.Set<ExecutorSubscriber<T>> getSubscribers()
Copyright © 2026 The Apache Software Foundation. All rights reserved.