com.opendxl.streaming.cli.operation

Class CreateOperation

java.lang.Object

com.opendxl.streaming.cli.operation.CreateOperation

All Implemented Interfaces:

CommandLineOperation

public class CreateOperation
extends java.lang.Object
implements CommandLineOperation

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

Constructor Summary

Constructors

Constructor and Description
CreateOperation(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

CreateOperation

public CreateOperation(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 creating operation command line. Example in Json notation

 {
     "code": "200",
     "result": {
         "consumerId": "c0c29763-eb5a-4edd-b3fa-83b9c6d527c9a931f3a5-1e5a-4b3d-b5ae-e45cfdf75853",
         "cookie": {
             "value": "qMbg3fL95SVj0Mc++/f07G7PBfAvPlfYlFbjuelDYDlSMU...",
             "domain": "my-host.my-domain.net"
         }
     },
     "options": {
         "session-timeout": ["60000"],
         "cg": ["cg1"],
         "offset-reset": ["latest"],
         "consumer-prefix": ["/databus/consumer-service/v1"],
         "verify-cert-bundle": ["1234"],
         "request-timeout": ["60001"],
         "config": ["max.message.size=1000,min.message.size=200"],
         "url": ["https://my-host.my-domain.net/databus/consumer-service/v1"],
         "retry": ["true"],
         "token": ["myToken"]
     }
 }