org.opennms.core.ipc.sink.api

Interface MessageConsumerManager

All Known Implementing Classes:

AbstractMessageConsumerManager, CamelMessageConsumerManager, KafkaMessageConsumerManager, MockMessageConsumerManager

public interface MessageConsumerManager

Handles dispatching of messages to the registered consumer(s).

Author:

jwhite

Field Summary

Fields

Modifier and Type	Field and Description
static String	LOG_PREFIX

Method Summary

Modifier and Type	Method and Description
<S extends Message,T extends Message> void	dispatch(SinkModule<S,T> module, T message)
<S extends Message,T extends Message> void	registerConsumer(MessageConsumer<S,T> consumer)
<S extends Message,T extends Message> void	unregisterConsumer(MessageConsumer<S,T> consumer)

Field Detail

LOG_PREFIX

static final String LOG_PREFIX

See Also:

Constant Field Values

Method Detail

dispatch

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

registerConsumer

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

Throws:

Exception

unregisterConsumer

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

Throws:

Exception