public abstract class AbstractMessageConsumerManager extends Object implements MessageConsumerManager
Modifier and Type | Field and Description |
---|---|
static String |
SINK_INITIAL_SLEEP_TIME |
CompletableFuture<Void> |
waitForStartup |
LOG_PREFIX, METRIC_DISPATCH_TIME, METRIC_MESSAGE_SIZE, METRIC_MESSAGES_RECEIVED
Modifier | Constructor and Description |
---|---|
protected |
AbstractMessageConsumerManager() |
Modifier and Type | Method and Description |
---|---|
<S extends Message,T extends Message> |
dispatch(SinkModule<S,T> module,
T message) |
static int |
getNumConsumerThreads(SinkModule<?,?> module) |
<S extends Message,T extends Message> |
registerConsumer(MessageConsumer<S,T> consumer) |
protected abstract void |
startConsumingForModule(SinkModule<?,Message> module) |
protected abstract void |
stopConsumingForModule(SinkModule<?,Message> module) |
void |
unregisterAllConsumers() |
<S extends Message,T extends Message> |
unregisterConsumer(MessageConsumer<S,T> consumer) |
public static final String SINK_INITIAL_SLEEP_TIME
public final CompletableFuture<Void> waitForStartup
protected abstract void startConsumingForModule(SinkModule<?,Message> module) throws Exception
Exception
protected abstract void stopConsumingForModule(SinkModule<?,Message> module) throws Exception
Exception
public <S extends Message,T extends Message> void dispatch(SinkModule<S,T> module, T message)
dispatch
in interface MessageConsumerManager
public <S extends Message,T extends Message> void registerConsumer(MessageConsumer<S,T> consumer) throws Exception
registerConsumer
in interface MessageConsumerManager
Exception
public <S extends Message,T extends Message> void unregisterConsumer(MessageConsumer<S,T> consumer) throws Exception
unregisterConsumer
in interface MessageConsumerManager
Exception
public static int getNumConsumerThreads(SinkModule<?,?> module)
Copyright © 2020. All rights reserved.