Package org.opennms.core.ipc.sink.common

Class AbstractMessageConsumerManager

java.lang.Object

org.opennms.core.ipc.sink.common.AbstractMessageConsumerManager

All Implemented Interfaces:

MessageConsumerManager

Direct Known Subclasses:

CamelMessageConsumerManager, KafkaMessageConsumerManager, OpennmsGrpcServer, OsgiIpcManager

public abstract class AbstractMessageConsumerManager
extends Object
implements MessageConsumerManager

Field Summary

Fields

Modifier and Type	Field	Description
static String	SINK_INITIAL_SLEEP_TIME
protected ExecutorService	startupExecutor
CompletableFuture<Void>	waitForStartup

Fields inherited from interface org.opennms.core.ipc.sink.api.MessageConsumerManager

LOG_PREFIX, METRIC_DISPATCH_TIME, METRIC_MESSAGE_SIZE, METRIC_MESSAGES_RECEIVED

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractMessageConsumerManager()

Method Summary

Modifier and Type	Method	Description
<S extends Message,T extends Message> void	dispatch(SinkModule<S,T> module, T message)
static int	getNumConsumerThreads(SinkModule<?,?> module)
ExecutorService	getStartupExecutor()
<S extends Message,T extends Message> void	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> void	unregisterConsumer(MessageConsumer<S,T> consumer)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

SINK_INITIAL_SLEEP_TIME

public static final String SINK_INITIAL_SLEEP_TIME

See Also:

Constant Field Values

startupExecutor

protected final ExecutorService startupExecutor

waitForStartup

public final CompletableFuture<Void> waitForStartup

Constructor Detail

AbstractMessageConsumerManager

protected AbstractMessageConsumerManager()

Method Detail

startConsumingForModule

protected abstract void startConsumingForModule(SinkModule<?,Message> module)
                                         throws Exception

Throws:

Exception

stopConsumingForModule

protected abstract void stopConsumingForModule(SinkModule<?,Message> module)
                                        throws Exception

Throws:

Exception

dispatch

public <S extends Message,T extends Message> void dispatch(SinkModule<S,T> module,
                                                                 T message)

Specified by:

dispatch in interface MessageConsumerManager

registerConsumer

public <S extends Message,T extends Message> void registerConsumer(MessageConsumer<S,T> consumer)
                                                                  throws Exception

Specified by:

registerConsumer in interface MessageConsumerManager

Throws:

Exception

unregisterConsumer

public <S extends Message,T extends Message> void unregisterConsumer(MessageConsumer<S,T> consumer)
                                                                    throws Exception

Specified by:

unregisterConsumer in interface MessageConsumerManager

Throws:

Exception

unregisterAllConsumers

public void unregisterAllConsumers()
                            throws Exception

Throws:

Exception

getNumConsumerThreads

public static int getNumConsumerThreads(SinkModule<?,?> module)

getStartupExecutor

public ExecutorService getStartupExecutor()