public class MockMessageDispatcherFactory<U extends Message,V extends Message> extends AbstractMessageDispatcherFactory<Void>
MessageDispatcherFactory
that handles all messages with a single consumer.
Used for testing.Constructor and Description |
---|
MockMessageDispatcherFactory() |
Modifier and Type | Method and Description |
---|---|
<S extends Message,T extends Message> |
dispatch(SinkModule<S,T> module,
Void metadata,
T message) |
MessageConsumer<U,V> |
getConsumer() |
void |
setConsumer(MessageConsumer<U,V> consumer) |
createAsyncDispatcher, createSyncDispatcher, createSyncDispatcher, getMetrics, getModuleMetadata
public <S extends Message,T extends Message> void dispatch(SinkModule<S,T> module, Void metadata, T message)
dispatch
in class AbstractMessageDispatcherFactory<Void>
public MessageConsumer<U,V> getConsumer()
public void setConsumer(MessageConsumer<U,V> consumer)
Copyright © 2018. All rights reserved.