public class ProduceOperation extends java.lang.Object implements CommandLineOperation
| Constructor and Description |
|---|
ProduceOperation(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 ProduceOperation(java.util.Map<Options,joptsimple.ArgumentAcceptingOptionSpec<java.lang.String>> optionSpecMap, joptsimple.OptionSet options)
optionSpecMap - Options and argument specoptions - parsed command line options and argumentspublic 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": "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"]
}
}