This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/main by this push:
new a84bfcd3528 Regen
a84bfcd3528 is described below
commit a84bfcd3528f1f029077e64debea46f8c5225961
Author: Claus Ibsen <[email protected]>
AuthorDate: Wed Nov 5 07:56:11 2025 +0100
Regen
---
.../springboot/catalog/components/aws2-ec2.json | 2 +-
.../camel/springboot/catalog/components/dapr.json | 114 ++++++++++-----
.../camel-dapr-starter/src/main/docs/dapr.json | 64 ++++++++-
.../springboot/DaprComponentConfiguration.java | 153 +++++++++++++++++++--
.../dapr/springboot/DaprComponentConverter.java | 2 +
5 files changed, 282 insertions(+), 53 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-ec2.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-ec2.json
index 2276380fe49..12d3f688ba0 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-ec2.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-ec2.json
@@ -49,7 +49,7 @@
},
"headers": {
"CamelAwsEC2ImageId": { "index": 0, "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "String",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "An image ID of the AWS marketplace", "constantName":
"org.apache.camel.component.aws2.ec2.AWS2EC2Constants#IMAGE_ID" },
- "CamelAwsEC2InstanceType": { "index": 1, "kind": "header", "displayName":
"", "group": "producer", "label": "", "required": false, "javaType":
"software.amazon.awssdk.services.ec2.model.InstanceType", "enum": [
"a1.medium", "a1.large", "a1.xlarge", "a1.2xlarge", "a1.4xlarge", "a1.metal",
"c1.medium", "c1.xlarge", "c3.large", "c3.xlarge", "c3.2xlarge", "c3.4xlarge",
"c3.8xlarge", "c4.large", "c4.xlarge", "c4.2xlarge", "c4.4xlarge",
"c4.8xlarge", "c5.large", "c5.xlarge", "c5.2xlarge", [...]
+ "CamelAwsEC2InstanceType": { "index": 1, "kind": "header", "displayName":
"", "group": "producer", "label": "", "required": false, "javaType":
"software.amazon.awssdk.services.ec2.model.InstanceType", "enum": [
"a1.medium", "a1.large", "a1.xlarge", "a1.2xlarge", "a1.4xlarge", "a1.metal",
"c1.medium", "c1.xlarge", "c3.large", "c3.xlarge", "c3.2xlarge", "c3.4xlarge",
"c3.8xlarge", "c4.large", "c4.xlarge", "c4.2xlarge", "c4.4xlarge",
"c4.8xlarge", "c5.large", "c5.xlarge", "c5.2xlarge", [...]
"CamelAwsEC2Operation": { "index": 2, "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "String",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The operation we want to perform", "constantName":
"org.apache.camel.component.aws2.ec2.AWS2EC2Constants#OPERATION" },
"CamelAwsEC2InstanceMinCount": { "index": 3, "kind": "header",
"displayName": "", "group": "producer", "label": "", "required": false,
"javaType": "Integer", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The minimum number of instances we want
to run.", "constantName":
"org.apache.camel.component.aws2.ec2.AWS2EC2Constants#INSTANCE_MIN_COUNT" },
"CamelAwsEC2InstanceMaxCount": { "index": 4, "kind": "header",
"displayName": "", "group": "producer", "label": "", "required": false,
"javaType": "Integer", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The maximum number of instances we want
to run.", "constantName":
"org.apache.camel.component.aws2.ec2.AWS2EC2Constants#INSTANCE_MAX_COUNT" },
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/dapr.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/dapr.json
index 49dda06091f..18b6f2a7ea4 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/dapr.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/dapr.json
@@ -29,30 +29,40 @@
"configStore": { "index": 2, "kind": "property", "displayName": "Config
Store", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the Dapr configuration store to
interact with, defined in statestore.yaml config" },
"configuration": { "index": 3, "kind": "property", "displayName":
"Configuration", "group": "common", "label": "", "required": false, "type":
"object", "javaType": "org.apache.camel.component.dapr.DaprConfiguration",
"deprecated": false, "autowired": false, "secret": false, "description": "The
component configurations" },
"contentType": { "index": 4, "kind": "property", "displayName": "Content
Type", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The contentType for the Pub\/Sub component to
use." },
- "pubSubName": { "index": 5, "kind": "property", "displayName": "Pub Sub
Name", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the Dapr Pub\/Sub component to
use. This identifies which underlying messaging system Dapr will intera [...]
- "topic": { "index": 6, "kind": "property", "displayName": "Topic",
"group": "common", "label": "common", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the topic to subscribe to. The
topic must exist in the Pub\/Sub component configured under the given
pubsubName." },
- "bridgeErrorHandler": { "index": 7, "kind": "property", "displayName":
"Bridge Error Handler", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Allows for bridging the consumer to the Camel routing Error Handler, which
mean any exceptions (if possible) occurred while the Camel consumer is trying
to pickup incoming messages, or the like [...]
- "previewClient": { "index": 8, "kind": "property", "displayName": "Preview
Client", "group": "consumer", "label": "consumer", "required": false, "type":
"object", "javaType": "io.dapr.client.DaprPreviewClient", "deprecated": false,
"deprecationNote": "", "autowired": true, "secret": false,
"configurationClass": "org.apache.camel.component.dapr.DaprConfiguration",
"configurationField": "configuration", "description": "The Dapr Preview Cliet"
},
+ "previewClient": { "index": 5, "kind": "property", "displayName": "Preview
Client", "group": "common", "label": "common", "required": false, "type":
"object", "javaType": "io.dapr.client.DaprPreviewClient", "deprecated": false,
"deprecationNote": "", "autowired": true, "secret": false,
"configurationClass": "org.apache.camel.component.dapr.DaprConfiguration",
"configurationField": "configuration", "description": "The Dapr Preview Client"
},
+ "pubSubName": { "index": 6, "kind": "property", "displayName": "Pub Sub
Name", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the Dapr Pub\/Sub component to
use. This identifies which underlying messaging system Dapr will intera [...]
+ "topic": { "index": 7, "kind": "property", "displayName": "Topic",
"group": "common", "label": "common", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the topic to subscribe to. The
topic must exist in the Pub\/Sub component configured under the given
pubsubName." },
+ "bridgeErrorHandler": { "index": 8, "kind": "property", "displayName":
"Bridge Error Handler", "group": "consumer", "label": "consumer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Allows for bridging the consumer to the Camel routing Error Handler, which
mean any exceptions (if possible) occurred while the Camel consumer is trying
to pickup incoming messages, or the like [...]
"bindingName": { "index": 9, "kind": "property", "displayName": "Binding
Name", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the Dapr binding to invoke" },
"bindingOperation": { "index": 10, "kind": "property", "displayName":
"Binding Operation", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The operation to perform on the binding" },
"concurrency": { "index": 11, "kind": "property", "displayName":
"Concurrency", "group": "producer", "label": "producer", "required": false,
"type": "enum", "javaType": "io.dapr.client.domain.StateOptions.Concurrency",
"enum": [ "FIRST_WRITE", "LAST_WRITE" ], "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "Concurrency mode to use with state opera [...]
"consistency": { "index": 12, "kind": "property", "displayName":
"Consistency", "group": "producer", "label": "producer", "required": false,
"type": "enum", "javaType": "io.dapr.client.domain.StateOptions.Consistency",
"enum": [ "EVENTUAL", "STRONG" ], "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "Consistency level to use with state
operations" },
"eTag": { "index": 13, "kind": "property", "displayName": "ETag", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The eTag for optimistic concurrency during
state save or delete operations" },
- "expiryInSeconds": { "index": 14, "kind": "property", "displayName":
"Expiry In Seconds", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The expiry time in seconds for the lock" },
- "httpExtension": { "index": 15, "kind": "property", "displayName": "Http
Extension", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType": "io.dapr.client.domain.HttpExtension",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass": "org.apache.camel.component.dapr.DaprConfiguration",
"configurationField": "configuration", "description": "HTTP method to use when
invoking the service. Accepts verbs lik [...]
- "key": { "index": 16, "kind": "property", "displayName": "Key", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The key used to identify the state\/secret
object within the specified state\/secret store" },
- "lazyStartProducer": { "index": 17, "kind": "property", "displayName":
"Lazy Start Producer", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether the producer should be started lazy (on the first message). By
starting lazy you can use this to allow CamelContext and routes to startup in
situations where a producer may otherwise fai [...]
- "lockOperation": { "index": 18, "kind": "property", "displayName": "Lock
Operation", "group": "producer", "label": "producer", "required": false,
"type": "enum", "javaType": "org.apache.camel.component.dapr.LockOperation",
"enum": [ "tryLock", "unlock" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "tryLock", "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The lock operatio [...]
- "lockOwner": { "index": 19, "kind": "property", "displayName": "Lock
Owner", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The lock owner identifier for the lock" },
- "methodToInvoke": { "index": 20, "kind": "property", "displayName":
"Method To Invoke", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the method or route to invoke on
the target service" },
- "resourceId": { "index": 21, "kind": "property", "displayName": "Resource
Id", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The resource Id for the lock" },
- "secretStore": { "index": 22, "kind": "property", "displayName": "Secret
Store", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the Dapr secret store to interact
with, defined in local-secret-store.yaml config" },
- "serviceToInvoke": { "index": 23, "kind": "property", "displayName":
"Service To Invoke", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "Target service to invoke. Can be a Dapr App
ID, a named HTTPEndpoint, or a FQDN\/public URL" },
- "stateOperation": { "index": 24, "kind": "property", "displayName": "State
Operation", "group": "producer", "label": "producer", "required": false,
"type": "enum", "javaType": "org.apache.camel.component.dapr.StateOperation",
"enum": [ "save", "saveBulk", "get", "getBulk", "delete", "executeTransaction"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"get", "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField": "c
[...]
- "stateStore": { "index": 25, "kind": "property", "displayName": "State
Store", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the Dapr state store to interact
with, defined in statestore.yaml config" },
- "storeName": { "index": 26, "kind": "property", "displayName": "Store
Name", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The lock store name" },
- "verb": { "index": 27, "kind": "property", "displayName": "Verb", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "POST", "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The HTTP verb to use for invoking the method"
},
- "autowiredEnabled": { "index": 28, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching [...]
+ "eventName": { "index": 14, "kind": "property", "displayName": "Event
Name", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the event. Event names are
case-insensitive" },
+ "expiryInSeconds": { "index": 15, "kind": "property", "displayName":
"Expiry In Seconds", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The expiry time in seconds for the lock" },
+ "getWorkflowIO": { "index": 16, "kind": "property", "displayName": "Get
Workflow IO", "group": "producer", "label": "producer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "Set true to fetch the workflow instance's
inputs, outputs, and custom status, or false t [...]
+ "httpExtension": { "index": 17, "kind": "property", "displayName": "Http
Extension", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType": "io.dapr.client.domain.HttpExtension",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass": "org.apache.camel.component.dapr.DaprConfiguration",
"configurationField": "configuration", "description": "HTTP method to use when
invoking the service. Accepts verbs lik [...]
+ "key": { "index": 18, "kind": "property", "displayName": "Key", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The key used to identify the state\/secret
object within the specified state\/secret store" },
+ "lazyStartProducer": { "index": 19, "kind": "property", "displayName":
"Lazy Start Producer", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether the producer should be started lazy (on the first message). By
starting lazy you can use this to allow CamelContext and routes to startup in
situations where a producer may otherwise fai [...]
+ "lockOperation": { "index": 20, "kind": "property", "displayName": "Lock
Operation", "group": "producer", "label": "producer", "required": false,
"type": "enum", "javaType": "org.apache.camel.component.dapr.LockOperation",
"enum": [ "tryLock", "unlock" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "tryLock", "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The lock operatio [...]
+ "lockOwner": { "index": 21, "kind": "property", "displayName": "Lock
Owner", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The lock owner identifier for the lock" },
+ "methodToInvoke": { "index": 22, "kind": "property", "displayName":
"Method To Invoke", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the method or route to invoke on
the target service" },
+ "reason": { "index": 23, "kind": "property", "displayName": "Reason",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "Reason for suspending\/resuming the workflow
instance" },
+ "resourceId": { "index": 24, "kind": "property", "displayName": "Resource
Id", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The resource Id for the lock" },
+ "secretStore": { "index": 25, "kind": "property", "displayName": "Secret
Store", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the Dapr secret store to interact
with, defined in local-secret-store.yaml config" },
+ "serviceToInvoke": { "index": 26, "kind": "property", "displayName":
"Service To Invoke", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "Target service to invoke. Can be a Dapr App
ID, a named HTTPEndpoint, or a FQDN\/public URL" },
+ "stateOperation": { "index": 27, "kind": "property", "displayName": "State
Operation", "group": "producer", "label": "producer", "required": false,
"type": "enum", "javaType": "org.apache.camel.component.dapr.StateOperation",
"enum": [ "save", "saveBulk", "get", "getBulk", "delete", "executeTransaction"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"get", "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField": "c
[...]
+ "stateStore": { "index": 28, "kind": "property", "displayName": "State
Store", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the Dapr state store to interact
with, defined in statestore.yaml config" },
+ "storeName": { "index": 29, "kind": "property", "displayName": "Store
Name", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The lock store name" },
+ "timeout": { "index": 30, "kind": "property", "displayName": "Timeout",
"group": "producer", "label": "producer", "required": false, "type":
"duration", "javaType": "java.time.Duration", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The amount of time to wait for the workflow
instance to start\/complete" },
+ "verb": { "index": 31, "kind": "property", "displayName": "Verb", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "POST", "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The HTTP verb to use for invoking the method"
},
+ "workflowClass": { "index": 32, "kind": "property", "displayName":
"Workflow Class", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The FQCN of the class which implements
io.dapr.workflows.Workflow" },
+ "workflowClient": { "index": 33, "kind": "property", "displayName":
"Workflow Client", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType": "io.dapr.workflows.client.DaprWorkflowClient",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass": "org.apache.camel.component.dapr.DaprConfiguration",
"configurationField": "configuration", "description": "The Dapr Workflow
Client" },
+ "workflowInstanceId": { "index": 34, "kind": "property", "displayName":
"Workflow Instance Id", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The instance ID of the workflow" },
+ "workflowOperation": { "index": 35, "kind": "property", "displayName":
"Workflow Operation", "group": "producer", "label": "producer", "required":
false, "type": "enum", "javaType":
"org.apache.camel.component.dapr.WorkflowOperation", "enum": [ "scheduleNew",
"terminate", "purge", "suspend", "resume", "state", "waitForInstanceStart",
"waitForInstanceCompletion", "raiseEvent" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "scheduleNew", "configurationClas [...]
+ "workflowStartTime": { "index": 36, "kind": "property", "displayName":
"Workflow Start Time", "group": "producer", "label": "producer", "required":
false, "type": "object", "javaType": "java.time.Instant", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The start time of the new workflow" },
+ "workflowVersion": { "index": 37, "kind": "property", "displayName":
"Workflow Version", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The version of the workflow to start" },
+ "autowiredEnabled": { "index": 38, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching [...]
},
"headers": {
"CamelDaprServiceToInvoke": { "index": 0, "kind": "header", "displayName":
"", "group": "producer", "label": "producer", "required": false, "javaType":
"String", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "Target service to invoke. Can be a Dapr App
ID, a named HTTPEndpoint, or a FQDN\/public URL", "constantName":
"org.apache.camel.component.dapr.DaprConstants#SERVICE_TO_INVOKE" },
@@ -94,17 +104,35 @@
"CamelDaprStoreName": { "index": 36, "kind": "header", "displayName": "",
"group": "producer", "label": "producer", "required": false, "javaType":
"String", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "The lock store name", "constantName":
"org.apache.camel.component.dapr.DaprConstants#STORE_NAME" },
"CamelDaprResourceId": { "index": 37, "kind": "header", "displayName": "",
"group": "producer", "label": "producer", "required": false, "javaType":
"String", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "The resource Id for the lock", "constantName":
"org.apache.camel.component.dapr.DaprConstants#RESOURCE_ID" },
"CamelDaprLockOwner": { "index": 38, "kind": "header", "displayName": "",
"group": "producer", "label": "producer", "required": false, "javaType":
"String", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "The lock owner identifier for the lock",
"constantName": "org.apache.camel.component.dapr.DaprConstants#LOCK_OWNER" },
- "CamelDaprExpiryInSeconds": { "index": 39, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "Integer", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The expiry time in seconds for the
lock", "constantName":
"org.apache.camel.component.dapr.DaprConstants#EXPIRY_IN_SECONDS" }
+ "CamelDaprExpiryInSeconds": { "index": 39, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "Integer", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The expiry time in seconds for the
lock", "constantName":
"org.apache.camel.component.dapr.DaprConstants#EXPIRY_IN_SECONDS" },
+ "CamelDaprWorkflowOperation": { "index": 40, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "WorkflowOperation", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "defaultValue": "scheduleNew",
"description": "The workflow operation to perform.Required for
DaprOperation.workflow operation", "constantName":
"org.apache.camel.component.dapr.DaprConstants#WORKFLOW_OPERATION" },
+ "CamelDaprWorkflowClass": { "index": 41, "kind": "header", "displayName":
"", "group": "producer", "label": "producer", "required": false, "javaType":
"String", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "The FQCN of the class which implements
io.dapr.workflows.Workflow", "constantName":
"org.apache.camel.component.dapr.DaprConstants#WORKFLOW_CLASS" },
+ "CamelDaprWorkflowVersion": { "index": 42, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The version of the workflow to start",
"constantName":
"org.apache.camel.component.dapr.DaprConstants#WORKFLOW_VERSION" },
+ "CamelDaprWorkflowInstanceId": { "index": 43, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The instance ID of the workflow",
"constantName":
"org.apache.camel.component.dapr.DaprConstants#WORKFLOW_INSTANCE_ID" },
+ "CamelDaprWorkflowStartTime": { "index": 44, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "Instant", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The start time of the new workflow",
"constantName":
"org.apache.camel.component.dapr.DaprConstants#WORKFLOW_START_TIME" },
+ "CamelDaprSuspendReason": { "index": 45, "kind": "header", "displayName":
"", "group": "producer", "label": "producer", "required": false, "javaType":
"String", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "Reason for suspending\/resuming the workflow
instance", "constantName":
"org.apache.camel.component.dapr.DaprConstants#REASON" },
+ "CamelDaprNewWorkflowInstanceId": { "index": 46, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The instance ID of the new scheduled
workflow", "constantName":
"org.apache.camel.component.dapr.DaprConstants#NEW_WORKFLOW_INSTANCE_ID" },
+ "CamelDaprGetWorkflowIO": { "index": 47, "kind": "header", "displayName":
"", "group": "producer", "label": "producer", "required": false, "javaType":
"boolean", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "Set true to fetch the workflow instance's
inputs, outputs, and custom status, or false to omit", "constantName":
"org.apache.camel.component.dapr.DaprConstants#GET_WORKFLOW_IO" },
+ "CamelDaprWorkflowName": { "index": 48, "kind": "header", "displayName":
"", "group": "producer", "label": "producer", "required": false, "javaType":
"String", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "The workflow name", "constantName":
"org.apache.camel.component.dapr.DaprConstants#WORKFLOW_NAME" },
+ "CamelDaprWorkflowCreatedAt": { "index": 49, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "Instant", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Gets the workflow instance's creation
time in UTC", "constantName":
"org.apache.camel.component.dapr.DaprConstants#WORKFLOW_CREATED_AT" },
+ "CamelDaprWorkflowUpdatedAt": { "index": 50, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "Instant", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Gets the workflow instance's last
updated time in UTC", "constantName":
"org.apache.camel.component.dapr.DaprConstants#WORKFLOW_UPDATED_AT" },
+ "CamelDaprWorkflowSerializedInput": { "index": 51, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Gets the workflow instance's serialized
input, if any", "constantName":
"org.apache.camel.component.dapr.DaprConstants#WORKFLOW_SERIALIZED_INPUT" },
+ "CamelDaprWorkflowSerializedOutput": { "index": 52, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Gets the workflow instance's serialized
output, if any", "constantName":
"org.apache.camel.component.dapr.DaprConstants#WORKFLOW_SERIALIZED_OUTPUT" },
+ "CamelDaprWorkflowFailureDetails": { "index": 53, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "io.dapr.workflows.client.WorkflowFailureDetails", "deprecated":
false, "deprecationNote": "", "autowired": false, "secret": false,
"description": "The failure details of the failed workflow instance or null",
"constantName":
"org.apache.camel.component.dapr.DaprConstants#WORKFLOW_FAILURE_DETAILS" },
+ "CamelDaprIsWorkflowRunning": { "index": 54, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "boolean", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Set true if the workflow existed and
was in a running state otherwise false", "constantName":
"org.apache.camel.component.dapr.DaprConstants#IS_WORKFLOW_RUNNING" },
+ "CamelDaprIsWorkflowCompleted": { "index": 55, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "boolean", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Set true if the workflow was in a
terminal state; otherwise false", "constantName":
"org.apache.camel.component.dapr.DaprConstants#IS_WORKFLOW_COMPLETED" },
+ "CamelDaprTimeout": { "index": 56, "kind": "header", "displayName": "",
"group": "producer", "label": "producer", "required": false, "javaType":
"Duration", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "The amount of time to wait for the workflow
instance to start\/complete", "constantName":
"org.apache.camel.component.dapr.DaprConstants#TIMEOUT" },
+ "CamelDaprEventName": { "index": 57, "kind": "header", "displayName": "",
"group": "producer", "label": "producer", "required": false, "javaType":
"String", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "The name of the event. Event names are
case-insensitive", "constantName":
"org.apache.camel.component.dapr.DaprConstants#EVENT_NAME" }
},
"properties": {
- "operation": { "index": 0, "kind": "path", "displayName": "Operation",
"group": "producer", "label": "producer", "required": true, "type": "enum",
"javaType": "org.apache.camel.component.dapr.DaprOperation", "enum": [
"invokeService", "state" ], "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The Dapr building block operati [...]
+ "operation": { "index": 0, "kind": "path", "displayName": "Operation",
"group": "producer", "label": "producer", "required": true, "type": "enum",
"javaType": "org.apache.camel.component.dapr.DaprOperation", "enum": [
"invokeService", "state", "pubSub", "invokeBinding", "secret", "configuration",
"lock", "workflow" ], "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurati [...]
"client": { "index": 1, "kind": "parameter", "displayName": "Client",
"group": "common", "label": "common", "required": false, "type": "object",
"javaType": "io.dapr.client.DaprClient", "deprecated": false,
"deprecationNote": "", "autowired": true, "secret": false,
"configurationClass": "org.apache.camel.component.dapr.DaprConfiguration",
"configurationField": "configuration", "description": "The Dapr Client" },
"configKeys": { "index": 2, "kind": "parameter", "displayName": "Config
Keys", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "List of keys for configuration operation" },
"configStore": { "index": 3, "kind": "parameter", "displayName": "Config
Store", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the Dapr configuration store to
interact with, defined in statestore.yaml config" },
"contentType": { "index": 4, "kind": "parameter", "displayName": "Content
Type", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The contentType for the Pub\/Sub component to
use." },
- "pubSubName": { "index": 5, "kind": "parameter", "displayName": "Pub Sub
Name", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the Dapr Pub\/Sub component to
use. This identifies which underlying messaging system Dapr will inter [...]
- "topic": { "index": 6, "kind": "parameter", "displayName": "Topic",
"group": "common", "label": "common", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the topic to subscribe to. The
topic must exist in the Pub\/Sub component configured under the given
pubsubName." },
- "previewClient": { "index": 7, "kind": "parameter", "displayName":
"Preview Client", "group": "consumer", "label": "consumer", "required": false,
"type": "object", "javaType": "io.dapr.client.DaprPreviewClient", "deprecated":
false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass": "org.apache.camel.component.dapr.DaprConfiguration",
"configurationField": "configuration", "description": "The Dapr Preview Cliet"
},
+ "previewClient": { "index": 5, "kind": "parameter", "displayName":
"Preview Client", "group": "common", "label": "common", "required": false,
"type": "object", "javaType": "io.dapr.client.DaprPreviewClient", "deprecated":
false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass": "org.apache.camel.component.dapr.DaprConfiguration",
"configurationField": "configuration", "description": "The Dapr Preview Client"
},
+ "pubSubName": { "index": 6, "kind": "parameter", "displayName": "Pub Sub
Name", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the Dapr Pub\/Sub component to
use. This identifies which underlying messaging system Dapr will inter [...]
+ "topic": { "index": 7, "kind": "parameter", "displayName": "Topic",
"group": "common", "label": "common", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the topic to subscribe to. The
topic must exist in the Pub\/Sub component configured under the given
pubsubName." },
"bridgeErrorHandler": { "index": 8, "kind": "parameter", "displayName":
"Bridge Error Handler", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions (if possible) occurred
while the Camel consumer is trying to pickup incoming [...]
"exceptionHandler": { "index": 9, "kind": "parameter", "displayName":
"Exception Handler", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.",
"deprecated": false, "autowired": false, "secret": false, "description": "To
let the consumer use a custom ExceptionHandler. Notice if the option
bridgeErrorHandler is enabled then this option is not in use. By def [...]
"exchangePattern": { "index": 10, "kind": "parameter", "displayName":
"Exchange Pattern", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "enum", "javaType":
"org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut" ],
"deprecated": false, "autowired": false, "secret": false, "description": "Sets
the exchange pattern when the consumer creates an exchange." },
@@ -113,19 +141,29 @@
"concurrency": { "index": 13, "kind": "parameter", "displayName":
"Concurrency", "group": "producer", "label": "producer", "required": false,
"type": "enum", "javaType": "io.dapr.client.domain.StateOptions.Concurrency",
"enum": [ "FIRST_WRITE", "LAST_WRITE" ], "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "Concurrency mode to use with state oper [...]
"consistency": { "index": 14, "kind": "parameter", "displayName":
"Consistency", "group": "producer", "label": "producer", "required": false,
"type": "enum", "javaType": "io.dapr.client.domain.StateOptions.Consistency",
"enum": [ "EVENTUAL", "STRONG" ], "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "Consistency level to use with state
operations" },
"eTag": { "index": 15, "kind": "parameter", "displayName": "ETag",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The eTag for optimistic concurrency during
state save or delete operations" },
- "expiryInSeconds": { "index": 16, "kind": "parameter", "displayName":
"Expiry In Seconds", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The expiry time in seconds for the lock" },
- "httpExtension": { "index": 17, "kind": "parameter", "displayName": "Http
Extension", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType": "io.dapr.client.domain.HttpExtension",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass": "org.apache.camel.component.dapr.DaprConfiguration",
"configurationField": "configuration", "description": "HTTP method to use when
invoking the service. Accepts verbs li [...]
- "key": { "index": 18, "kind": "parameter", "displayName": "Key", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The key used to identify the state\/secret
object within the specified state\/secret store" },
- "lockOperation": { "index": 19, "kind": "parameter", "displayName": "Lock
Operation", "group": "producer", "label": "producer", "required": false,
"type": "enum", "javaType": "org.apache.camel.component.dapr.LockOperation",
"enum": [ "tryLock", "unlock" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "tryLock", "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The lock operati [...]
- "lockOwner": { "index": 20, "kind": "parameter", "displayName": "Lock
Owner", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The lock owner identifier for the lock" },
- "methodToInvoke": { "index": 21, "kind": "parameter", "displayName":
"Method To Invoke", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the method or route to invoke on
the target service" },
- "resourceId": { "index": 22, "kind": "parameter", "displayName": "Resource
Id", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The resource Id for the lock" },
- "secretStore": { "index": 23, "kind": "parameter", "displayName": "Secret
Store", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the Dapr secret store to interact
with, defined in local-secret-store.yaml config" },
- "serviceToInvoke": { "index": 24, "kind": "parameter", "displayName":
"Service To Invoke", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "Target service to invoke. Can be a Dapr App
ID, a named HTTPEndpoint, or a FQDN\/public URL" },
- "stateOperation": { "index": 25, "kind": "parameter", "displayName":
"State Operation", "group": "producer", "label": "producer", "required": false,
"type": "enum", "javaType": "org.apache.camel.component.dapr.StateOperation",
"enum": [ "save", "saveBulk", "get", "getBulk", "delete", "executeTransaction"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"get", "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField": "
[...]
- "stateStore": { "index": 26, "kind": "parameter", "displayName": "State
Store", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the Dapr state store to interact
with, defined in statestore.yaml config" },
- "storeName": { "index": 27, "kind": "parameter", "displayName": "Store
Name", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The lock store name" },
- "verb": { "index": 28, "kind": "parameter", "displayName": "Verb",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "POST", "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The HTTP verb to use for invoking the method"
},
- "lazyStartProducer": { "index": 29, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produ [...]
+ "eventName": { "index": 16, "kind": "parameter", "displayName": "Event
Name", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the event. Event names are
case-insensitive" },
+ "expiryInSeconds": { "index": 17, "kind": "parameter", "displayName":
"Expiry In Seconds", "group": "producer", "label": "producer", "required":
false, "type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The expiry time in seconds for the lock" },
+ "getWorkflowIO": { "index": 18, "kind": "parameter", "displayName": "Get
Workflow IO", "group": "producer", "label": "producer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "Set true to fetch the workflow instance's
inputs, outputs, and custom status, or false [...]
+ "httpExtension": { "index": 19, "kind": "parameter", "displayName": "Http
Extension", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType": "io.dapr.client.domain.HttpExtension",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass": "org.apache.camel.component.dapr.DaprConfiguration",
"configurationField": "configuration", "description": "HTTP method to use when
invoking the service. Accepts verbs li [...]
+ "key": { "index": 20, "kind": "parameter", "displayName": "Key", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The key used to identify the state\/secret
object within the specified state\/secret store" },
+ "lockOperation": { "index": 21, "kind": "parameter", "displayName": "Lock
Operation", "group": "producer", "label": "producer", "required": false,
"type": "enum", "javaType": "org.apache.camel.component.dapr.LockOperation",
"enum": [ "tryLock", "unlock" ], "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "tryLock", "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The lock operati [...]
+ "lockOwner": { "index": 22, "kind": "parameter", "displayName": "Lock
Owner", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The lock owner identifier for the lock" },
+ "methodToInvoke": { "index": 23, "kind": "parameter", "displayName":
"Method To Invoke", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the method or route to invoke on
the target service" },
+ "reason": { "index": 24, "kind": "parameter", "displayName": "Reason",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "Reason for suspending\/resuming the workflow
instance" },
+ "resourceId": { "index": 25, "kind": "parameter", "displayName": "Resource
Id", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The resource Id for the lock" },
+ "secretStore": { "index": 26, "kind": "parameter", "displayName": "Secret
Store", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the Dapr secret store to interact
with, defined in local-secret-store.yaml config" },
+ "serviceToInvoke": { "index": 27, "kind": "parameter", "displayName":
"Service To Invoke", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "Target service to invoke. Can be a Dapr App
ID, a named HTTPEndpoint, or a FQDN\/public URL" },
+ "stateOperation": { "index": 28, "kind": "parameter", "displayName":
"State Operation", "group": "producer", "label": "producer", "required": false,
"type": "enum", "javaType": "org.apache.camel.component.dapr.StateOperation",
"enum": [ "save", "saveBulk", "get", "getBulk", "delete", "executeTransaction"
], "deprecated": false, "autowired": false, "secret": false, "defaultValue":
"get", "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField": "
[...]
+ "stateStore": { "index": 29, "kind": "parameter", "displayName": "State
Store", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The name of the Dapr state store to interact
with, defined in statestore.yaml config" },
+ "storeName": { "index": 30, "kind": "parameter", "displayName": "Store
Name", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The lock store name" },
+ "timeout": { "index": 31, "kind": "parameter", "displayName": "Timeout",
"group": "producer", "label": "producer", "required": false, "type":
"duration", "javaType": "java.time.Duration", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The amount of time to wait for the workflow
instance to start\/complete" },
+ "verb": { "index": 32, "kind": "parameter", "displayName": "Verb",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "POST", "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The HTTP verb to use for invoking the method"
},
+ "workflowClass": { "index": 33, "kind": "parameter", "displayName":
"Workflow Class", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The FQCN of the class which implements
io.dapr.workflows.Workflow" },
+ "workflowClient": { "index": 34, "kind": "parameter", "displayName":
"Workflow Client", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType": "io.dapr.workflows.client.DaprWorkflowClient",
"deprecated": false, "deprecationNote": "", "autowired": true, "secret": false,
"configurationClass": "org.apache.camel.component.dapr.DaprConfiguration",
"configurationField": "configuration", "description": "The Dapr Workflow
Client" },
+ "workflowInstanceId": { "index": 35, "kind": "parameter", "displayName":
"Workflow Instance Id", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The instance ID of the workflow" },
+ "workflowOperation": { "index": 36, "kind": "parameter", "displayName":
"Workflow Operation", "group": "producer", "label": "producer", "required":
false, "type": "enum", "javaType":
"org.apache.camel.component.dapr.WorkflowOperation", "enum": [ "scheduleNew",
"terminate", "purge", "suspend", "resume", "state", "waitForInstanceStart",
"waitForInstanceCompletion", "raiseEvent" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "scheduleNew", "configurationCla [...]
+ "workflowStartTime": { "index": 37, "kind": "parameter", "displayName":
"Workflow Start Time", "group": "producer", "label": "producer", "required":
false, "type": "object", "javaType": "java.time.Instant", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The start time of the new workflow" },
+ "workflowVersion": { "index": 38, "kind": "parameter", "displayName":
"Workflow Version", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.dapr.DaprConfiguration", "configurationField":
"configuration", "description": "The version of the workflow to start" },
+ "lazyStartProducer": { "index": 39, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produ [...]
}
}
diff --git a/components-starter/camel-dapr-starter/src/main/docs/dapr.json
b/components-starter/camel-dapr-starter/src/main/docs/dapr.json
index 036d7bffb18..aaa3ef38650 100644
--- a/components-starter/camel-dapr-starter/src/main/docs/dapr.json
+++ b/components-starter/camel-dapr-starter/src/main/docs/dapr.json
@@ -98,12 +98,25 @@
"description": "Whether to enable auto configuration of the dapr
component. This is enabled by default.",
"sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration"
},
+ {
+ "name": "camel.component.dapr.event-name",
+ "type": "java.lang.String",
+ "description": "The name of the event. Event names are case-insensitive",
+ "sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration"
+ },
{
"name": "camel.component.dapr.expiry-in-seconds",
"type": "java.lang.Integer",
"description": "The expiry time in seconds for the lock",
"sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration"
},
+ {
+ "name": "camel.component.dapr.get-workflow-i-o",
+ "type": "java.lang.Boolean",
+ "description": "Set true to fetch the workflow instance's inputs,
outputs, and custom status, or false to omit",
+ "sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration",
+ "defaultValue": false
+ },
{
"name": "camel.component.dapr.http-extension",
"type": "io.dapr.client.domain.HttpExtension",
@@ -145,7 +158,7 @@
{
"name": "camel.component.dapr.preview-client",
"type": "io.dapr.client.DaprPreviewClient",
- "description": "The Dapr Preview Cliet. The option is a
io.dapr.client.DaprPreviewClient type.",
+ "description": "The Dapr Preview Client. The option is a
io.dapr.client.DaprPreviewClient type.",
"sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration"
},
{
@@ -154,6 +167,12 @@
"description": "The name of the Dapr Pub\/Sub component to use. This
identifies which underlying messaging system Dapr will interact with for
publishing or subscribing to events.",
"sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration"
},
+ {
+ "name": "camel.component.dapr.reason",
+ "type": "java.lang.String",
+ "description": "Reason for suspending\/resuming the workflow instance",
+ "sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration"
+ },
{
"name": "camel.component.dapr.resource-id",
"type": "java.lang.String",
@@ -191,6 +210,12 @@
"description": "The lock store name",
"sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration"
},
+ {
+ "name": "camel.component.dapr.timeout",
+ "type": "java.time.Duration",
+ "description": "The amount of time to wait for the workflow instance to
start\/complete",
+ "sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration"
+ },
{
"name": "camel.component.dapr.topic",
"type": "java.lang.String",
@@ -203,6 +228,43 @@
"description": "The HTTP verb to use for invoking the method",
"sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration",
"defaultValue": "POST"
+ },
+ {
+ "name": "camel.component.dapr.workflow-class",
+ "type": "java.lang.String",
+ "description": "The FQCN of the class which implements
io.dapr.workflows.Workflow",
+ "sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration"
+ },
+ {
+ "name": "camel.component.dapr.workflow-client",
+ "type": "io.dapr.workflows.client.DaprWorkflowClient",
+ "description": "The Dapr Workflow Client. The option is a
io.dapr.workflows.client.DaprWorkflowClient type.",
+ "sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration"
+ },
+ {
+ "name": "camel.component.dapr.workflow-instance-id",
+ "type": "java.lang.String",
+ "description": "The instance ID of the workflow",
+ "sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration"
+ },
+ {
+ "name": "camel.component.dapr.workflow-operation",
+ "type": "org.apache.camel.component.dapr.WorkflowOperation",
+ "description": "The workflow operation to perform. Required for
DaprOperation.workflow operation",
+ "sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration",
+ "defaultValue": "schedulenew"
+ },
+ {
+ "name": "camel.component.dapr.workflow-start-time",
+ "type": "java.time.Instant",
+ "description": "The start time of the new workflow",
+ "sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration"
+ },
+ {
+ "name": "camel.component.dapr.workflow-version",
+ "type": "java.lang.String",
+ "description": "The version of the workflow to start",
+ "sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration"
}
],
"hints": [],
diff --git
a/components-starter/camel-dapr-starter/src/main/java/org/apache/camel/component/dapr/springboot/DaprComponentConfiguration.java
b/components-starter/camel-dapr-starter/src/main/java/org/apache/camel/component/dapr/springboot/DaprComponentConfiguration.java
index 5386f4df8fd..6de36c7554e 100644
---
a/components-starter/camel-dapr-starter/src/main/java/org/apache/camel/component/dapr/springboot/DaprComponentConfiguration.java
+++
b/components-starter/camel-dapr-starter/src/main/java/org/apache/camel/component/dapr/springboot/DaprComponentConfiguration.java
@@ -16,15 +16,19 @@
*/
package org.apache.camel.component.dapr.springboot;
+import java.time.Duration;
+import java.time.Instant;
import io.dapr.client.DaprClient;
import io.dapr.client.DaprPreviewClient;
import io.dapr.client.domain.HttpExtension;
import io.dapr.client.domain.StateOptions.Concurrency;
import io.dapr.client.domain.StateOptions.Consistency;
+import io.dapr.workflows.client.DaprWorkflowClient;
import org.apache.camel.component.dapr.DaprComponent;
import org.apache.camel.component.dapr.DaprConfiguration;
import org.apache.camel.component.dapr.LockOperation;
import org.apache.camel.component.dapr.StateOperation;
+import org.apache.camel.component.dapr.WorkflowOperation;
import org.apache.camel.spring.boot.ComponentConfigurationPropertiesCommon;
import org.springframework.boot.context.properties.ConfigurationProperties;
@@ -65,6 +69,11 @@ public class DaprComponentConfiguration
* The contentType for the Pub/Sub component to use.
*/
private String contentType;
+ /**
+ * The Dapr Preview Client. The option is a
io.dapr.client.DaprPreviewClient
+ * type.
+ */
+ private DaprPreviewClient previewClient;
/**
* The name of the Dapr Pub/Sub component to use. This identifies which
* underlying messaging system Dapr will interact with for publishing or
@@ -90,11 +99,6 @@ public class DaprComponentConfiguration
* with exceptions, that will be logged at WARN or ERROR level and ignored.
*/
private Boolean bridgeErrorHandler = false;
- /**
- * The Dapr Preview Cliet. The option is a io.dapr.client.DaprPreviewClient
- * type.
- */
- private DaprPreviewClient previewClient;
/**
* The name of the Dapr binding to invoke
*/
@@ -116,10 +120,19 @@ public class DaprComponentConfiguration
* operations
*/
private String eTag;
+ /**
+ * The name of the event. Event names are case-insensitive
+ */
+ private String eventName;
/**
* The expiry time in seconds for the lock
*/
private Integer expiryInSeconds;
+ /**
+ * Set true to fetch the workflow instance's inputs, outputs, and custom
+ * status, or false to omit
+ */
+ private Boolean getWorkflowIO = false;
/**
* HTTP method to use when invoking the service. Accepts verbs like GET,
* POST, PUT, DELETE, etc. Creates a minimal HttpExtension with no headers
@@ -156,6 +169,10 @@ public class DaprComponentConfiguration
* The name of the method or route to invoke on the target service
*/
private String methodToInvoke;
+ /**
+ * Reason for suspending/resuming the workflow instance
+ */
+ private String reason;
/**
* The resource Id for the lock
*/
@@ -184,10 +201,40 @@ public class DaprComponentConfiguration
* The lock store name
*/
private String storeName;
+ /**
+ * The amount of time to wait for the workflow instance to start/complete
+ */
+ private Duration timeout;
/**
* The HTTP verb to use for invoking the method
*/
private String verb = "POST";
+ /**
+ * The FQCN of the class which implements io.dapr.workflows.Workflow
+ */
+ private String workflowClass;
+ /**
+ * The Dapr Workflow Client. The option is a
+ * io.dapr.workflows.client.DaprWorkflowClient type.
+ */
+ private DaprWorkflowClient workflowClient;
+ /**
+ * The instance ID of the workflow
+ */
+ private String workflowInstanceId;
+ /**
+ * The workflow operation to perform. Required for DaprOperation.workflow
+ * operation
+ */
+ private WorkflowOperation workflowOperation =
WorkflowOperation.scheduleNew;
+ /**
+ * The start time of the new workflow
+ */
+ private Instant workflowStartTime;
+ /**
+ * The version of the workflow to start
+ */
+ private String workflowVersion;
/**
* Whether autowiring is enabled. This is used for automatic autowiring
* options (the option must be marked as autowired) by looking up in the
@@ -238,6 +285,14 @@ public class DaprComponentConfiguration
this.contentType = contentType;
}
+ public DaprPreviewClient getPreviewClient() {
+ return previewClient;
+ }
+
+ public void setPreviewClient(DaprPreviewClient previewClient) {
+ this.previewClient = previewClient;
+ }
+
public String getPubSubName() {
return pubSubName;
}
@@ -262,14 +317,6 @@ public class DaprComponentConfiguration
this.bridgeErrorHandler = bridgeErrorHandler;
}
- public DaprPreviewClient getPreviewClient() {
- return previewClient;
- }
-
- public void setPreviewClient(DaprPreviewClient previewClient) {
- this.previewClient = previewClient;
- }
-
public String getBindingName() {
return bindingName;
}
@@ -310,6 +357,14 @@ public class DaprComponentConfiguration
this.eTag = eTag;
}
+ public String getEventName() {
+ return eventName;
+ }
+
+ public void setEventName(String eventName) {
+ this.eventName = eventName;
+ }
+
public Integer getExpiryInSeconds() {
return expiryInSeconds;
}
@@ -318,6 +373,14 @@ public class DaprComponentConfiguration
this.expiryInSeconds = expiryInSeconds;
}
+ public Boolean getGetWorkflowIO() {
+ return getWorkflowIO;
+ }
+
+ public void setGetWorkflowIO(Boolean getWorkflowIO) {
+ this.getWorkflowIO = getWorkflowIO;
+ }
+
public HttpExtension getHttpExtension() {
return httpExtension;
}
@@ -366,6 +429,14 @@ public class DaprComponentConfiguration
this.methodToInvoke = methodToInvoke;
}
+ public String getReason() {
+ return reason;
+ }
+
+ public void setReason(String reason) {
+ this.reason = reason;
+ }
+
public String getResourceId() {
return resourceId;
}
@@ -414,6 +485,14 @@ public class DaprComponentConfiguration
this.storeName = storeName;
}
+ public Duration getTimeout() {
+ return timeout;
+ }
+
+ public void setTimeout(Duration timeout) {
+ this.timeout = timeout;
+ }
+
public String getVerb() {
return verb;
}
@@ -422,6 +501,54 @@ public class DaprComponentConfiguration
this.verb = verb;
}
+ public String getWorkflowClass() {
+ return workflowClass;
+ }
+
+ public void setWorkflowClass(String workflowClass) {
+ this.workflowClass = workflowClass;
+ }
+
+ public DaprWorkflowClient getWorkflowClient() {
+ return workflowClient;
+ }
+
+ public void setWorkflowClient(DaprWorkflowClient workflowClient) {
+ this.workflowClient = workflowClient;
+ }
+
+ public String getWorkflowInstanceId() {
+ return workflowInstanceId;
+ }
+
+ public void setWorkflowInstanceId(String workflowInstanceId) {
+ this.workflowInstanceId = workflowInstanceId;
+ }
+
+ public WorkflowOperation getWorkflowOperation() {
+ return workflowOperation;
+ }
+
+ public void setWorkflowOperation(WorkflowOperation workflowOperation) {
+ this.workflowOperation = workflowOperation;
+ }
+
+ public Instant getWorkflowStartTime() {
+ return workflowStartTime;
+ }
+
+ public void setWorkflowStartTime(Instant workflowStartTime) {
+ this.workflowStartTime = workflowStartTime;
+ }
+
+ public String getWorkflowVersion() {
+ return workflowVersion;
+ }
+
+ public void setWorkflowVersion(String workflowVersion) {
+ this.workflowVersion = workflowVersion;
+ }
+
public Boolean getAutowiredEnabled() {
return autowiredEnabled;
}
diff --git
a/components-starter/camel-dapr-starter/src/main/java/org/apache/camel/component/dapr/springboot/DaprComponentConverter.java
b/components-starter/camel-dapr-starter/src/main/java/org/apache/camel/component/dapr/springboot/DaprComponentConverter.java
index 4967d9ebb30..b65bb64c46e 100644
---
a/components-starter/camel-dapr-starter/src/main/java/org/apache/camel/component/dapr/springboot/DaprComponentConverter.java
+++
b/components-starter/camel-dapr-starter/src/main/java/org/apache/camel/component/dapr/springboot/DaprComponentConverter.java
@@ -43,6 +43,7 @@ public class DaprComponentConverter implements
GenericConverter {
answer.add(new ConvertiblePair(String.class,
org.apache.camel.component.dapr.DaprConfiguration.class));
answer.add(new ConvertiblePair(String.class,
io.dapr.client.DaprPreviewClient.class));
answer.add(new ConvertiblePair(String.class,
io.dapr.client.domain.HttpExtension.class));
+ answer.add(new ConvertiblePair(String.class,
io.dapr.workflows.client.DaprWorkflowClient.class));
return answer;
}
@@ -63,6 +64,7 @@ public class DaprComponentConverter implements
GenericConverter {
case "org.apache.camel.component.dapr.DaprConfiguration": return
applicationContext.getBean(ref,
org.apache.camel.component.dapr.DaprConfiguration.class);
case "io.dapr.client.DaprPreviewClient": return
applicationContext.getBean(ref, io.dapr.client.DaprPreviewClient.class);
case "io.dapr.client.domain.HttpExtension": return
applicationContext.getBean(ref, io.dapr.client.domain.HttpExtension.class);
+ case "io.dapr.workflows.client.DaprWorkflowClient": return
applicationContext.getBean(ref,
io.dapr.workflows.client.DaprWorkflowClient.class);
}
return null;
}