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:

AmazonSQSMessageConsumerManager, CamelMessageConsumerManager, KafkaMessageConsumerManager

public abstract class AbstractMessageConsumerManager
extends Object
implements MessageConsumerManager

Field Summary

Fields

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

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

LOG_PREFIX

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractMessageConsumerManager()

Method Summary

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

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)