com.opendxl.databus.entities.internal

Class DatabusMessage

java.lang.Object

com.opendxl.databus.entities.internal.DatabusMessage

All Implemented Interfaces:

java.io.Serializable

public class DatabusMessage
extends java.lang.Object
implements java.io.Serializable

It represents the message sent thru Databus. It contains a Headers and payload as byte[]

This class is for internal use of Databus-SDK. It is created and kept as a member of ConsumerRecord and it is used when the Databus-SDK's user invoke DatabusProducer.send() method

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DatabusMessage(Headers headers, byte[] payload) A DatabusMessage is created by providing a Headers and a payload as byte[].

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object obj) Overrides equals method for DatabusMessage
Headers	getHeaders() Gets the headers of a DatabusMessage instance
byte[]	getPayload() Gets the payload data
int	hashCode() Overrides equals method for DatabusMessage
void	removeHeader(java.lang.String key) Delete an specific header passing a header name as a parameter

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DatabusMessage

public DatabusMessage(Headers headers,
                      byte[] payload)

A DatabusMessage is created by providing a Headers and a payload as byte[]. If they are not provided, empty instances of them will be created.

Parameters:

headers - Key-value map that contains message headers

payload - Payload as byte[]

Method Detail

getHeaders

public Headers getHeaders()

Gets the headers of a DatabusMessage instance

Returns:

Headers of the message

removeHeader

public void removeHeader(java.lang.String key)

Delete an specific header passing a header name as a parameter

Parameters:

key - The key to be removed from headers

getPayload

public byte[] getPayload()

Gets the payload data

Returns:

A payload as array of byte

equals

public boolean equals(java.lang.Object obj)

Overrides equals method for DatabusMessage

Overrides:

equals in class java.lang.Object

Parameters:

obj - An instance to be compared to

Returns:

True if both objects are equals

hashCode

public int hashCode()

Overrides equals method for DatabusMessage

Overrides:

hashCode in class java.lang.Object

Returns:

HashCode as a product of payload hashcode and headers hashcode