com.opendxl.databus.producer

Class ProducerRecord<P>

java.lang.Object

com.opendxl.databus.producer.ProducerRecord<P>

Type Parameters:

P - message type

public final class ProducerRecord<P>
extends java.lang.Object

Represents a record that DatabusProducer sends to DatabusConsumer

Constructor Summary

Constructors

Constructor and Description
ProducerRecord(RoutingData routingData, Headers headers, MessagePayload<P> payload) Parameters cannot be null.

Method Summary

Modifier and Type	Method and Description
Headers	getHeaders() A Map with additional information.
RoutingData	getRoutingData() The address where the record must to be sent.
MessagePayload<P>	payload() The message which will be sent

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ProducerRecord

public ProducerRecord(RoutingData routingData,
                      Headers headers,
                      MessagePayload<P> payload)

Parameters cannot be null.

Parameters:

routingData - the address where the record must to be sent. If it's null, throws DatabusClientRuntimeException exception

headers - key-value map with additional information. Some fields are well-know. See HeadersField

payload - message itself

Method Detail

getRoutingData

public RoutingData getRoutingData()

The address where the record must to be sent.

Returns:

Routing Data

getHeaders

public Headers getHeaders()

A Map with additional information. Some fields are well-know. See HeadersField

Returns:

Headers

payload

public MessagePayload<P> payload()

The message which will be sent

Returns:

Payload