public class MockMessageConsumerManager extends Object implements MessageConsumerManager
LOG_PREFIX
Constructor and Description |
---|
MockMessageConsumerManager() |
Modifier and Type | Method and Description |
---|---|
<S extends Message,T extends Message> |
dispatch(SinkModule<S,T> module,
T message) |
<S extends Message,T extends Message> |
registerConsumer(MessageConsumer<S,T> consumer) |
<S extends Message,T extends Message> |
unregisterConsumer(MessageConsumer<S,T> consumer) |
public <S extends Message,T extends Message> void dispatch(SinkModule<S,T> module, T message)
dispatch
in interface MessageConsumerManager
public <S extends Message,T extends Message> void registerConsumer(MessageConsumer<S,T> consumer) throws Exception
registerConsumer
in interface MessageConsumerManager
Exception
public <S extends Message,T extends Message> void unregisterConsumer(MessageConsumer<S,T> consumer) throws Exception
unregisterConsumer
in interface MessageConsumerManager
Exception
Copyright © 2018. All rights reserved.