AbstractXmlSinkModule (OpenNMS 29.0.8 API)

java.lang.Object
- org.opennms.core.ipc.sink.xml.AbstractXmlSinkModule<S,T>

All Implemented Interfaces:: SinkModule<S,T>

Direct Known Subclasses:: 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

- Constructor Detail
  - AbstractXmlSinkModule
```
public AbstractXmlSinkModule(Class<T> messageClazz)
```
- Method Detail
  - marshal
```
public byte[] marshal(T message)
```
    Description copied from interface: SinkModule
    
    Marshals the aggregated message to a byte array.
    
    Specified by:
    
    marshal in interface SinkModule<S extends Message,T extends Message>
  - unmarshal
```
public T unmarshal(byte[] bytes)
```
    Description copied from interface: SinkModule
    
    Unmarshals the aggregated message from a byte array.
    
    Specified by:
    
    unmarshal in interface SinkModule<S extends Message,T extends Message>
  - marshalSingleMessage
```
public byte[] marshalSingleMessage(S message)
```
    Description copied from interface: SinkModule
    
    Marshals single message to a byte array.
    
    Specified by:
    
    marshalSingleMessage in interface SinkModule<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 interface SinkModule<S extends Message,T extends Message>
  - hashCode
```
public int hashCode()
```
    Overrides:
    
    hashCode in class Object
  - equals
```
public boolean equals(Object obj)
```
    Overrides:
    
    equals in class Object