public class ConsumeOperation extends java.lang.Object implements CommandLineOperation
| Constructor and Description |
|---|
ConsumeOperation(java.util.Map<Options,joptsimple.ArgumentAcceptingOptionSpec<java.lang.String>> optionSpecMap,
joptsimple.OptionSet options)
Constructor
|
| 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() |
public ConsumeOperation(java.util.Map<Options,joptsimple.ArgumentAcceptingOptionSpec<java.lang.String>> optionSpecMap, joptsimple.OptionSet options)
optionSpecMap - Map of options specoptions - parsed optionspublic java.util.Map<Options,joptsimple.ArgumentAcceptingOptionSpec<java.lang.String>> getMandatoryOptions()
getMandatoryOptions in interface CommandLineOperationpublic java.lang.String getOperationName()
getOperationName in interface CommandLineOperationpublic ExecutionResult execute()
execute in interface CommandLineOperation
{
"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"]
}
}