public abstract class AbstractXmlSinkModule<S extends Message,T extends Message> extends Object implements SinkModule<S,T>
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 message to a byte array.
|
T |
unmarshal(byte[] bytes)
Unmarshals the message from a byte array.
|
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
getAggregationPolicy, getAsyncPolicy, getId, getNumConsumerThreads
public byte[] marshal(T message)
SinkModule
public T unmarshal(byte[] bytes)
SinkModule
Copyright © 2018. All rights reserved.