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 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 and Description
MockMessageConsumerManager()

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

MockMessageConsumerManager

public MockMessageConsumerManager()

Method Detail

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