com.opendxl.streaming.client.entity

Class ProducerRecords.ProducerRecord.Builder

java.lang.Object

com.opendxl.streaming.client.entity.ProducerRecords.ProducerRecord.Builder

Enclosing class:

ProducerRecords.ProducerRecord

public static class ProducerRecords.ProducerRecord.Builder
extends java.lang.Object

ProducerRecords.ProducerRecord.Builder is a helper class implementing the builder pattern to easily create ProducerRecords.ProducerRecord objects.

Constructor Summary

Constructors

Constructor and Description
Builder(java.lang.String topic, java.lang.String payload) ProducerRecords.ProducerRecord.Builder constructor asks for the ProducerRecords.ProducerRecord mandatory attributes which are topic and payload.

Method Summary

Modifier and Type	Method and Description
ProducerRecords.ProducerRecord	build() Create a brand new ProducerRecords.ProducerRecord object which attributes are set to the values given for topic, base64EncodedPayload, shardingKey and headers
ProducerRecords.ProducerRecord.Builder	withHeaders(java.util.Map<java.lang.String,java.lang.String> headers) Set the headers value to be set in the upcoming ProducerRecords.ProducerRecord object.
ProducerRecords.ProducerRecord.Builder	withShardingKey(java.lang.String shardingKey) Set the shardingKey attribute value to be set in the upcoming ProducerRecords.ProducerRecord object.

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder(java.lang.String topic,
               java.lang.String payload)

ProducerRecords.ProducerRecord.Builder constructor asks for the ProducerRecords.ProducerRecord mandatory attributes which are topic and payload.

Parameters:

topic - topic value to be set in ProducerRecord.routingData.topic attribute

payload - payload value to be set in ProducerRecord.message.payload attribute

Method Detail

withShardingKey

public ProducerRecords.ProducerRecord.Builder withShardingKey(java.lang.String shardingKey)

Set the shardingKey attribute value to be set in the upcoming ProducerRecords.ProducerRecord object.

Parameters:

shardingKey - value to set in the ProducerRecords.ProducerRecord.RoutingData.shardingKey attribute of the ProducerRecords.ProducerRecord to be built.

Returns:

the ProducerRecords.ProducerRecord.Builder instance

withHeaders

public ProducerRecords.ProducerRecord.Builder withHeaders(java.util.Map<java.lang.String,java.lang.String> headers)

Set the headers value to be set in the upcoming ProducerRecords.ProducerRecord object.

Parameters:

headers - value to be set in the ProducerRecords.ProducerRecord.Message.headers attribute of the ProducerRecords.ProducerRecord to be built

Returns:

the ProducerRecords.ProducerRecord.Builder instance

build

public ProducerRecords.ProducerRecord build()

Create a brand new ProducerRecords.ProducerRecord object which attributes are set to the values given for topic, base64EncodedPayload, shardingKey and headers

Returns:

the new ProducerRecords.ProducerRecord object