Package org.opennms.core.ipc.sink.mock
Class MockMessageConsumerManager
- java.lang.Object
-
- org.opennms.core.ipc.sink.mock.MockMessageConsumerManager
-
- All Implemented Interfaces:
MessageConsumerManager
public class MockMessageConsumerManager extends java.lang.Object implements MessageConsumerManager
-
-
Field Summary
-
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 Constructor Description MockMessageConsumerManager()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <S extends Message,T extends Message>
voiddispatch(SinkModule<S,T> module, T message)
<S extends Message,T extends Message>
voidregisterConsumer(MessageConsumer<S,T> consumer)
<S extends Message,T extends Message>
voidunregisterConsumer(MessageConsumer<S,T> consumer)
-
-
-
Method Detail
-
dispatch
public <S extends Message,T extends Message> void dispatch(SinkModule<S,T> module, T message)
- Specified by:
dispatch
in interfaceMessageConsumerManager
-
registerConsumer
public <S extends Message,T extends Message> void registerConsumer(MessageConsumer<S,T> consumer) throws java.lang.Exception
- Specified by:
registerConsumer
in interfaceMessageConsumerManager
- Throws:
java.lang.Exception
-
unregisterConsumer
public <S extends Message,T extends Message> void unregisterConsumer(MessageConsumer<S,T> consumer) throws java.lang.Exception
- Specified by:
unregisterConsumer
in interfaceMessageConsumerManager
- Throws:
java.lang.Exception
-
-