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 85bd5e5dd8f Regen
85bd5e5dd8f is described below
commit 85bd5e5dd8f59963b589854b2a3897531c9d76aa
Author: Claus Ibsen <[email protected]>
AuthorDate: Mon Nov 3 12:41:43 2025 +0100
Regen
---
.../camel/springboot/catalog/components/dapr.json | 111 ++++++++++++---------
.../camel-dapr-starter/src/main/docs/dapr.json | 39 +++++++-
.../springboot/DaprComponentConfiguration.java | 79 ++++++++++++++-
.../dapr/springboot/DaprComponentConverter.java | 2 +
4 files changed, 181 insertions(+), 50 deletions(-)
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 3340b270180..49dda06091f 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
@@ -24,29 +24,35 @@
"remote": true
},
"componentProperties": {
- "configKeys": { "index": 0, "kind": "property", "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": 1, "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": 2, "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": 3, "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": 4, "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": 5, "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": 6, "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": 7, "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 client to consume
messages by the consumer" },
- "bindingName": { "index": 8, "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": 9, "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": 10, "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": 11, "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": 12, "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" },
- "httpExtension": { "index": 13, "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": 14, "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": 15, "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 [...]
- "methodToInvoke": { "index": 16, "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" },
- "secretStore": { "index": 17, "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": 18, "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": 19, "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": 20, "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" },
- "verb": { "index": 21, "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": 22, "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 [...]
+ "client": { "index": 0, "kind": "property", "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": 1, "kind": "property", "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": 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"
},
+ "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 [...]
},
"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" },
@@ -83,32 +89,43 @@
"CamelDaprBindingOperation": { "index": 31, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The operation to perform on the
binding", "constantName":
"org.apache.camel.component.dapr.DaprConstants#BINDING_OPERATION" },
"CamelDaprConfigKeys": { "index": 32, "kind": "header", "displayName": "",
"group": "producer", "label": "producer", "required": false, "javaType":
"String", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "List of keys for configuration operation",
"constantName": "org.apache.camel.component.dapr.DaprConstants#CONFIG_KEYS" },
"CamelDaprSubscriptionId": { "index": 33, "kind": "header", "displayName":
"", "group": "consumer", "label": "consumer", "required": false, "javaType":
"String", "deprecated": false, "deprecationNote": "", "autowired": false,
"secret": false, "description": "The id for configuration change subscription",
"constantName": "org.apache.camel.component.dapr.DaprConstants#SUBSCRIPTION_ID"
},
- "CamelDaprRawConfigResponse": { "index": 34, "kind": "header",
"displayName": "", "group": "common", "label": "common", "required": false,
"javaType": "Map<String, io.dapr.client.domain.ConfigurationItem",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The raw configuration update response", "constantName":
"org.apache.camel.component.dapr.DaprConstants#RAW_CONFIG_RESPONSE" }
+ "CamelDaprRawConfigResponse": { "index": 34, "kind": "header",
"displayName": "", "group": "common", "label": "common", "required": false,
"javaType": "Map<String, io.dapr.client.domain.ConfigurationItem",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The raw configuration update response", "constantName":
"org.apache.camel.component.dapr.DaprConstants#RAW_CONFIG_RESPONSE" },
+ "CamelDaprLockOperation": { "index": 35, "kind": "header", "displayName":
"", "group": "producer", "label": "producer", "required": false, "javaType":
"LockOperation", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "defaultValue": "tryLock", "description": "The lock
operation to perform on the store. Required for DaprOperation.lock operation",
"constantName": "org.apache.camel.component.dapr.DaprConstants#LOCK_OPERATION"
},
+ "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" }
},
"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 [...]
- "configKeys": { "index": 1, "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": 2, "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": 3, "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": 4, "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": 5, "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": 6, "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 client to consume
messages by the consumer" },
- "bridgeErrorHandler": { "index": 7, "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": 8, "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": 9, "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." },
- "bindingName": { "index": 10, "kind": "parameter", "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": 11, "kind": "parameter", "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": 12, "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": 13, "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": 14, "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" },
- "httpExtension": { "index": 15, "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": 16, "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" },
- "methodToInvoke": { "index": 17, "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" },
- "secretStore": { "index": 18, "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": 19, "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": 20, "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": 21, "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" },
- "verb": { "index": 22, "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": 23, "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 [...]
+ "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"
},
+ "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." },
+ "bindingName": { "index": 11, "kind": "parameter", "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": 12, "kind": "parameter", "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": 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 [...]
}
}
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 0de8ae82f7f..036d7bffb18 100644
--- a/components-starter/camel-dapr-starter/src/main/docs/dapr.json
+++ b/components-starter/camel-dapr-starter/src/main/docs/dapr.json
@@ -39,6 +39,12 @@
"sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration",
"defaultValue": false
},
+ {
+ "name": "camel.component.dapr.client",
+ "type": "io.dapr.client.DaprClient",
+ "description": "The Dapr Client. The option is a
io.dapr.client.DaprClient type.",
+ "sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration"
+ },
{
"name": "camel.component.dapr.concurrency",
"type": "io.dapr.client.domain.StateOptions$Concurrency",
@@ -92,6 +98,12 @@
"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.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.http-extension",
"type": "io.dapr.client.domain.HttpExtension",
@@ -111,6 +123,19 @@
"sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration",
"defaultValue": false
},
+ {
+ "name": "camel.component.dapr.lock-operation",
+ "type": "org.apache.camel.component.dapr.LockOperation",
+ "description": "The lock operation to perform on the store. Required for
DaprOperation.lock operation",
+ "sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration",
+ "defaultValue": "trylock"
+ },
+ {
+ "name": "camel.component.dapr.lock-owner",
+ "type": "java.lang.String",
+ "description": "The lock owner identifier for the lock",
+ "sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration"
+ },
{
"name": "camel.component.dapr.method-to-invoke",
"type": "java.lang.String",
@@ -120,7 +145,7 @@
{
"name": "camel.component.dapr.preview-client",
"type": "io.dapr.client.DaprPreviewClient",
- "description": "The client to consume messages by the consumer. The
option is a io.dapr.client.DaprPreviewClient type.",
+ "description": "The Dapr Preview Cliet. The option is a
io.dapr.client.DaprPreviewClient type.",
"sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration"
},
{
@@ -129,6 +154,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.resource-id",
+ "type": "java.lang.String",
+ "description": "The resource Id for the lock",
+ "sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration"
+ },
{
"name": "camel.component.dapr.secret-store",
"type": "java.lang.String",
@@ -154,6 +185,12 @@
"description": "The name of the Dapr state store to interact with,
defined in statestore.yaml config",
"sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration"
},
+ {
+ "name": "camel.component.dapr.store-name",
+ "type": "java.lang.String",
+ "description": "The lock store name",
+ "sourceType":
"org.apache.camel.component.dapr.springboot.DaprComponentConfiguration"
+ },
{
"name": "camel.component.dapr.topic",
"type": "java.lang.String",
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 393c057ad66..5386f4df8fd 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,12 +16,14 @@
*/
package org.apache.camel.component.dapr.springboot;
+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 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.spring.boot.ComponentConfigurationPropertiesCommon;
import org.springframework.boot.context.properties.ConfigurationProperties;
@@ -41,6 +43,10 @@ public class DaprComponentConfiguration
* enabled by default.
*/
private Boolean enabled;
+ /**
+ * The Dapr Client. The option is a io.dapr.client.DaprClient type.
+ */
+ private DaprClient client;
/**
* List of keys for configuration operation
*/
@@ -85,8 +91,8 @@ public class DaprComponentConfiguration
*/
private Boolean bridgeErrorHandler = false;
/**
- * The client to consume messages by the consumer. The option is a
- * io.dapr.client.DaprPreviewClient type.
+ * The Dapr Preview Cliet. The option is a io.dapr.client.DaprPreviewClient
+ * type.
*/
private DaprPreviewClient previewClient;
/**
@@ -110,6 +116,10 @@ public class DaprComponentConfiguration
* operations
*/
private String eTag;
+ /**
+ * The expiry time in seconds for the lock
+ */
+ private Integer expiryInSeconds;
/**
* HTTP method to use when invoking the service. Accepts verbs like GET,
* POST, PUT, DELETE, etc. Creates a minimal HttpExtension with no headers
@@ -133,10 +143,23 @@ public class DaprComponentConfiguration
* and prolong the total processing time of the processing.
*/
private Boolean lazyStartProducer = false;
+ /**
+ * The lock operation to perform on the store. Required for
+ * DaprOperation.lock operation
+ */
+ private LockOperation lockOperation = LockOperation.tryLock;
+ /**
+ * The lock owner identifier for the lock
+ */
+ private String lockOwner;
/**
* The name of the method or route to invoke on the target service
*/
private String methodToInvoke;
+ /**
+ * The resource Id for the lock
+ */
+ private String resourceId;
/**
* The name of the Dapr secret store to interact with, defined in
* local-secret-store.yaml config
@@ -157,6 +180,10 @@ public class DaprComponentConfiguration
* statestore.yaml config
*/
private String stateStore;
+ /**
+ * The lock store name
+ */
+ private String storeName;
/**
* The HTTP verb to use for invoking the method
*/
@@ -171,6 +198,14 @@ public class DaprComponentConfiguration
*/
private Boolean autowiredEnabled = true;
+ public DaprClient getClient() {
+ return client;
+ }
+
+ public void setClient(DaprClient client) {
+ this.client = client;
+ }
+
public String getConfigKeys() {
return configKeys;
}
@@ -275,6 +310,14 @@ public class DaprComponentConfiguration
this.eTag = eTag;
}
+ public Integer getExpiryInSeconds() {
+ return expiryInSeconds;
+ }
+
+ public void setExpiryInSeconds(Integer expiryInSeconds) {
+ this.expiryInSeconds = expiryInSeconds;
+ }
+
public HttpExtension getHttpExtension() {
return httpExtension;
}
@@ -299,6 +342,22 @@ public class DaprComponentConfiguration
this.lazyStartProducer = lazyStartProducer;
}
+ public LockOperation getLockOperation() {
+ return lockOperation;
+ }
+
+ public void setLockOperation(LockOperation lockOperation) {
+ this.lockOperation = lockOperation;
+ }
+
+ public String getLockOwner() {
+ return lockOwner;
+ }
+
+ public void setLockOwner(String lockOwner) {
+ this.lockOwner = lockOwner;
+ }
+
public String getMethodToInvoke() {
return methodToInvoke;
}
@@ -307,6 +366,14 @@ public class DaprComponentConfiguration
this.methodToInvoke = methodToInvoke;
}
+ public String getResourceId() {
+ return resourceId;
+ }
+
+ public void setResourceId(String resourceId) {
+ this.resourceId = resourceId;
+ }
+
public String getSecretStore() {
return secretStore;
}
@@ -339,6 +406,14 @@ public class DaprComponentConfiguration
this.stateStore = stateStore;
}
+ public String getStoreName() {
+ return storeName;
+ }
+
+ public void setStoreName(String storeName) {
+ this.storeName = storeName;
+ }
+
public String getVerb() {
return verb;
}
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 116fcfe267f..4967d9ebb30 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
@@ -39,6 +39,7 @@ public class DaprComponentConverter implements
GenericConverter {
public Set<ConvertiblePair> getConvertibleTypes() {
Set<ConvertiblePair> answer = new LinkedHashSet<>();
+ answer.add(new ConvertiblePair(String.class,
io.dapr.client.DaprClient.class));
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));
@@ -58,6 +59,7 @@ public class DaprComponentConverter implements
GenericConverter {
}
ref = ref.startsWith("#bean:") ? ref.substring(6) : ref.substring(1);
switch (targetType.getName()) {
+ case "io.dapr.client.DaprClient": return
applicationContext.getBean(ref, io.dapr.client.DaprClient.class);
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);