Package org.opennms.core.ipc.sink.xml
Class AbstractXmlSinkModule<S extends Message,T extends Message>
- java.lang.Object
-
- org.opennms.core.ipc.sink.xml.AbstractXmlSinkModule<S,T>
-
- All Implemented Interfaces:
SinkModule<S,T>
- Direct Known Subclasses:
DeviceConfigSinkModuleImpl
,EventSinkModule
,HeartbeatModule
,SyslogSinkModule
,TrapSinkModule
public abstract class AbstractXmlSinkModule<S extends Message,T extends Message> extends Object implements SinkModule<S,T>
-
-
Field Summary
-
Fields inherited from interface org.opennms.core.ipc.sink.api.SinkModule
HEARTBEAT_MODULE_ID
-
-
Constructor Summary
Constructors Constructor Description AbstractXmlSinkModule(Class<T> messageClazz)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.opennms.core.ipc.sink.api.SinkModule
getAggregationPolicy, getAsyncPolicy, getId, getNumConsumerThreads, getRoutingKey
-
-
-
-
Method Detail
-
marshal
public byte[] marshal(T message)
Description copied from interface:SinkModule
Marshals the aggregated message to a byte array.
-
unmarshal
public T unmarshal(byte[] bytes)
Description copied from interface:SinkModule
Unmarshals the aggregated message from a byte array.
-
marshalSingleMessage
public byte[] marshalSingleMessage(S message)
Description copied from interface:SinkModule
Marshals single message to a byte array.- Specified by:
marshalSingleMessage
in interfaceSinkModule<S extends Message,T extends Message>
-
unmarshalSingleMessage
public S unmarshalSingleMessage(byte[] bytes)
Modules with different aggregated message should override this method- Specified by:
unmarshalSingleMessage
in interfaceSinkModule<S extends Message,T extends Message>
-
-