public class MockSinkModule<S extends Message,T extends Message> extends Object implements SinkModule<S,T>
Constructor and Description |
---|
MockSinkModule() |
Modifier and Type | Method and Description |
---|---|
AggregationPolicy<S,T> |
getAggregationPolicy()
Defines how messages should be combined, and when they
should be "released".
|
AsyncPolicy |
getAsyncPolicy()
Defines how messages should be asynchronously dispatched.
|
String |
getId()
Globally unique identifier.
|
int |
getNumConsumerThreads()
The number of threads used to consume from the broker.
|
String |
marshal(T message)
Marshals the message to a string.
|
T |
unmarshal(String message)
Unmarshals the message from a string.
|
public String getId()
SinkModule
public int getNumConsumerThreads()
SinkModule
getNumConsumerThreads
in interface SinkModule<S extends Message,T extends Message>
public String marshal(T message)
SinkModule
public T unmarshal(String message)
SinkModule
public AggregationPolicy<S,T> getAggregationPolicy()
SinkModule
null
.getAggregationPolicy
in interface SinkModule<S extends Message,T extends Message>
AggregationPolicy
used to combine messages, or null
if the messages should not be combined.public AsyncPolicy getAsyncPolicy()
SinkModule
getAsyncPolicy
in interface SinkModule<S extends Message,T extends Message>
AsyncPolicy
used when asynchronously dispatching
messages for this module.Copyright © 2017. All rights reserved.