com.opendxl.streaming.cli.operation

Class ProduceOperation

java.lang.Object

com.opendxl.streaming.cli.operation.ProduceOperation

All Implemented Interfaces:

CommandLineOperation

public class ProduceOperation
extends java.lang.Object
implements CommandLineOperation

This class represents the "produce" argument for a --operation option

Constructor Summary

Constructors

Constructor and Description
ProduceOperation(java.util.Map<Options,joptsimple.ArgumentAcceptingOptionSpec<java.lang.String>> optionSpecMap, joptsimple.OptionSet options) Constructor

Method Summary

Modifier and Type	Method and Description
ExecutionResult	execute() Execute the operation
java.util.Map<Options,joptsimple.ArgumentAcceptingOptionSpec<java.lang.String>>	getMandatoryOptions()
java.lang.String	getOperationName()

Methods inherited from class java.lang.Object

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

Constructor Detail

ProduceOperation

public ProduceOperation(java.util.Map<Options,joptsimple.ArgumentAcceptingOptionSpec<java.lang.String>> optionSpecMap,
                        joptsimple.OptionSet options)

Constructor

Parameters:

optionSpecMap - Options and argument spec

options - parsed command line options and arguments

Method Detail

getMandatoryOptions

public java.util.Map<Options,joptsimple.ArgumentAcceptingOptionSpec<java.lang.String>> getMandatoryOptions()

Specified by:

getMandatoryOptions in interface CommandLineOperation

Returns:

mandatory options for the specific operation

getOperationName

public java.lang.String getOperationName()

Specified by:

getOperationName in interface CommandLineOperation

Returns:

the operation name

execute

public ExecutionResult execute()

Execute the operation

Specified by:

execute in interface CommandLineOperation

Returns:

The result of produce operation command line. Example in Json notation after serializing

 {
   "code": "204",
   "result": "",
   "options": {
     "records": ["[{\"topic\":\"topic1\",\"payload\":\"Hello OpenDXL\",\"shardingKey\":\"123\",
                  \"headers\":{\"sourceId\":\"D5452543-E2FB-4585-8BE5-A61C3636819C\"}}]"],
     "verify-cert-bundle": ["1234"],
     "producer-prefix": ["/databus/cloudproxy/v1"],
     "http-proxy": ["true,10.20.30.40,8080"],
     "url": ["https://my-host.my-domain.net"],
     "token": ["myToken"]
   }
 }