public abstract class AbstractXmlSinkModule<S extends Message,T extends Message> extends Object implements SinkModule<S,T>
HEARTBEAT_MODULE_ID
Constructor and Description |
---|
AbstractXmlSinkModule(Class<T> messageClazz) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj) |
int |
hashCode() |
byte[] |
marshal(T message)
Marshals the aggregated message to a byte array.
|
byte[] |
marshalSingleMessage(S message)
Marshals single message to a byte array.
|
T |
unmarshal(byte[] bytes)
Unmarshals the aggregated message from a byte array.
|
S |
unmarshalSingleMessage(byte[] bytes)
Modules with different aggregated message should override this method
|
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
getAggregationPolicy, getAsyncPolicy, getId, getNumConsumerThreads, getRoutingKey
public byte[] marshal(T message)
SinkModule
public T unmarshal(byte[] bytes)
SinkModule
public byte[] marshalSingleMessage(S message)
SinkModule
marshalSingleMessage
in interface SinkModule<S extends Message,T extends Message>
public S unmarshalSingleMessage(byte[] bytes)
unmarshalSingleMessage
in interface SinkModule<S extends Message,T extends Message>
Copyright © 2020. All rights reserved.