com.opendxl.streaming.cli.operation

Class ConsumeOperation

java.lang.Object

com.opendxl.streaming.cli.operation.ConsumeOperation

All Implemented Interfaces:

CommandLineOperation

public class ConsumeOperation
extends java.lang.Object
implements CommandLineOperation

It represents a --consume operation command line

Constructor Summary

Constructors

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

ConsumeOperation

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

Constructor

Parameters:

optionSpecMap - Map of options spec

options - parsed options

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 consuming operation command line. Example in Json notation after serializing

 {
     "code": "200",
     "result": [{
         "routingData": {
             "topic": "topic3",
             "shardingKey": "pool-1-thread-1-30-0"
         },
         "message": {
             "headers": {
                 "sourceId": "abc",
                 "tenantId": "D27BF561-D6CF-443B-A134-995459EA8921",
                 "zoneId": "TMP.Identity.MULTIMOCK"
             },
             "payload": "SGVsbG8gV29ybGQgYXQ6MjAxOS0wMi0yN1QxNToyMDozMC4wMTYgRXh..."
         },
         "partition": 3,
         "offset": 764
     }],
     "options": {
         "cookie": ["ixB1cHbCVprX8qTIuoo7n8WtTPT8uNnmQ2bcZCDO+NqiRNBms49QAE96b3Q+D7..."],
         "consumer-prefix": ["/databus/consumer-service/v1"],
         "domain": ["my-host.my-domain.net"],
         "verify-cert-bundle": ["1234"],
         "consumer-id": ["227e7fcf-84ad-48c4-8e1a-6c3614ac9782c3363971-3f45-417f-a827-80f9079d002d"],
         "url": ["https://my-host.my-domain.net/databus/consumer-service/v1"],
         "token": ["myToken"]
     }
 }