com.opendxl.streaming.cli.entity

Class SimplifiedProducerRecords

java.lang.Object

com.opendxl.streaming.cli.entity.SimplifiedProducerRecords

public final class SimplifiedProducerRecords
extends java.lang.Object

SimplifiedProducerRecords is collection of SimplifiedProducerRecord object. It is a helper class to create an equivalent ProducerRecords object as required by Channel.produce(ProducerRecords)

Constructor Summary

Constructors

Constructor and Description
SimplifiedProducerRecords(java.lang.String jsonSimplifiedProducerRecords) SimplifiedProducerRecords is a public constructor which takes a single String argument as required by joptsimple requirement.

Method Summary

Modifier and Type	Method and Description
ProducerRecords	getProducerRecords() Create a ProducerRecords object from the SimplifiedProducerRecords JSON objects specified by user in the --records CLI parameter.

Methods inherited from class java.lang.Object

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

Constructor Detail

SimplifiedProducerRecords

public SimplifiedProducerRecords(java.lang.String jsonSimplifiedProducerRecords)

SimplifiedProducerRecords is a public constructor which takes a single String argument as required by joptsimple requirement. joptsimple internally calls this constructor to convert a OptionSpec into a SimplifiedProducerRecords object.

Parameters:

jsonSimplifiedProducerRecords - JSON string representation of the SimplifiedProducerRecords object as typed in by the user

Method Detail

getProducerRecords

public ProducerRecords getProducerRecords()

Create a ProducerRecords object from the SimplifiedProducerRecords JSON objects specified by user in the --records CLI parameter. Each element of ProducerRecords is equivalent (e.g.: same topic value, same payload, same headers, etc.) to its corresponding element of SimplifiedProducerRecords and they are presented in the same order.

Returns:

an equivalent ProducerRecords object