You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by lb...@apache.org on 2020/10/21 08:16:27 UTC
[camel-k-runtime] branch master updated (45ed5e1 -> c88d959)
This is an automated email from the ASF dual-hosted git repository.
lburgazzoli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel-k-runtime.git.
from 45ed5e1 Updated CHANGELOG.md
new cfd08e6 chore(deps): update to camel-quarkus 1.3.0
new be89158 yaml: use EndpointUriFactory to compute endpoint uri
new 77ca0b7 yaml: use URISupport to create query string
new c88d959 Regen
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../k/loader/yaml/support/StepParserSupport.java | 35 +-
camel-k-loader-yaml/camel-k-loader-yaml/pom.xml | 5 -
.../src/generated/resources/camel-yaml-dsl.json | 20 +-
.../generated/resources/camel-yaml-endpoint.json | 805 +++++++++------------
.../k/loader/yaml/RoutesWithEndpointTest.groovy | 4 +-
.../routes/RoutesWithEndpointTest_from.yaml | 2 +-
.../routes/RoutesWithEndpointTest_route.yaml | 2 +-
.../health/HealthContextCustomizerConfigurer.java | 17 +-
.../TracingContextCustomizerConfigurer.java | 17 +-
.../apache/camel/k/SourceDefinitionConfigurer.java | 29 +-
.../k/listener/SourcesConfigurerConfigurer.java | 11 +-
.../CronSourceLoaderInterceptorConfigurer.java | 15 +-
...formHttpServiceContextCustomizerConfigurer.java | 25 +-
...tiveSinkBindingContextCustomizerConfigurer.java | 17 +-
.../WebhookContextCustomizerConfigurer.java | 11 +-
.../kamelet/KameletComponentConfigurer.java | 19 +-
.../kamelet/KameletEndpointConfigurer.java | 29 +-
.../apache/camel/component/kamelet/kamelet.json | 13 +-
components/camel-knative/camel-knative/pom.xml | 3 +
.../knative/KnativeComponentConfigurer.java | 43 +-
.../knative/KnativeEndpointConfigurer.java | 45 +-
.../apache/camel/component/knative/knative.json | 9 +-
.../component/wrap/WrapComponentConfigurer.java | 15 +-
.../component/wrap/WrapEndpointConfigurer.java | 22 +-
.../org/apache/camel/component/wrap/wrap.json | 5 +-
pom.xml | 14 +-
tooling/camel-k-test/pom.xml | 4 -
27 files changed, 608 insertions(+), 628 deletions(-)
[camel-k-runtime] 04/04: Regen
Posted by lb...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lburgazzoli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-k-runtime.git
commit c88d959d0a82b446773c7e88a37cbe9292e06439
Author: Luca Burgazzoli <lb...@gmail.com>
AuthorDate: Mon Oct 19 14:39:24 2020 +0200
Regen
---
.../src/generated/resources/camel-yaml-dsl.json | 20 +-
.../generated/resources/camel-yaml-endpoint.json | 805 +++++++++------------
.../health/HealthContextCustomizerConfigurer.java | 17 +-
.../TracingContextCustomizerConfigurer.java | 17 +-
.../apache/camel/k/SourceDefinitionConfigurer.java | 29 +-
.../k/listener/SourcesConfigurerConfigurer.java | 11 +-
.../CronSourceLoaderInterceptorConfigurer.java | 15 +-
...formHttpServiceContextCustomizerConfigurer.java | 25 +-
...tiveSinkBindingContextCustomizerConfigurer.java | 17 +-
.../WebhookContextCustomizerConfigurer.java | 11 +-
.../kamelet/KameletComponentConfigurer.java | 19 +-
.../kamelet/KameletEndpointConfigurer.java | 29 +-
.../apache/camel/component/kamelet/kamelet.json | 13 +-
.../knative/KnativeComponentConfigurer.java | 43 +-
.../knative/KnativeEndpointConfigurer.java | 45 +-
.../apache/camel/component/knative/knative.json | 9 +-
.../component/wrap/WrapComponentConfigurer.java | 15 +-
.../component/wrap/WrapEndpointConfigurer.java | 22 +-
.../org/apache/camel/component/wrap/wrap.json | 5 +-
19 files changed, 576 insertions(+), 591 deletions(-)
diff --git a/camel-k-loader-yaml/camel-k-loader-yaml/src/generated/resources/camel-yaml-dsl.json b/camel-k-loader-yaml/camel-k-loader-yaml/src/generated/resources/camel-yaml-dsl.json
index 4d18bdd..3e90bc7 100644
--- a/camel-k-loader-yaml/camel-k-loader-yaml/src/generated/resources/camel-yaml-dsl.json
+++ b/camel-k-loader-yaml/camel-k-loader-yaml/src/generated/resources/camel-yaml-dsl.json
@@ -169,6 +169,10 @@
"header-name" : {
"type" : "string"
},
+ "option" : {
+ "type" : "string",
+ "enum" : [ "DEFAULT_PATH_LEAF_TO_NULL", "ALWAYS_RETURN_LIST", "AS_PATH_LIST", "SUPPRESS_EXCEPTIONS", "REQUIRE_PROPERTIES" ]
+ },
"result-type" : {
"type" : "string"
},
@@ -224,6 +228,10 @@
"ref" : {
"type" : "string"
},
+ "scope" : {
+ "type" : "string",
+ "enum" : [ "Singleton", "Request", "Prototype" ]
+ },
"expression" : {
"type" : "string"
},
@@ -405,6 +413,9 @@
"object-model" : {
"type" : "string"
},
+ "pre-compile" : {
+ "type" : "string"
+ },
"result-type" : {
"type" : "string",
"enum" : [ "NUMBER", "STRING", "BOOLEAN", "NODESET", "NODE" ]
@@ -466,7 +477,8 @@
"type" : "string"
},
"mode" : {
- "type" : "string"
+ "type" : "string",
+ "enum" : [ "i", "w", "u", "t" ]
},
"expression" : {
"type" : "string"
@@ -1612,6 +1624,9 @@
"allow-empty-directory" : {
"type" : "string"
},
+ "max-decompressed-size" : {
+ "type" : "string"
+ },
"preserve-path-elements" : {
"type" : "string"
},
@@ -1947,6 +1962,9 @@
"allow-empty-directory" : {
"type" : "string"
},
+ "max-decompressed-size" : {
+ "type" : "string"
+ },
"preserve-path-elements" : {
"type" : "string"
},
diff --git a/camel-k-loader-yaml/camel-k-loader-yaml/src/generated/resources/camel-yaml-endpoint.json b/camel-k-loader-yaml/camel-k-loader-yaml/src/generated/resources/camel-yaml-endpoint.json
index a5baa42..0fe105c 100644
--- a/camel-k-loader-yaml/camel-k-loader-yaml/src/generated/resources/camel-yaml-endpoint.json
+++ b/camel-k-loader-yaml/camel-k-loader-yaml/src/generated/resources/camel-yaml-endpoint.json
@@ -125,7 +125,7 @@
"type" : "integer"
},
"delivery-mode" : {
- "description" : "Specifies the delivery mode to be used. Possibles values are those defined by javax.jms.DeliveryMode. NON_PERSISTENT = 1 and PERSISTENT = 2.",
+ "description" : "Specifies the delivery mode to be used. Possible values are those defined by javax.jms.DeliveryMode. NON_PERSISTENT = 1 and PERSISTENT = 2.",
"enum" : [ "1", "2" ],
"type" : "integer"
},
@@ -321,7 +321,7 @@
"type" : "string"
},
"reply-to" : {
- "description" : "Provides an explicit ReplyTo destination, which overrides any incoming value of Message.getJMSReplyTo().",
+ "description" : "Provides an explicit ReplyTo destination (overrides any incoming value of Message.getJMSReplyTo() in consumer).",
"type" : "string"
},
"reply-to-cache-level-name" : {
@@ -779,7 +779,7 @@
"type" : "integer"
},
"delivery-mode" : {
- "description" : "Specifies the delivery mode to be used. Possibles values are those defined by javax.jms.DeliveryMode. NON_PERSISTENT = 1 and PERSISTENT = 2.",
+ "description" : "Specifies the delivery mode to be used. Possible values are those defined by javax.jms.DeliveryMode. NON_PERSISTENT = 1 and PERSISTENT = 2.",
"enum" : [ "1", "2" ],
"type" : "integer"
},
@@ -975,7 +975,7 @@
"type" : "string"
},
"reply-to" : {
- "description" : "Provides an explicit ReplyTo destination, which overrides any incoming value of Message.getJMSReplyTo().",
+ "description" : "Provides an explicit ReplyTo destination (overrides any incoming value of Message.getJMSReplyTo() in consumer).",
"type" : "string"
},
"reply-to-cache-level-name" : {
@@ -1338,28 +1338,11 @@
"enum" : [ "1.0", "1.1" ],
"type" : "string"
},
- "backoff-error-threshold" : {
- "description" : "The number of subsequent error polls (failed due some error) that should happen before the backoffMultipler should kick-in.",
- "type" : "integer"
- },
- "backoff-idle-threshold" : {
- "description" : "The number of subsequent idle polls that should happen before the backoffMultipler should kick-in.",
- "type" : "integer"
- },
- "backoff-multiplier" : {
- "description" : "To let the scheduled polling consumer backoff if there has been a number of subsequent idles/errors in a row. The multiplier is then the number of polls that will be skipped before the next actual attempt is happening again. When this option is in use then backoffIdleThreshold and/or backoffErrorThreshold must also be configured.",
- "type" : "integer"
- },
"basic-property-binding" : {
"description" : "Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities",
"default" : "false",
"type" : "boolean"
},
- "bridge-error-handler" : {
- "description" : "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored.",
- "default" : "false",
- "type" : "boolean"
- },
"client-fqdn" : {
"description" : "The Client Fully Qualified Domain Name (FQDN). Used in message ids sent by endpoint.",
"default" : "camel.apache.org",
@@ -1374,11 +1357,6 @@
"description" : "The key used to encrypt the EDI message.",
"type" : "string"
},
- "delay" : {
- "description" : "Milliseconds before the next poll.",
- "default" : "500",
- "type" : "integer"
- },
"disposition-notification-to" : {
"description" : "The value of the Disposition-Notification-To header. Assigning a value to this parameter requests a message disposition notification (MDN) for the AS2 message.",
"type" : "string"
@@ -1413,20 +1391,10 @@
"description" : "The value of the From header of AS2 message.",
"type" : "string"
},
- "greedy" : {
- "description" : "If greedy is enabled, then the ScheduledPollConsumer will run immediately again, if the previous run polled 1 or more messages.",
- "default" : "false",
- "type" : "boolean"
- },
"in-body" : {
"description" : "Sets the name of a parameter to be passed in the exchange In Body",
"type" : "string"
},
- "initial-delay" : {
- "description" : "Milliseconds before the first poll starts.",
- "default" : "1000",
- "type" : "integer"
- },
"lazy-start-producer" : {
"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 fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and startin [...]
"default" : "false",
@@ -1436,44 +1404,11 @@
"description" : "The template used to format MDN message",
"type" : "string"
},
- "poll-strategy" : {
- "description" : "A pluggable org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your custom implementation to control error handling usually occurred during the poll operation before an Exchange have been created and being routed in Camel.",
- "type" : "string"
- },
- "repeat-count" : {
- "description" : "Specifies a maximum limit of number of fires. So if you set it to 1, the scheduler will only fire once. If you set it to 5, it will only fire five times. A value of zero or negative means fire forever.",
- "default" : "0",
- "type" : "integer"
- },
"request-uri" : {
"description" : "The request URI of EDI message.",
"default" : "/",
"type" : "string"
},
- "run-logging-level" : {
- "description" : "The consumer logs a start/complete log line when it polls. This option allows you to configure the logging level for that.",
- "default" : "TRACE",
- "enum" : [ "TRACE", "DEBUG", "INFO", "WARN", "ERROR", "OFF" ],
- "type" : "string"
- },
- "scheduled-executor-service" : {
- "description" : "Allows for configuring a custom/shared thread pool to use for the consumer. By default each consumer has its own single threaded thread pool.",
- "type" : "string"
- },
- "scheduler" : {
- "description" : "To use a cron scheduler from either camel-spring or camel-quartz component. Use value spring or quartz for built in scheduler",
- "default" : "none",
- "type" : "string"
- },
- "scheduler-properties" : {
- "description" : "To configure additional properties when using a custom scheduler or any of the Quartz, Spring based scheduler.",
- "type" : "string"
- },
- "send-empty-message-when-idle" : {
- "description" : "If the polling consumer did not poll any files, you can enable this option to send an empty message (no body) instead.",
- "default" : "false",
- "type" : "boolean"
- },
"server" : {
"description" : "The value included in the Server message header identifying the AS2 Server.",
"default" : "Camel AS2 Server Endpoint",
@@ -1505,11 +1440,6 @@
"description" : "The key used to sign the EDI message.",
"type" : "string"
},
- "start-scheduler" : {
- "description" : "Whether the scheduler should be auto started.",
- "default" : "true",
- "type" : "boolean"
- },
"subject" : {
"description" : "The value of Subject header of AS2 message.",
"type" : "string"
@@ -1527,17 +1457,6 @@
"description" : "The port number of target host. -1 indicates the scheme default port.",
"type" : "integer"
},
- "time-unit" : {
- "description" : "Time unit for initialDelay and delay options.",
- "default" : "MILLISECONDS",
- "enum" : [ "NANOSECONDS", "MICROSECONDS", "MILLISECONDS", "SECONDS", "MINUTES", "HOURS", "DAYS" ],
- "type" : "string"
- },
- "use-fixed-delay" : {
- "description" : "Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in JDK for details.",
- "default" : "true",
- "type" : "boolean"
- },
"user-agent" : {
"description" : "The value included in the User-Agent message header identifying the AS2 user agent.",
"default" : "Camel AS2 Client Endpoint",
@@ -5453,6 +5372,86 @@
}
}
},
+ "aws2-eventbridge" : {
+ "type" : "object",
+ "required" : [ "eventbusNameOrArn", "operation" ],
+ "properties" : {
+ "eventbus-name-or-arn" : {
+ "description" : "Event bus name or ARN",
+ "type" : "string"
+ },
+ "access-key" : {
+ "description" : "Amazon AWS Access Key",
+ "type" : "string"
+ },
+ "auto-discover-client" : {
+ "description" : "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.",
+ "default" : "true",
+ "type" : "boolean"
+ },
+ "basic-property-binding" : {
+ "description" : "Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities",
+ "default" : "false",
+ "type" : "boolean"
+ },
+ "event-pattern-file" : {
+ "description" : "EventPattern File",
+ "type" : "string"
+ },
+ "eventbridge-client" : {
+ "description" : "To use a existing configured AWS Eventbridge as client",
+ "type" : "string"
+ },
+ "lazy-start-producer" : {
+ "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 fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and startin [...]
+ "default" : "false",
+ "type" : "boolean"
+ },
+ "operation" : {
+ "description" : "The operation to perform",
+ "default" : "putRule",
+ "enum" : [ "putRule", "putTargets", "removeTargets", "deleteRule", "enableRule", "disableRule", "describeRule", "listRules", "listTargetsByRule", "listRuleNamesByTarget" ],
+ "type" : "string"
+ },
+ "pojo-request" : {
+ "description" : "If we want to use a POJO request as body or not",
+ "default" : "false",
+ "type" : "boolean"
+ },
+ "proxy-host" : {
+ "description" : "To define a proxy host when instantiating the Eventbridge client",
+ "type" : "string"
+ },
+ "proxy-port" : {
+ "description" : "To define a proxy port when instantiating the Eventbridge client",
+ "type" : "integer"
+ },
+ "proxy-protocol" : {
+ "description" : "To define a proxy protocol when instantiating the Eventbridge client",
+ "default" : "HTTPS",
+ "enum" : [ "HTTP", "HTTPS" ],
+ "type" : "string"
+ },
+ "region" : {
+ "description" : "The region in which Eventbridge client needs to work. When using this parameter, the configuration will expect the lowercase name of the region (for example ap-east-1) You'll need to use the name Region.EU_WEST_1.id()",
+ "type" : "string"
+ },
+ "secret-key" : {
+ "description" : "Amazon AWS Secret Key",
+ "type" : "string"
+ },
+ "synchronous" : {
+ "description" : "Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported).",
+ "default" : "false",
+ "type" : "boolean"
+ },
+ "trust-all-certificates" : {
+ "description" : "If we want to trust all certificates in case of overriding the endpoint",
+ "default" : "false",
+ "type" : "boolean"
+ }
+ }
+ },
"aws2-iam" : {
"type" : "object",
"required" : [ "label", "operation" ],
@@ -5572,6 +5571,11 @@
"default" : "false",
"type" : "boolean"
},
+ "cbor-enabled" : {
+ "description" : "This option will set the CBOR_ENABLED property during the execution",
+ "default" : "true",
+ "type" : "boolean"
+ },
"delay" : {
"description" : "Milliseconds before the next poll.",
"default" : "500",
@@ -5735,6 +5739,11 @@
"default" : "false",
"type" : "boolean"
},
+ "cbor-enabled" : {
+ "description" : "This option will set the CBOR_ENABLED property during the execution",
+ "default" : "true",
+ "type" : "boolean"
+ },
"lazy-start-producer" : {
"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 fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and startin [...]
"default" : "false",
@@ -5742,7 +5751,7 @@
},
"operation" : {
"description" : "The operation to do in case the user don't want to send only a record",
- "enum" : [ "sendBatchRecord", "createDeliveryStream", "deleteDeliveryStream", "updateDestination" ],
+ "enum" : [ "sendBatchRecord", "createDeliveryStream", "deleteDeliveryStream", "describeDeliveryStream", "updateDestination" ],
"type" : "string"
},
"proxy-host" : {
@@ -6107,7 +6116,7 @@
"type" : "boolean"
},
"autoclose-body" : {
- "description" : "If this option is true and includeBody is true, then the S3Object.close() method will be called on exchange completion. This option is strongly related to includeBody option. In case of setting includeBody to true and autocloseBody to false, it will be up to the caller to close the S3Object stream. Setting autocloseBody to true, will close the S3Object stream automatically.",
+ "description" : "If this option is true and includeBody is false, then the S3Object.close() method will be called on exchange completion. This option is strongly related to includeBody option. In case of setting includeBody to false and autocloseBody to false, it will be up to the caller to close the S3Object stream. Setting autocloseBody to true, will close the S3Object stream automatically.",
"default" : "true",
"type" : "boolean"
},
@@ -6199,7 +6208,7 @@
"type" : "boolean"
},
"include-body" : {
- "description" : "If it is true, the exchange body will be set to a stream to the contents of the file. If false, the headers will be set with the S3 object metadata, but the body will be null. This option is strongly related to autocloseBody option. In case of setting includeBody to true and autocloseBody to false, it will be up to the caller to close the S3Object stream. Setting autocloseBody to true, will close the S3Object stream automatically.",
+ "description" : "If it is true, the S3Object exchange will be consumed and put into the body and closed. If false the S3Object stream will be put raw into the body and the headers will be set with the S3 object metadata. This option is strongly related to autocloseBody option. In case of setting includeBody to true because the S3Object stream will be consumed then it will also be closed in case of includeBody false then it will be up to the caller to close the S3Object stream. [...]
"default" : "true",
"type" : "boolean"
},
@@ -7217,7 +7226,7 @@
"type" : "boolean"
},
"partition-id" : {
- "description" : "Sets the identifier of the Event Hub partition that the {link EventData events} will be sent to. If the identifier is not specified, the Event Hubs service will be responsible for routing events that are sent to an available partition.",
+ "description" : "Sets the identifier of the Event Hub partition that the events will be sent to. If the identifier is not specified, the Event Hubs service will be responsible for routing events that are sent to an available partition.",
"type" : "string"
},
"partition-key" : {
@@ -7230,7 +7239,7 @@
"type" : "integer"
},
"producer-async-client" : {
- "description" : "Sets the EventHubProducerAsyncClient.An asynchronous producer responsible for transmitting EventData to a specific Event Hub, grouped together in batches. Depending on the {link CreateBatchOptions options} specified when creating an {linkEventDataBatch}, the events may be automatically routed to an available partition or specific to a partition. Use by this component to produce the data in camel producer.",
+ "description" : "Sets the EventHubProducerAsyncClient.An asynchronous producer responsible for transmitting EventData to a specific Event Hub, grouped together in batches. Depending on the options specified when creating an {linkEventDataBatch}, the events may be automatically routed to an available partition or specific to a partition. Use by this component to produce the data in camel producer.",
"type" : "string"
},
"shared-access-key" : {
@@ -7352,7 +7361,7 @@
"type" : "boolean"
},
"blob-name" : {
- "description" : "The blob name, required for consumer. However on producer, is only required for the operations on the blob level",
+ "description" : "The blob name, to consume specific blob from a container. However on producer, is only required for the operations on the blob level",
"type" : "string"
},
"blob-offset" : {
@@ -7466,7 +7475,7 @@
"type" : "string"
},
"service-client" : {
- "description" : "Client to a storage account. This client does not hold any state about a particular storage account but is instead a convenient way of sending off appropriate requests to the resource on the service. It may also be used to construct URLs to blobs and containers. This client contains operations on a service account. Operations on a container are available on BlobContainerClient through getBlobContainerClient(String), and operations on a blob are available on Blo [...]
+ "description" : "Client to a storage account. This client does not hold any state about a particular storage account but is instead a convenient way of sending off appropriate requests to the resource on the service. It may also be used to construct URLs to blobs and containers. This client contains operations on a service account. Operations on a container are available on BlobContainerClient through BlobServiceClient#getBlobContainerClient(String), and operations on a blob ar [...]
"type" : "string"
},
"synchronous" : {
@@ -7891,28 +7900,11 @@
"default" : "APP_USER_AUTHENTICATION",
"type" : "string"
},
- "backoff-error-threshold" : {
- "description" : "The number of subsequent error polls (failed due some error) that should happen before the backoffMultipler should kick-in.",
- "type" : "integer"
- },
- "backoff-idle-threshold" : {
- "description" : "The number of subsequent idle polls that should happen before the backoffMultipler should kick-in.",
- "type" : "integer"
- },
- "backoff-multiplier" : {
- "description" : "To let the scheduled polling consumer backoff if there has been a number of subsequent idles/errors in a row. The multiplier is then the number of polls that will be skipped before the next actual attempt is happening again. When this option is in use then backoffIdleThreshold and/or backoffErrorThreshold must also be configured.",
- "type" : "integer"
- },
"basic-property-binding" : {
"description" : "Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities",
"default" : "false",
"type" : "boolean"
},
- "bridge-error-handler" : {
- "description" : "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored.",
- "default" : "false",
- "type" : "boolean"
- },
"client-id" : {
"description" : "Box application client ID",
"type" : "string"
@@ -7921,11 +7913,6 @@
"description" : "Box application client secret",
"type" : "string"
},
- "delay" : {
- "description" : "Milliseconds before the next poll.",
- "default" : "500",
- "type" : "integer"
- },
"encryption-algorithm" : {
"description" : "The type of encryption algorithm for JWT. Supported Algorithms: RSA_SHA_256 RSA_SHA_384 RSA_SHA_512",
"default" : "RSA_SHA_256",
@@ -7945,11 +7932,6 @@
"enum" : [ "InOnly", "InOut", "InOptionalOut" ],
"type" : "string"
},
- "greedy" : {
- "description" : "If greedy is enabled, then the ScheduledPollConsumer will run immediately again, if the previous run polled 1 or more messages.",
- "default" : "false",
- "type" : "boolean"
- },
"http-params" : {
"description" : "Custom HTTP params for settings like proxy host",
"type" : "string"
@@ -7958,11 +7940,6 @@
"description" : "Sets the name of a parameter to be passed in the exchange In Body",
"type" : "string"
},
- "initial-delay" : {
- "description" : "Milliseconds before the first poll starts.",
- "default" : "1000",
- "type" : "integer"
- },
"lazy-start-producer" : {
"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 fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and startin [...]
"default" : "false",
@@ -7973,10 +7950,6 @@
"default" : "100",
"type" : "integer"
},
- "poll-strategy" : {
- "description" : "A pluggable org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your custom implementation to control error handling usually occurred during the poll operation before an Exchange have been created and being routed in Camel.",
- "type" : "string"
- },
"private-key-file" : {
"description" : "The private key for generating the JWT signature.",
"type" : "string"
@@ -7989,60 +7962,15 @@
"description" : "The ID for public key for validating the JWT signature.",
"type" : "string"
},
- "repeat-count" : {
- "description" : "Specifies a maximum limit of number of fires. So if you set it to 1, the scheduler will only fire once. If you set it to 5, it will only fire five times. A value of zero or negative means fire forever.",
- "default" : "0",
- "type" : "integer"
- },
- "run-logging-level" : {
- "description" : "The consumer logs a start/complete log line when it polls. This option allows you to configure the logging level for that.",
- "default" : "TRACE",
- "enum" : [ "TRACE", "DEBUG", "INFO", "WARN", "ERROR", "OFF" ],
- "type" : "string"
- },
- "scheduled-executor-service" : {
- "description" : "Allows for configuring a custom/shared thread pool to use for the consumer. By default each consumer has its own single threaded thread pool.",
- "type" : "string"
- },
- "scheduler" : {
- "description" : "To use a cron scheduler from either camel-spring or camel-quartz component. Use value spring or quartz for built in scheduler",
- "default" : "none",
- "type" : "string"
- },
- "scheduler-properties" : {
- "description" : "To configure additional properties when using a custom scheduler or any of the Quartz, Spring based scheduler.",
- "type" : "string"
- },
- "send-empty-message-when-idle" : {
- "description" : "If the polling consumer did not poll any files, you can enable this option to send an empty message (no body) instead.",
- "default" : "false",
- "type" : "boolean"
- },
"ssl-context-parameters" : {
"description" : "To configure security using SSLContextParameters.",
"type" : "string"
},
- "start-scheduler" : {
- "description" : "Whether the scheduler should be auto started.",
- "default" : "true",
- "type" : "boolean"
- },
"synchronous" : {
"description" : "Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported).",
"default" : "false",
"type" : "boolean"
},
- "time-unit" : {
- "description" : "Time unit for initialDelay and delay options.",
- "default" : "MILLISECONDS",
- "enum" : [ "NANOSECONDS", "MICROSECONDS", "MILLISECONDS", "SECONDS", "MINUTES", "HOURS", "DAYS" ],
- "type" : "string"
- },
- "use-fixed-delay" : {
- "description" : "Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in JDK for details.",
- "default" : "true",
- "type" : "boolean"
- },
"user-id" : {
"description" : "The user ID to use for an App User.",
"type" : "string"
@@ -8059,66 +7987,31 @@
},
"braintree" : {
"type" : "object",
- "required" : [ "apiName" ],
+ "required" : [ "apiName", "methodName" ],
"properties" : {
"api-name" : {
"description" : "What kind of operation to perform",
- "enum" : [ "ADDON", "ADDRESS", "CLIENTTOKEN", "CREDITCARDVERIFICATION", "CUSTOMER", "DISCOUNT", "DISPUTE", "DOCUMENTUPLOAD", "MERCHANTACCOUNT", "PAYMENTMETHOD", "PAYMENTMETHODNONCE", "PLAN", "REPORT", "SETTLEMENTBATCHSUMMARY", "SUBSCRIPTION", "TRANSACTION", "WEBHOOKNOTIFICATION" ],
+ "enum" : [ "ADD_ON", "ADDRESS", "CLIENT_TOKEN", "CREDIT_CARD_VERIFICATION", "CUSTOMER", "DISCOUNT", "DISPUTE", "DOCUMENT_UPLOAD", "MERCHANT_ACCOUNT", "PAYMENT_METHOD", "PAYMENT_METHOD_NONCE", "PLAN", "REPORT", "SETTLEMENT_BATCH_SUMMARY", "SUBSCRIPTION", "TRANSACTION", "WEBHOOK_NOTIFICATION" ],
"type" : "string"
},
"method-name" : {
"description" : "What sub operation to use for the selected operation",
+ "enum" : [ "accept", "addFileEvidence", "addTextEvidence", "cancel", "cancelRelease", "cloneTransaction", "create", "createForCurrency", "credit", "delete", "fetchMerchantAccounts", "finalize", "find", "generate", "grant", "holdInEscrow", "parse", "refund", "releaseFromEscrow", "removeEvidence", "retryCharge", "revoke", "sale", "search", "submitForPartialSettlement", "submitForSettlement", "transactionLevelFees", "update", "updateDetails", "verify", "voidTransaction" ],
"type" : "string"
},
"access-token" : {
"description" : "The access token granted by a merchant to another in order to process transactions on their behalf. Used in place of environment, merchant id, public key and private key fields.",
"type" : "string"
},
- "backoff-error-threshold" : {
- "description" : "The number of subsequent error polls (failed due some error) that should happen before the backoffMultipler should kick-in.",
- "type" : "integer"
- },
- "backoff-idle-threshold" : {
- "description" : "The number of subsequent idle polls that should happen before the backoffMultipler should kick-in.",
- "type" : "integer"
- },
- "backoff-multiplier" : {
- "description" : "To let the scheduled polling consumer backoff if there has been a number of subsequent idles/errors in a row. The multiplier is then the number of polls that will be skipped before the next actual attempt is happening again. When this option is in use then backoffIdleThreshold and/or backoffErrorThreshold must also be configured.",
- "type" : "integer"
- },
"basic-property-binding" : {
"description" : "Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities",
"default" : "false",
"type" : "boolean"
},
- "bridge-error-handler" : {
- "description" : "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored.",
- "default" : "false",
- "type" : "boolean"
- },
- "delay" : {
- "description" : "Milliseconds before the next poll.",
- "default" : "500",
- "type" : "integer"
- },
"environment" : {
"description" : "The environment Either SANDBOX or PRODUCTION",
"type" : "string"
},
- "exception-handler" : {
- "description" : "To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored.",
- "type" : "string"
- },
- "exchange-pattern" : {
- "description" : "Sets the exchange pattern when the consumer creates an exchange.",
- "enum" : [ "InOnly", "InOut", "InOptionalOut" ],
- "type" : "string"
- },
- "greedy" : {
- "description" : "If greedy is enabled, then the ScheduledPollConsumer will run immediately again, if the previous run polled 1 or more messages.",
- "default" : "false",
- "type" : "boolean"
- },
"http-log-level" : {
"description" : "Set logging level for http calls, see java.util.logging.Level",
"enum" : [ "OFF", "SEVERE", "WARNING", "INFO", "CONFIG", "FINE", "FINER", "FINEST", "ALL" ],
@@ -8137,11 +8030,6 @@
"description" : "Sets the name of a parameter to be passed in the exchange In Body",
"type" : "string"
},
- "initial-delay" : {
- "description" : "Milliseconds before the first poll starts.",
- "default" : "1000",
- "type" : "integer"
- },
"lazy-start-producer" : {
"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 fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and startin [...]
"default" : "false",
@@ -8156,10 +8044,6 @@
"description" : "The merchant id provided by Braintree.",
"type" : "string"
},
- "poll-strategy" : {
- "description" : "A pluggable org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your custom implementation to control error handling usually occurred during the poll operation before an Exchange have been created and being routed in Camel.",
- "type" : "string"
- },
"private-key" : {
"description" : "The private key provided by Braintree.",
"type" : "string"
@@ -8176,55 +8060,10 @@
"description" : "The public key provided by Braintree.",
"type" : "string"
},
- "repeat-count" : {
- "description" : "Specifies a maximum limit of number of fires. So if you set it to 1, the scheduler will only fire once. If you set it to 5, it will only fire five times. A value of zero or negative means fire forever.",
- "default" : "0",
- "type" : "integer"
- },
- "run-logging-level" : {
- "description" : "The consumer logs a start/complete log line when it polls. This option allows you to configure the logging level for that.",
- "default" : "TRACE",
- "enum" : [ "TRACE", "DEBUG", "INFO", "WARN", "ERROR", "OFF" ],
- "type" : "string"
- },
- "scheduled-executor-service" : {
- "description" : "Allows for configuring a custom/shared thread pool to use for the consumer. By default each consumer has its own single threaded thread pool.",
- "type" : "string"
- },
- "scheduler" : {
- "description" : "To use a cron scheduler from either camel-spring or camel-quartz component. Use value spring or quartz for built in scheduler",
- "default" : "none",
- "type" : "string"
- },
- "scheduler-properties" : {
- "description" : "To configure additional properties when using a custom scheduler or any of the Quartz, Spring based scheduler.",
- "type" : "string"
- },
- "send-empty-message-when-idle" : {
- "description" : "If the polling consumer did not poll any files, you can enable this option to send an empty message (no body) instead.",
- "default" : "false",
- "type" : "boolean"
- },
- "start-scheduler" : {
- "description" : "Whether the scheduler should be auto started.",
- "default" : "true",
- "type" : "boolean"
- },
"synchronous" : {
"description" : "Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported).",
"default" : "false",
"type" : "boolean"
- },
- "time-unit" : {
- "description" : "Time unit for initialDelay and delay options.",
- "default" : "MILLISECONDS",
- "enum" : [ "NANOSECONDS", "MICROSECONDS", "MILLISECONDS", "SECONDS", "MINUTES", "HOURS", "DAYS" ],
- "type" : "string"
- },
- "use-fixed-delay" : {
- "description" : "Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in JDK for details.",
- "default" : "true",
- "type" : "boolean"
}
}
},
@@ -8284,10 +8123,6 @@
"default" : "false",
"type" : "boolean"
},
- "cache" : {
- "description" : "To configure an already instantiated cache to be used",
- "type" : "string"
- },
"cache-loader" : {
"description" : "To configure a CacheLoader in case of a LoadCache use",
"type" : "string"
@@ -8377,10 +8212,6 @@
"default" : "false",
"type" : "boolean"
},
- "cache" : {
- "description" : "To configure an already instantiated cache to be used",
- "type" : "string"
- },
"cache-loader" : {
"description" : "To configure a CacheLoader in case of a LoadCache use",
"type" : "string"
@@ -10519,12 +10350,12 @@
"default" : "false",
"type" : "boolean"
},
- "collection-blacklist" : {
- "description" : "Description is not available here, please check Debezium website for corresponding key 'collection.blacklist' description.",
+ "collection-exclude-list" : {
+ "description" : "A comma-separated list of regular expressions that match the collection names for which changes are to be excluded",
"type" : "string"
},
- "collection-whitelist" : {
- "description" : "The collections for which changes are to be captured",
+ "collection-include-list" : {
+ "description" : "A comma-separated list of regular expressions that match the collection names for which changes are to be captured",
"type" : "string"
},
"connect-backoff-initial-delay-ms" : {
@@ -10546,16 +10377,16 @@
"description" : "Optional list of custom converters that would be used instead of default ones. The converters are defined using '.type' config option and configured using options '.'",
"type" : "string"
},
- "database-blacklist" : {
- "description" : "The databases for which changes are to be excluded",
+ "database-exclude-list" : {
+ "description" : "A comma-separated list of regular expressions that match the database names for which changes are to be excluded",
"type" : "string"
},
"database-history-file-filename" : {
"description" : "The path to the file that will be used to record the database history",
"type" : "string"
},
- "database-whitelist" : {
- "description" : "The databases for which changes are to be captured",
+ "database-include-list" : {
+ "description" : "A comma-separated list of regular expressions that match the database names for which changes are to be captured",
"type" : "string"
},
"event-processing-failure-handling-mode" : {
@@ -10572,8 +10403,8 @@
"enum" : [ "InOnly", "InOut", "InOptionalOut" ],
"type" : "string"
},
- "field-blacklist" : {
- "description" : "Description is not available here, please check Debezium website for corresponding key 'field.blacklist' description.",
+ "field-exclude-list" : {
+ "description" : "A comma-separated list of the fully-qualified names of fields that should be excluded from change event message values",
"type" : "string"
},
"field-renames" : {
@@ -10620,6 +10451,11 @@
"default" : "admin",
"type" : "string"
},
+ "mongodb-connect-timeout-ms" : {
+ "description" : "The connection timeout in milliseconds",
+ "default" : "10s",
+ "type" : "string"
+ },
"mongodb-hosts" : {
"description" : "The hostname and port pairs (in the form 'host' or 'host:port') of the MongoDB server(s) in the replica set.",
"type" : "string"
@@ -10637,10 +10473,20 @@
"description" : "Password to be used when connecting to MongoDB, if necessary.",
"type" : "string"
},
- "mongodb-poll-interval-sec" : {
- "description" : "Frequency in seconds to look for new, removed, or changed replica sets. Defaults to 30 seconds.",
- "default" : "30",
- "type" : "integer"
+ "mongodb-poll-interval-ms" : {
+ "description" : "Frequency in milliseconds to look for new, removed, or changed replica sets. Defaults to 30000 milliseconds.",
+ "default" : "30s",
+ "type" : "string"
+ },
+ "mongodb-server-selection-timeout-ms" : {
+ "description" : "The server selection timeout in milliseconds",
+ "default" : "30s",
+ "type" : "string"
+ },
+ "mongodb-socket-timeout-ms" : {
+ "description" : "The socket timeout in milliseconds",
+ "default" : "0ms",
+ "type" : "string"
},
"mongodb-ssl-enabled" : {
"description" : "Should connector use SSL to connect to MongoDB instances",
@@ -10702,6 +10548,16 @@
"default" : "false",
"type" : "boolean"
},
+ "query-fetch-size" : {
+ "description" : "The maximum number of records that should be loaded into memory while streaming. A value of 0 uses the default JDBC fetch size.",
+ "default" : "0",
+ "type" : "integer"
+ },
+ "retriable-restart-connector-wait-ms" : {
+ "description" : "Time to wait before restarting connector after retriable exception occurs. Defaults to 10000ms.",
+ "default" : "10s",
+ "type" : "string"
+ },
"sanitize-field-names" : {
"description" : "Whether field names will be sanitized to Avro naming conventions",
"default" : "false",
@@ -10780,9 +10636,17 @@
"type" : "boolean"
},
"column-blacklist" : {
+ "description" : "Regular expressions matching columns to exclude from change events (deprecated, use column.exclude.list instead)",
+ "type" : "string"
+ },
+ "column-exclude-list" : {
"description" : "Regular expressions matching columns to exclude from change events",
"type" : "string"
},
+ "column-include-list" : {
+ "description" : "Regular expressions matching columns to include in change events",
+ "type" : "string"
+ },
"connect-keep-alive" : {
"description" : "Whether a separate thread should be used to ensure the connection is kept alive.",
"default" : "true",
@@ -10798,8 +10662,8 @@
"default" : "30s",
"type" : "string"
},
- "database-blacklist" : {
- "description" : "Description is not available here, please check Debezium website for corresponding key 'database.blacklist' description.",
+ "database-exclude-list" : {
+ "description" : "A comma-separated list of regular expressions that match database names to be excluded from monitoring",
"type" : "string"
},
"database-history" : {
@@ -10843,6 +10707,10 @@
"description" : "Resolvable hostname or IP address of the MySQL database server.",
"type" : "string"
},
+ "database-include-list" : {
+ "description" : "The databases for which changes are to be captured",
+ "type" : "string"
+ },
"database-initial-statements" : {
"description" : "A semicolon separated list of SQL statements to be executed when a JDBC connection (not binlog reading connection) to the database is established. Note that the connector may establish JDBC connections at its own discretion, so this should typically be used for configuration of session parameters only,but not for executing DML statements. Use doubled semicolon (';;') to use a semicolon as a character and not as a delimiter.",
"type" : "string"
@@ -10899,10 +10767,6 @@
"description" : "Name of the MySQL database user to be used when connecting to the database.",
"type" : "string"
},
- "database-whitelist" : {
- "description" : "The databases for which changes are to be captured",
- "type" : "string"
- },
"decimal-handling-mode" : {
"description" : "Specify how DECIMAL and NUMERIC columns should be represented in change events, including:'precise' (the default) uses java.math.BigDecimal to represent values, which are encoded in the change events using a binary representation and Kafka Connect's 'org.apache.kafka.connect.data.Decimal' type; 'string' uses string to represent values; 'double' represents values using Java's 'double', which may not offer the precision but will be far easier to use in consumers.",
"default" : "precise",
@@ -11083,7 +10947,11 @@
"type" : "boolean"
},
"table-blacklist" : {
- "description" : "Description is not available here, please check Debezium website for corresponding key 'table.blacklist' description.",
+ "description" : "A comma-separated list of regular expressions that match the fully-qualified names of tables to be excluded from monitoring (deprecated, use table.exclude.list instead)",
+ "type" : "string"
+ },
+ "table-exclude-list" : {
+ "description" : "A comma-separated list of regular expressions that match the fully-qualified names of tables to be excluded from monitoring",
"type" : "string"
},
"table-ignore-builtin" : {
@@ -11091,10 +10959,14 @@
"default" : "true",
"type" : "boolean"
},
- "table-whitelist" : {
+ "table-include-list" : {
"description" : "The tables for which changes are to be captured",
"type" : "string"
},
+ "table-whitelist" : {
+ "description" : "The tables for which changes are to be captured (deprecated, use table.include.list instead)",
+ "type" : "string"
+ },
"time-precision-mode" : {
"description" : "Time, date and timestamps can be represented with different kinds of precisions, including:'adaptive_time_microseconds': the precision of date and timestamp values is based the database column's precision; but time fields always use microseconds precision;'connect': always represents time, date and timestamp values using Kafka Connect's built-in representations for Time, Date, and Timestamp, which uses millisecond precision regardless of the database columns' p [...]
"default" : "adaptive_time_microseconds",
@@ -11135,13 +11007,25 @@
"type" : "boolean"
},
"column-blacklist" : {
+ "description" : "Regular expressions matching columns to exclude from change events (deprecated, use column.exclude.list instead)",
+ "type" : "string"
+ },
+ "column-exclude-list" : {
"description" : "Regular expressions matching columns to exclude from change events",
"type" : "string"
},
- "column-whitelist" : {
+ "column-include-list" : {
"description" : "Regular expressions matching columns to include in change events",
"type" : "string"
},
+ "column-propagate-source-type" : {
+ "description" : "A comma-separated list of regular expressions matching fully-qualified names of columns that adds the columns original type and original length as parameters to the corresponding field schemas in the emitted change records.",
+ "type" : "string"
+ },
+ "column-whitelist" : {
+ "description" : "Regular expressions matching columns to include in change events (deprecated, use column.include.list instead)",
+ "type" : "string"
+ },
"converters" : {
"description" : "Optional list of custom converters that would be used instead of default ones. The converters are defined using '.type' config option and configured using options '.'",
"type" : "string"
@@ -11209,6 +11093,10 @@
"description" : "Name of the Postgres database user to be used when connecting to the database.",
"type" : "string"
},
+ "datatype-propagate-source-type" : {
+ "description" : "A comma-separated list of regular expressions matching the database-specific data type names that adds the data type's original type and original length as parameters to the corresponding field schemas in the emitted change records.",
+ "type" : "string"
+ },
"decimal-handling-mode" : {
"description" : "Specify how DECIMAL and NUMERIC columns should be represented in change events, including:'precise' (the default) uses java.math.BigDecimal to represent values, which are encoded in the change events using a binary representation and Kafka Connect's 'org.apache.kafka.connect.data.Decimal' type; 'string' uses string to represent values; 'double' represents values using Java's 'double', which may not offer the precision but will be far easier to use in consumers.",
"default" : "precise",
@@ -11229,7 +11117,7 @@
"type" : "string"
},
"heartbeat-action-query" : {
- "description" : "The query executed with every heartbeat. Defaults to an empty string.",
+ "description" : "The query executed with every heartbeat.",
"type" : "string"
},
"heartbeat-interval-ms" : {
@@ -11333,7 +11221,7 @@
"type" : "boolean"
},
"publication-autocreate-mode" : {
- "description" : "Applies only when streaming changes using pgoutput.Determine how creation of a publication should work, the default is all_tables.DISABLED - The connector will not attempt to create a publication at all. The expectation is that the user has created the publication up-front. If the publication isn't found to exist upon startup, the connector will throw an exception and stop.ALL_TABLES - If no publication exists, the connector will create a new publication for al [...]
+ "description" : "Applies only when streaming changes using pgoutput.Determine how creation of a publication should work, the default is all_tables.DISABLED - The connector will not attempt to create a publication at all. The expectation is that the user has created the publication up-front. If the publication isn't found to exist upon startup, the connector will throw an exception and stop.ALL_TABLES - If no publication exists, the connector will create a new publication for al [...]
"default" : "all_tables",
"type" : "string"
},
@@ -11342,22 +11230,40 @@
"default" : "dbz_publication",
"type" : "string"
},
+ "query-fetch-size" : {
+ "description" : "The maximum number of records that should be loaded into memory while streaming. A value of 0 uses the default JDBC fetch size.",
+ "default" : "0",
+ "type" : "integer"
+ },
+ "retriable-restart-connector-wait-ms" : {
+ "description" : "Time to wait before restarting connector after retriable exception occurs. Defaults to 10000ms.",
+ "default" : "10s",
+ "type" : "string"
+ },
"sanitize-field-names" : {
"description" : "Whether field names will be sanitized to Avro naming conventions",
"default" : "false",
"type" : "boolean"
},
"schema-blacklist" : {
+ "description" : "The schemas for which events must not be captured (deprecated, use schema.exclude.list instead)",
+ "type" : "string"
+ },
+ "schema-exclude-list" : {
"description" : "The schemas for which events must not be captured",
"type" : "string"
},
+ "schema-include-list" : {
+ "description" : "The schemas for which events should be captured",
+ "type" : "string"
+ },
"schema-refresh-mode" : {
"description" : "Specify the conditions that trigger a refresh of the in-memory schema for a table. 'columns_diff' (the default) is the safest mode, ensuring the in-memory schema stays in-sync with the database table's schema at all times. 'columns_diff_exclude_unchanged_toast' instructs the connector to refresh the in-memory schema cache if there is a discrepancy between it and the schema derived from the incoming message, unless unchanged TOASTable data fully accounts for the [...]
"default" : "columns_diff",
"type" : "string"
},
"schema-whitelist" : {
- "description" : "The schemas for which events should be captured",
+ "description" : "The schemas for which events should be captured (deprecated, use schema.include.list instead)",
"type" : "string"
},
"skipped-operations" : {
@@ -11431,7 +11337,11 @@
"type" : "boolean"
},
"table-blacklist" : {
- "description" : "Description is not available here, please check Debezium website for corresponding key 'table.blacklist' description.",
+ "description" : "A comma-separated list of regular expressions that match the fully-qualified names of tables to be excluded from monitoring (deprecated, use table.exclude.list instead)",
+ "type" : "string"
+ },
+ "table-exclude-list" : {
+ "description" : "A comma-separated list of regular expressions that match the fully-qualified names of tables to be excluded from monitoring",
"type" : "string"
},
"table-ignore-builtin" : {
@@ -11439,17 +11349,21 @@
"default" : "true",
"type" : "boolean"
},
- "table-whitelist" : {
+ "table-include-list" : {
"description" : "The tables for which changes are to be captured",
"type" : "string"
},
+ "table-whitelist" : {
+ "description" : "The tables for which changes are to be captured (deprecated, use table.include.list instead)",
+ "type" : "string"
+ },
"time-precision-mode" : {
"description" : "Time, date, and timestamps can be represented with different kinds of precisions, including:'adaptive' (the default) bases the precision of time, date, and timestamp values on the database column's precision; 'adaptive_time_microseconds' like 'adaptive' mode, but TIME fields always use microseconds precision;'connect' always represents time, date, and timestamp values using Kafka Connect's built-in representations for Time, Date, and Timestamp, which uses milli [...]
"default" : "adaptive",
"type" : "string"
},
"toasted-value-placeholder" : {
- "description" : "Specify the constant that will be provided by Debezium to indicate that the original value is a toasted value not provided by the database.If starts with 'hex:' prefix it is expected that the rest of the string repesents hexadecimally encoded octets.",
+ "description" : "Specify the constant that will be provided by Debezium to indicate that the original value is a toasted value not provided by the database. If starts with 'hex:' prefix it is expected that the rest of the string repesents hexadecimally encoded octets.",
"default" : "__debezium_unavailable_value",
"type" : "string"
},
@@ -11488,13 +11402,25 @@
"type" : "boolean"
},
"column-blacklist" : {
+ "description" : "Regular expressions matching columns to exclude from change events (deprecated, use column.exclude.list instead)",
+ "type" : "string"
+ },
+ "column-exclude-list" : {
"description" : "Regular expressions matching columns to exclude from change events",
"type" : "string"
},
- "column-whitelist" : {
+ "column-include-list" : {
"description" : "Regular expressions matching columns to include in change events",
"type" : "string"
},
+ "column-propagate-source-type" : {
+ "description" : "A comma-separated list of regular expressions matching fully-qualified names of columns that adds the columns original type and original length as parameters to the corresponding field schemas in the emitted change records.",
+ "type" : "string"
+ },
+ "column-whitelist" : {
+ "description" : "Regular expressions matching columns to include in change events (deprecated, use column.include.list instead)",
+ "type" : "string"
+ },
"converters" : {
"description" : "Optional list of custom converters that would be used instead of default ones. The converters are defined using '.type' config option and configured using options '.'",
"type" : "string"
@@ -11534,6 +11460,10 @@
"description" : "Resolvable hostname or IP address of the SQL Server database server.",
"type" : "string"
},
+ "database-instance" : {
+ "description" : "The SQL Server instance name",
+ "type" : "string"
+ },
"database-password" : {
"description" : "Password of the SQL Server database user to be used when connecting to the database.",
"type" : "string"
@@ -11555,6 +11485,10 @@
"description" : "Name of the SQL Server database user to be used when connecting to the database.",
"type" : "string"
},
+ "datatype-propagate-source-type" : {
+ "description" : "A comma-separated list of regular expressions matching the database-specific data type names that adds the data type's original type and original length as parameters to the corresponding field schemas in the emitted change records.",
+ "type" : "string"
+ },
"decimal-handling-mode" : {
"description" : "Specify how DECIMAL and NUMERIC columns should be represented in change events, including:'precise' (the default) uses java.math.BigDecimal to represent values, which are encoded in the change events using a binary representation and Kafka Connect's 'org.apache.kafka.connect.data.Decimal' type; 'string' uses string to represent values; 'double' represents values using Java's 'double', which may not offer the precision but will be far easier to use in consumers.",
"default" : "precise",
@@ -11659,6 +11593,16 @@
"default" : "false",
"type" : "boolean"
},
+ "query-fetch-size" : {
+ "description" : "The maximum number of records that should be loaded into memory while streaming. A value of 0 uses the default JDBC fetch size.",
+ "default" : "0",
+ "type" : "integer"
+ },
+ "retriable-restart-connector-wait-ms" : {
+ "description" : "Time to wait before restarting connector after retriable exception occurs. Defaults to 10000ms.",
+ "default" : "10s",
+ "type" : "string"
+ },
"sanitize-field-names" : {
"description" : "Whether field names will be sanitized to Avro naming conventions",
"default" : "false",
@@ -11712,7 +11656,11 @@
"type" : "boolean"
},
"table-blacklist" : {
- "description" : "Description is not available here, please check Debezium website for corresponding key 'table.blacklist' description.",
+ "description" : "A comma-separated list of regular expressions that match the fully-qualified names of tables to be excluded from monitoring (deprecated, use table.exclude.list instead)",
+ "type" : "string"
+ },
+ "table-exclude-list" : {
+ "description" : "A comma-separated list of regular expressions that match the fully-qualified names of tables to be excluded from monitoring",
"type" : "string"
},
"table-ignore-builtin" : {
@@ -11720,10 +11668,14 @@
"default" : "true",
"type" : "boolean"
},
- "table-whitelist" : {
+ "table-include-list" : {
"description" : "The tables for which changes are to be captured",
"type" : "string"
},
+ "table-whitelist" : {
+ "description" : "The tables for which changes are to be captured (deprecated, use table.include.list instead)",
+ "type" : "string"
+ },
"time-precision-mode" : {
"description" : "Time, date, and timestamps can be represented with different kinds of precisions, including:'adaptive' (the default) bases the precision of time, date, and timestamp values on the database column's precision; 'adaptive_time_microseconds' like 'adaptive' mode, but TIME fields always use microseconds precision;'connect' always represents time, date, and timestamp values using Kafka Connect's built-in representations for Time, Date, and Timestamp, which uses milli [...]
"default" : "adaptive",
@@ -13606,7 +13558,7 @@
"properties" : {
"api-name" : {
"description" : "What kind of operation to perform",
- "enum" : [ "capabilities", "create", "delete", "history", "load-page", "meta", "patch", "read", "search", "transaction", "update", "validate" ],
+ "enum" : [ "CAPABILITIES", "CREATE", "DELETE", "HISTORY", "LOAD_PAGE", "META", "OPERATION", "PATCH", "READ", "SEARCH", "TRANSACTION", "UPDATE", "VALIDATE" ],
"type" : "string"
},
"method-name" : {
@@ -16286,6 +16238,7 @@
},
"google-calendar-stream" : {
"type" : "object",
+ "required" : [ "index" ],
"properties" : {
"index" : {
"description" : "Specifies an index for the endpoint",
@@ -16447,7 +16400,7 @@
"properties" : {
"api-name" : {
"description" : "What kind of operation to perform",
- "enum" : [ "drive-about", "drive-apps", "drive-changes", "drive-channels", "drive-children", "drive-comments", "drive-files", "drive-parents", "drive-permissions", "drive-properties", "drive-realtime", "drive-replies", "drive-revisions" ],
+ "enum" : [ "DRIVE_ABOUT", "DRIVE_APPS", "DRIVE_CHANGES", "DRIVE_CHANNELS", "DRIVE_CHILDREN", "DRIVE_COMMENTS", "DRIVE_FILES", "DRIVE_PARENTS", "DRIVE_PERMISSIONS", "DRIVE_PROPERTIES", "DRIVE_REALTIME", "DRIVE_REPLIES", "DRIVE_REVISIONS" ],
"type" : "string"
},
"method-name" : {
@@ -16741,9 +16694,10 @@
},
"google-mail-stream" : {
"type" : "object",
+ "required" : [ "index" ],
"properties" : {
"index" : {
- "description" : "Specifies an index for the endpoint",
+ "description" : "Currently not in use",
"type" : "string"
},
"access-token" : {
@@ -17077,6 +17031,11 @@
"default" : "false",
"type" : "boolean"
},
+ "split-result" : {
+ "description" : "When consumer return an array or collection this will generate one exchange per element, and their routes will be executed once for each exchange. Set this value to false to use a single exchange for the entire list or array.",
+ "default" : "true",
+ "type" : "boolean"
+ },
"start-scheduler" : {
"description" : "Whether the scheduler should be auto started.",
"default" : "true",
@@ -17102,6 +17061,7 @@
},
"google-sheets-stream" : {
"type" : "object",
+ "required" : [ "apiName" ],
"properties" : {
"api-name" : {
"description" : "Sets the apiName.",
@@ -17182,7 +17142,6 @@
},
"max-results" : {
"description" : "Specify the maximum number of returned results. This will limit the number of rows in a returned value range data set or the number of returned value ranges in a batch request.",
- "default" : "0",
"type" : "integer"
},
"poll-strategy" : {
@@ -18576,143 +18535,6 @@
}
}
},
- "hipchat" : {
- "type" : "object",
- "required" : [ "host", "protocol" ],
- "properties" : {
- "host" : {
- "description" : "The host for the hipchat server, such as api.hipchat.com",
- "type" : "string"
- },
- "port" : {
- "description" : "The port for the hipchat server. Is by default 80.",
- "default" : "80",
- "type" : "integer"
- },
- "protocol" : {
- "description" : "The protocol for the hipchat server, such as http.",
- "type" : "string"
- },
- "auth-token" : {
- "description" : "OAuth 2 auth token",
- "type" : "string"
- },
- "backoff-error-threshold" : {
- "description" : "The number of subsequent error polls (failed due some error) that should happen before the backoffMultipler should kick-in.",
- "type" : "integer"
- },
- "backoff-idle-threshold" : {
- "description" : "The number of subsequent idle polls that should happen before the backoffMultipler should kick-in.",
- "type" : "integer"
- },
- "backoff-multiplier" : {
- "description" : "To let the scheduled polling consumer backoff if there has been a number of subsequent idles/errors in a row. The multiplier is then the number of polls that will be skipped before the next actual attempt is happening again. When this option is in use then backoffIdleThreshold and/or backoffErrorThreshold must also be configured.",
- "type" : "integer"
- },
- "basic-property-binding" : {
- "description" : "Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities",
- "default" : "false",
- "type" : "boolean"
- },
- "bridge-error-handler" : {
- "description" : "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored.",
- "default" : "false",
- "type" : "boolean"
- },
- "consume-users" : {
- "description" : "Username(s) when consuming messages from the hiptchat server. Multiple user names can be separated by comma.",
- "type" : "string"
- },
- "delay" : {
- "description" : "Milliseconds before the next poll.",
- "default" : "5000",
- "type" : "integer"
- },
- "exception-handler" : {
- "description" : "To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored.",
- "type" : "string"
- },
- "exchange-pattern" : {
- "description" : "Sets the exchange pattern when the consumer creates an exchange.",
- "enum" : [ "InOnly", "InOut", "InOptionalOut" ],
- "type" : "string"
- },
- "greedy" : {
- "description" : "If greedy is enabled, then the ScheduledPollConsumer will run immediately again, if the previous run polled 1 or more messages.",
- "default" : "false",
- "type" : "boolean"
- },
- "http-client" : {
- "description" : "The CloseableHttpClient reference from registry to be used during API HTTP requests.",
- "default" : "CloseableHttpClient default from HttpClient library",
- "type" : "string"
- },
- "initial-delay" : {
- "description" : "Milliseconds before the first poll starts.",
- "default" : "1000",
- "type" : "integer"
- },
- "lazy-start-producer" : {
- "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 fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and startin [...]
- "default" : "false",
- "type" : "boolean"
- },
- "poll-strategy" : {
- "description" : "A pluggable org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your custom implementation to control error handling usually occurred during the poll operation before an Exchange have been created and being routed in Camel.",
- "type" : "string"
- },
- "repeat-count" : {
- "description" : "Specifies a maximum limit of number of fires. So if you set it to 1, the scheduler will only fire once. If you set it to 5, it will only fire five times. A value of zero or negative means fire forever.",
- "default" : "0",
- "type" : "integer"
- },
- "run-logging-level" : {
- "description" : "The consumer logs a start/complete log line when it polls. This option allows you to configure the logging level for that.",
- "default" : "TRACE",
- "enum" : [ "TRACE", "DEBUG", "INFO", "WARN", "ERROR", "OFF" ],
- "type" : "string"
- },
- "scheduled-executor-service" : {
- "description" : "Allows for configuring a custom/shared thread pool to use for the consumer. By default each consumer has its own single threaded thread pool.",
- "type" : "string"
- },
- "scheduler" : {
- "description" : "To use a cron scheduler from either camel-spring or camel-quartz component. Use value spring or quartz for built in scheduler",
- "default" : "none",
- "type" : "string"
- },
- "scheduler-properties" : {
- "description" : "To configure additional properties when using a custom scheduler or any of the Quartz, Spring based scheduler.",
- "type" : "string"
- },
- "send-empty-message-when-idle" : {
- "description" : "If the polling consumer did not poll any files, you can enable this option to send an empty message (no body) instead.",
- "default" : "false",
- "type" : "boolean"
- },
- "start-scheduler" : {
- "description" : "Whether the scheduler should be auto started.",
- "default" : "true",
- "type" : "boolean"
- },
- "synchronous" : {
- "description" : "Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported).",
- "default" : "false",
- "type" : "boolean"
- },
- "time-unit" : {
- "description" : "Time unit for initialDelay and delay options.",
- "default" : "MILLISECONDS",
- "enum" : [ "NANOSECONDS", "MICROSECONDS", "MILLISECONDS", "SECONDS", "MINUTES", "HOURS", "DAYS" ],
- "type" : "string"
- },
- "use-fixed-delay" : {
- "description" : "Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in JDK for details.",
- "default" : "true",
- "type" : "boolean"
- }
- }
- },
"http" : {
"type" : "object",
"required" : [ "httpUri" ],
@@ -20002,6 +19824,10 @@
"description" : "Returns the custom listener in use, if provided",
"type" : "string"
},
+ "default-value" : {
+ "description" : "Set a specific default value for some producer operations",
+ "type" : "string"
+ },
"event-types" : {
"description" : "Specifies the set of event types to register by the consumer. Multiple event can be separated by comma. The possible event types are: CACHE_ENTRY_ACTIVATED, CACHE_ENTRY_PASSIVATED, CACHE_ENTRY_VISITED, CACHE_ENTRY_LOADED, CACHE_ENTRY_EVICTED, CACHE_ENTRY_CREATED, CACHE_ENTRY_REMOVED, CACHE_ENTRY_MODIFIED, TRANSACTION_COMPLETED, TRANSACTION_REGISTERED, CACHE_ENTRY_INVALIDATED, DATA_REHASHED, TOPOLOGY_CHANGED, PARTITION_STATUS_CHANGED",
"type" : "string"
@@ -20023,17 +19849,29 @@
"description" : "Specifies the host of the cache on Infinispan instance",
"type" : "string"
},
+ "key" : {
+ "description" : "Set a specific key for producer operations",
+ "type" : "string"
+ },
"lazy-start-producer" : {
"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 fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and startin [...]
"default" : "false",
"type" : "boolean"
},
+ "old-value" : {
+ "description" : "Set a specific old value for some producer operations",
+ "type" : "string"
+ },
"operation" : {
"description" : "The operation to perform.",
"default" : "PUT",
"enum" : [ "PUT", "PUTASYNC", "PUTALL", "PUTALLASYNC", "PUTIFABSENT", "PUTIFABSENTASYNC", "GET", "GETORDEFAULT", "CONTAINSKEY", "CONTAINSVALUE", "REMOVE", "REMOVEASYNC", "REPLACE", "REPLACEASYNC", "SIZE", "CLEAR", "CLEARASYNC", "QUERY", "STATS", "COMPUTE", "COMPUTEASYNC" ],
"type" : "string"
},
+ "password" : {
+ "description" : "Define the password to access the infinispan instance",
+ "type" : "string"
+ },
"query-builder" : {
"description" : "Specifies the query builder.",
"type" : "string"
@@ -20046,6 +19884,23 @@
"description" : "Store the operation result in a header instead of the message body. By default, resultHeader == null and the query result is stored in the message body, any existing content in the message body is discarded. If resultHeader is set, the value is used as the name of the header to store the query result and the original message body is preserved. This value can be overridden by an in message header named: CamelInfinispanOperationResultHeader",
"type" : "string"
},
+ "sasl-mechanism" : {
+ "description" : "Define the SASL Mechanism to access the infinispan instance",
+ "type" : "string"
+ },
+ "secure" : {
+ "description" : "Define if we are connecting to a secured Infinispan instance",
+ "default" : "false",
+ "type" : "boolean"
+ },
+ "security-realm" : {
+ "description" : "Define the security realm to access the infinispan instance",
+ "type" : "string"
+ },
+ "security-server-name" : {
+ "description" : "Define the security server name to access the infinispan instance",
+ "type" : "string"
+ },
"sync" : {
"description" : "If true, the consumer will receive notifications synchronously",
"default" : "true",
@@ -20055,6 +19910,14 @@
"description" : "Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported).",
"default" : "false",
"type" : "boolean"
+ },
+ "username" : {
+ "description" : "Define the username to access the infinispan instance",
+ "type" : "string"
+ },
+ "value" : {
+ "description" : "Set a specific value for producer operations",
+ "type" : "string"
}
}
},
@@ -21534,7 +21397,7 @@
"type" : "integer"
},
"delivery-mode" : {
- "description" : "Specifies the delivery mode to be used. Possibles values are those defined by javax.jms.DeliveryMode. NON_PERSISTENT = 1 and PERSISTENT = 2.",
+ "description" : "Specifies the delivery mode to be used. Possible values are those defined by javax.jms.DeliveryMode. NON_PERSISTENT = 1 and PERSISTENT = 2.",
"enum" : [ "1", "2" ],
"type" : "integer"
},
@@ -21730,7 +21593,7 @@
"type" : "string"
},
"reply-to" : {
- "description" : "Provides an explicit ReplyTo destination, which overrides any incoming value of Message.getJMSReplyTo().",
+ "description" : "Provides an explicit ReplyTo destination (overrides any incoming value of Message.getJMSReplyTo() in consumer).",
"type" : "string"
},
"reply-to-cache-level-name" : {
@@ -23172,7 +23035,6 @@
},
"ssl-enabled-protocols" : {
"description" : "The list of protocols enabled for SSL connections. TLSv1.2, TLSv1.1 and TLSv1 are enabled by default.",
- "default" : "TLSv1.2",
"type" : "string"
},
"ssl-endpoint-algorithm" : {
@@ -23204,7 +23066,6 @@
},
"ssl-protocol" : {
"description" : "The SSL protocol used to generate the SSLContext. Default setting is TLS, which is fine for most cases. Allowed values in recent JVMs are TLS, TLSv1.1 and TLSv1.2. SSL, SSLv2 and SSLv3 may be supported in older JVMs, but their usage is discouraged due to known security vulnerabilities.",
- "default" : "TLSv1.2",
"type" : "string"
},
"ssl-provider" : {
@@ -28161,6 +28022,10 @@
"description" : "The NSQ channel",
"type" : "string"
},
+ "custom-nsq-lookup" : {
+ "description" : "A Custom NSQ lookup implementation",
+ "type" : "string"
+ },
"exception-handler" : {
"description" : "To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored.",
"type" : "string"
@@ -29303,7 +29168,7 @@
"required" : [ "configFile" ],
"properties" : {
"config-file" : {
- "description" : "Specifies the location to the solver file",
+ "description" : "Specifies the location to the solver file. If useSolverManager=FALSE, Camel uses this file and create the Solver. If useSolverManager=TRUE and SolverManager is set in the header {OptaPlannerConstants.SOLVER_MANAGER} : this file is ignored by Camel usage of SolverManager. SolverManager can be injected by DI in Quarkus or Spring.",
"type" : "string"
},
"async" : {
@@ -29335,6 +29200,11 @@
"default" : "false",
"type" : "boolean"
},
+ "problem-id" : {
+ "description" : "In case of using SolverManager : the problem id",
+ "default" : "1L",
+ "type" : "integer"
+ },
"solver-id" : {
"description" : "Specifies the solverId to user for the solver instance key",
"default" : "DEFAULT_SOLVER",
@@ -29349,6 +29219,11 @@
"description" : "Specifies the thread pool size to use when async is true",
"default" : "10",
"type" : "integer"
+ },
+ "use-solver-manager" : {
+ "description" : "use SolverManager instead of XML file config. Use this mode on Quarkus app.",
+ "default" : "false",
+ "type" : "boolean"
}
}
},
@@ -29535,7 +29410,7 @@
},
"font-size" : {
"description" : "Font size in pixels",
- "default" : "14",
+ "default" : "14.0",
"type" : "number"
},
"lazy-start-producer" : {
@@ -30251,7 +30126,7 @@
"required" : [ "configurationName" ],
"properties" : {
"configuration-name" : {
- "description" : "The configFile is the name of the QuickFIX/J configuration to use for the FIX engine (located as a resource found in your classpath).",
+ "description" : "Path to the quickfix configuration file. You can prefix with: classpath, file, http, ref, or bean. classpath, file and http loads the configuration file using these protocols (classpath is default). ref will lookup the configuration file in the registry. bean will call a method on a bean to be used as the configuration. For bean you can specify the method name after dot, eg bean:myBean.myMethod",
"type" : "string"
},
"basic-property-binding" : {
@@ -30302,6 +30177,14 @@
"description" : "The exchange name determines the exchange to which the produced messages will be sent to. In the case of consumers, the exchange name determines the exchange the queue will be bound to.",
"type" : "string"
},
+ "additional-headers" : {
+ "description" : "Map of additional headers. These headers will be set only when the 'allowCustomHeaders' is set to true",
+ "type" : "string"
+ },
+ "additional-properties" : {
+ "description" : "Map of additional properties. These are standard RabbitMQ properties as defined in com.rabbitmq.client.AMQP.BasicProperties. The map keys should be from org.apache.camel.component.rabbitmq.RabbitMQConstants. Any other keys will be ignored.",
+ "type" : "string"
+ },
"addresses" : {
"description" : "If this option is set, camel-rabbitmq will try to create connection based on the setting of option addresses. The addresses value is a string which looks like server1:12345, server2:12345",
"type" : "string"
@@ -30518,6 +30401,11 @@
"description" : "The queue to receive messages from",
"type" : "string"
},
+ "re-queue" : {
+ "description" : "This is used by the consumer to control rejection of the message. When the consumer is complete processing the exchange, and if the exchange failed, then the consumer is going to reject the message from the RabbitMQ broker. If the header CamelRabbitmqRequeue is present then the value of the header will be used, otherwise this endpoint value is used as fallback. If the value is false (by default) then the message is discarded/dead-lettered. If the value is true, [...]
+ "default" : "false",
+ "type" : "boolean"
+ },
"request-timeout" : {
"description" : "Set timeout for waiting for a reply when using the InOut Exchange Pattern (in milliseconds)",
"default" : "20000",
@@ -35362,11 +35250,11 @@
"type" : "string"
},
"fault-action" : {
- "description" : "Signifies the value for the faultAction response WS-Addressing Fault Action header that is provided by the method.",
+ "description" : "Signifies the value for the faultAction response WS-Addressing Fault Action header that is provided by the method. See org.springframework.ws.soap.addressing.server.annotation.Action annotation for more details.",
"type" : "string"
},
"fault-to" : {
- "description" : "Signifies the value for the faultAction response WS-Addressing FaultTo header that is provided by the method.",
+ "description" : "Signifies the value for the faultAction response WS-Addressing FaultTo header that is provided by the method. See org.springframework.ws.soap.addressing.server.annotation.Action annotation for more details.",
"type" : "string"
},
"lazy-start-producer" : {
@@ -35383,7 +35271,7 @@
"type" : "string"
},
"message-id-strategy" : {
- "description" : "Option to provide a custom MessageIdStrategy to control generation of unique message ids.",
+ "description" : "Option to provide a custom MessageIdStrategy to control generation of WS-Addressing unique message ids.",
"type" : "string"
},
"message-sender" : {
@@ -35391,11 +35279,11 @@
"type" : "string"
},
"output-action" : {
- "description" : "Signifies the value for the response WS-Addressing Action header that is provided by the method.",
+ "description" : "Signifies the value for the response WS-Addressing Action header that is provided by the method. See org.springframework.ws.soap.addressing.server.annotation.Action annotation for more details.",
"type" : "string"
},
"reply-to" : {
- "description" : "Signifies the value for the replyTo response WS-Addressing ReplyTo header that is provided by the method.",
+ "description" : "Signifies the value for the replyTo response WS-Addressing ReplyTo header that is provided by the method. See org.springframework.ws.soap.addressing.server.annotation.Action annotation for more details.",
"type" : "string"
},
"soap-action" : {
@@ -39790,6 +39678,7 @@
"properties" : {
"method-name" : {
"description" : "What operation to use",
+ "enum" : [ "ADD_TAG_TO_ORGANISATIONS", "ADD_TAG_TO_TICKET", "ADD_TAG_TO_TOPICS", "ASSOCIATE_ATTACHMENTS_TO_ARTICLE", "CHANGE_USER_PASSWORD", "CREATE_ARTICLE", "CREATE_ARTICLE_1", "CREATE_ARTICLE_TRANSLATION", "CREATE_AUTOMATION", "CREATE_CATEGORY", "CREATE_CATEGORY_TRANSLATION", "CREATE_COMMENT", "CREATE_DYNAMIC_CONTENT_ITEM", "CREATE_DYNAMIC_CONTENT_ITEM_VARIANT", "CREATE_FORUM", "CREATE_GROUP", "CREATE_GROUP_MEMBERSHIP", "CREATE_GROUP_MEMBERSHIP_1", "CREATE_MACRO", "CREATE_OR [...]
"type" : "string"
},
"backoff-error-threshold" : {
diff --git a/camel-k-main/camel-k-runtime-health/src/generated/java/org/apache/camel/k/health/HealthContextCustomizerConfigurer.java b/camel-k-main/camel-k-runtime-health/src/generated/java/org/apache/camel/k/health/HealthContextCustomizerConfigurer.java
index a79e2b1..3f38b1b 100644
--- a/camel-k-main/camel-k-runtime-health/src/generated/java/org/apache/camel/k/health/HealthContextCustomizerConfigurer.java
+++ b/camel-k-main/camel-k-runtime-health/src/generated/java/org/apache/camel/k/health/HealthContextCustomizerConfigurer.java
@@ -15,6 +15,16 @@ import org.apache.camel.k.health.HealthContextCustomizer;
@SuppressWarnings("unchecked")
public class HealthContextCustomizerConfigurer extends org.apache.camel.support.component.PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
+ private static final Map<String, Object> ALL_OPTIONS;
+ static {
+ Map<String, Object> map = new CaseInsensitiveMap();
+ map.put("HealthGroupFilterExclude", java.lang.String.class);
+ map.put("IncludeContext", boolean.class);
+ map.put("IncludeRoutes", boolean.class);
+ map.put("Path", java.lang.String.class);
+ ALL_OPTIONS = map;
+ }
+
@Override
public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
org.apache.camel.k.health.HealthContextCustomizer target = (org.apache.camel.k.health.HealthContextCustomizer) obj;
@@ -33,12 +43,7 @@ public class HealthContextCustomizerConfigurer extends org.apache.camel.support.
@Override
public Map<String, Object> getAllOptions(Object target) {
- Map<String, Object> answer = new CaseInsensitiveMap();
- answer.put("HealthGroupFilterExclude", java.lang.String.class);
- answer.put("IncludeContext", boolean.class);
- answer.put("IncludeRoutes", boolean.class);
- answer.put("Path", java.lang.String.class);
- return answer;
+ return ALL_OPTIONS;
}
@Override
diff --git a/camel-k-main/camel-k-runtime-tracing/src/generated/java/org/apache/camel/k/tracing/TracingContextCustomizerConfigurer.java b/camel-k-main/camel-k-runtime-tracing/src/generated/java/org/apache/camel/k/tracing/TracingContextCustomizerConfigurer.java
index a0902ba..6879ede 100644
--- a/camel-k-main/camel-k-runtime-tracing/src/generated/java/org/apache/camel/k/tracing/TracingContextCustomizerConfigurer.java
+++ b/camel-k-main/camel-k-runtime-tracing/src/generated/java/org/apache/camel/k/tracing/TracingContextCustomizerConfigurer.java
@@ -15,6 +15,16 @@ import org.apache.camel.k.tracing.TracingContextCustomizer;
@SuppressWarnings("unchecked")
public class TracingContextCustomizerConfigurer extends org.apache.camel.support.component.PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
+ private static final Map<String, Object> ALL_OPTIONS;
+ static {
+ Map<String, Object> map = new CaseInsensitiveMap();
+ map.put("Reporter", io.jaegertracing.Configuration.ReporterConfiguration.class);
+ map.put("Sampler", io.jaegertracing.Configuration.SamplerConfiguration.class);
+ map.put("ServiceName", java.lang.String.class);
+ map.put("Tags", java.util.Map.class);
+ ALL_OPTIONS = map;
+ }
+
@Override
public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
org.apache.camel.k.tracing.TracingContextCustomizer target = (org.apache.camel.k.tracing.TracingContextCustomizer) obj;
@@ -33,12 +43,7 @@ public class TracingContextCustomizerConfigurer extends org.apache.camel.support
@Override
public Map<String, Object> getAllOptions(Object target) {
- Map<String, Object> answer = new CaseInsensitiveMap();
- answer.put("Reporter", io.jaegertracing.Configuration.ReporterConfiguration.class);
- answer.put("Sampler", io.jaegertracing.Configuration.SamplerConfiguration.class);
- answer.put("ServiceName", java.lang.String.class);
- answer.put("Tags", java.util.Map.class);
- return answer;
+ return ALL_OPTIONS;
}
@Override
diff --git a/camel-k-runtime-core/src/generated/java/org/apache/camel/k/SourceDefinitionConfigurer.java b/camel-k-runtime-core/src/generated/java/org/apache/camel/k/SourceDefinitionConfigurer.java
index e23c414..8f01900 100644
--- a/camel-k-runtime-core/src/generated/java/org/apache/camel/k/SourceDefinitionConfigurer.java
+++ b/camel-k-runtime-core/src/generated/java/org/apache/camel/k/SourceDefinitionConfigurer.java
@@ -15,6 +15,22 @@ import org.apache.camel.k.SourceDefinition;
@SuppressWarnings("unchecked")
public class SourceDefinitionConfigurer extends org.apache.camel.support.component.PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
+ private static final Map<String, Object> ALL_OPTIONS;
+ static {
+ Map<String, Object> map = new CaseInsensitiveMap();
+ map.put("Compressed", boolean.class);
+ map.put("Content", byte[].class);
+ map.put("Id", java.lang.String.class);
+ map.put("Interceptors", java.util.List.class);
+ map.put("Language", java.lang.String.class);
+ map.put("Loader", java.lang.String.class);
+ map.put("Location", java.lang.String.class);
+ map.put("Name", java.lang.String.class);
+ map.put("PropertyNames", java.util.List.class);
+ map.put("Type", org.apache.camel.k.SourceType.class);
+ ALL_OPTIONS = map;
+ }
+
@Override
public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
org.apache.camel.k.SourceDefinition target = (org.apache.camel.k.SourceDefinition) obj;
@@ -45,18 +61,7 @@ public class SourceDefinitionConfigurer extends org.apache.camel.support.compone
@Override
public Map<String, Object> getAllOptions(Object target) {
- Map<String, Object> answer = new CaseInsensitiveMap();
- answer.put("Compressed", boolean.class);
- answer.put("Content", byte[].class);
- answer.put("Id", java.lang.String.class);
- answer.put("Interceptors", java.util.List.class);
- answer.put("Language", java.lang.String.class);
- answer.put("Loader", java.lang.String.class);
- answer.put("Location", java.lang.String.class);
- answer.put("Name", java.lang.String.class);
- answer.put("PropertyNames", java.util.List.class);
- answer.put("Type", org.apache.camel.k.SourceType.class);
- return answer;
+ return ALL_OPTIONS;
}
@Override
diff --git a/camel-k-runtime-core/src/generated/java/org/apache/camel/k/listener/SourcesConfigurerConfigurer.java b/camel-k-runtime-core/src/generated/java/org/apache/camel/k/listener/SourcesConfigurerConfigurer.java
index a9faffa..9944e06 100644
--- a/camel-k-runtime-core/src/generated/java/org/apache/camel/k/listener/SourcesConfigurerConfigurer.java
+++ b/camel-k-runtime-core/src/generated/java/org/apache/camel/k/listener/SourcesConfigurerConfigurer.java
@@ -15,6 +15,13 @@ import org.apache.camel.k.listener.SourcesConfigurer;
@SuppressWarnings("unchecked")
public class SourcesConfigurerConfigurer extends org.apache.camel.support.component.PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
+ private static final Map<String, Object> ALL_OPTIONS;
+ static {
+ Map<String, Object> map = new CaseInsensitiveMap();
+ map.put("Sources", org.apache.camel.k.SourceDefinition[].class);
+ ALL_OPTIONS = map;
+ }
+
@Override
public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
org.apache.camel.k.listener.SourcesConfigurer target = (org.apache.camel.k.listener.SourcesConfigurer) obj;
@@ -27,9 +34,7 @@ public class SourcesConfigurerConfigurer extends org.apache.camel.support.compon
@Override
public Map<String, Object> getAllOptions(Object target) {
- Map<String, Object> answer = new CaseInsensitiveMap();
- answer.put("Sources", org.apache.camel.k.SourceDefinition[].class);
- return answer;
+ return ALL_OPTIONS;
}
@Override
diff --git a/camel-k-runtime-cron/src/generated/java/org/apache/camel/k/cron/CronSourceLoaderInterceptorConfigurer.java b/camel-k-runtime-cron/src/generated/java/org/apache/camel/k/cron/CronSourceLoaderInterceptorConfigurer.java
index bbb5edb..832d7db 100644
--- a/camel-k-runtime-cron/src/generated/java/org/apache/camel/k/cron/CronSourceLoaderInterceptorConfigurer.java
+++ b/camel-k-runtime-cron/src/generated/java/org/apache/camel/k/cron/CronSourceLoaderInterceptorConfigurer.java
@@ -15,6 +15,15 @@ import org.apache.camel.k.cron.CronSourceLoaderInterceptor;
@SuppressWarnings("unchecked")
public class CronSourceLoaderInterceptorConfigurer extends org.apache.camel.support.component.PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
+ private static final Map<String, Object> ALL_OPTIONS;
+ static {
+ Map<String, Object> map = new CaseInsensitiveMap();
+ map.put("OverridableComponents", java.lang.String.class);
+ map.put("Runtime", org.apache.camel.k.Runtime.class);
+ map.put("TimerUri", java.lang.String.class);
+ ALL_OPTIONS = map;
+ }
+
@Override
public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
org.apache.camel.k.cron.CronSourceLoaderInterceptor target = (org.apache.camel.k.cron.CronSourceLoaderInterceptor) obj;
@@ -31,11 +40,7 @@ public class CronSourceLoaderInterceptorConfigurer extends org.apache.camel.supp
@Override
public Map<String, Object> getAllOptions(Object target) {
- Map<String, Object> answer = new CaseInsensitiveMap();
- answer.put("OverridableComponents", java.lang.String.class);
- answer.put("Runtime", org.apache.camel.k.Runtime.class);
- answer.put("TimerUri", java.lang.String.class);
- return answer;
+ return ALL_OPTIONS;
}
@Override
diff --git a/camel-k-runtime-http/src/generated/java/org/apache/camel/k/http/PlatformHttpServiceContextCustomizerConfigurer.java b/camel-k-runtime-http/src/generated/java/org/apache/camel/k/http/PlatformHttpServiceContextCustomizerConfigurer.java
index 233b5e5..e90e61f 100644
--- a/camel-k-runtime-http/src/generated/java/org/apache/camel/k/http/PlatformHttpServiceContextCustomizerConfigurer.java
+++ b/camel-k-runtime-http/src/generated/java/org/apache/camel/k/http/PlatformHttpServiceContextCustomizerConfigurer.java
@@ -15,6 +15,20 @@ import org.apache.camel.k.http.PlatformHttpServiceContextCustomizer;
@SuppressWarnings("unchecked")
public class PlatformHttpServiceContextCustomizerConfigurer extends org.apache.camel.support.component.PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
+ private static final Map<String, Object> ALL_OPTIONS;
+ static {
+ Map<String, Object> map = new CaseInsensitiveMap();
+ map.put("BindHost", java.lang.String.class);
+ map.put("BindPort", int.class);
+ map.put("BodyHandler", org.apache.camel.component.platform.http.vertx.VertxPlatformHttpServerConfiguration.BodyHandler.class);
+ map.put("Cors", org.apache.camel.component.platform.http.vertx.VertxPlatformHttpServerConfiguration.Cors.class);
+ map.put("MaxBodySize", java.math.BigInteger.class);
+ map.put("Path", java.lang.String.class);
+ map.put("SslContextParameters", org.apache.camel.support.jsse.SSLContextParameters.class);
+ map.put("UseGlobalSslContextParameters", boolean.class);
+ ALL_OPTIONS = map;
+ }
+
@Override
public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
org.apache.camel.k.http.PlatformHttpServiceContextCustomizer target = (org.apache.camel.k.http.PlatformHttpServiceContextCustomizer) obj;
@@ -41,16 +55,7 @@ public class PlatformHttpServiceContextCustomizerConfigurer extends org.apache.c
@Override
public Map<String, Object> getAllOptions(Object target) {
- Map<String, Object> answer = new CaseInsensitiveMap();
- answer.put("BindHost", java.lang.String.class);
- answer.put("BindPort", int.class);
- answer.put("BodyHandler", org.apache.camel.component.platform.http.vertx.VertxPlatformHttpServerConfiguration.BodyHandler.class);
- answer.put("Cors", org.apache.camel.component.platform.http.vertx.VertxPlatformHttpServerConfiguration.Cors.class);
- answer.put("MaxBodySize", java.math.BigInteger.class);
- answer.put("Path", java.lang.String.class);
- answer.put("SslContextParameters", org.apache.camel.support.jsse.SSLContextParameters.class);
- answer.put("UseGlobalSslContextParameters", boolean.class);
- return answer;
+ return ALL_OPTIONS;
}
@Override
diff --git a/camel-k-runtime-knative/src/generated/java/org/apache/camel/k/knative/customizer/KnativeSinkBindingContextCustomizerConfigurer.java b/camel-k-runtime-knative/src/generated/java/org/apache/camel/k/knative/customizer/KnativeSinkBindingContextCustomizerConfigurer.java
index 2499950..c193c00 100644
--- a/camel-k-runtime-knative/src/generated/java/org/apache/camel/k/knative/customizer/KnativeSinkBindingContextCustomizerConfigurer.java
+++ b/camel-k-runtime-knative/src/generated/java/org/apache/camel/k/knative/customizer/KnativeSinkBindingContextCustomizerConfigurer.java
@@ -15,6 +15,16 @@ import org.apache.camel.k.knative.customizer.KnativeSinkBindingContextCustomizer
@SuppressWarnings("unchecked")
public class KnativeSinkBindingContextCustomizerConfigurer extends org.apache.camel.support.component.PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
+ private static final Map<String, Object> ALL_OPTIONS;
+ static {
+ Map<String, Object> map = new CaseInsensitiveMap();
+ map.put("ApiVersion", java.lang.String.class);
+ map.put("Kind", java.lang.String.class);
+ map.put("Name", java.lang.String.class);
+ map.put("Type", org.apache.camel.component.knative.spi.Knative.Type.class);
+ ALL_OPTIONS = map;
+ }
+
@Override
public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
org.apache.camel.k.knative.customizer.KnativeSinkBindingContextCustomizer target = (org.apache.camel.k.knative.customizer.KnativeSinkBindingContextCustomizer) obj;
@@ -33,12 +43,7 @@ public class KnativeSinkBindingContextCustomizerConfigurer extends org.apache.ca
@Override
public Map<String, Object> getAllOptions(Object target) {
- Map<String, Object> answer = new CaseInsensitiveMap();
- answer.put("ApiVersion", java.lang.String.class);
- answer.put("Kind", java.lang.String.class);
- answer.put("Name", java.lang.String.class);
- answer.put("Type", org.apache.camel.component.knative.spi.Knative.Type.class);
- return answer;
+ return ALL_OPTIONS;
}
@Override
diff --git a/camel-k-runtime-webhook/src/generated/java/org/apache/camel/k/webhook/WebhookContextCustomizerConfigurer.java b/camel-k-runtime-webhook/src/generated/java/org/apache/camel/k/webhook/WebhookContextCustomizerConfigurer.java
index a93e359..5d8e0d1 100644
--- a/camel-k-runtime-webhook/src/generated/java/org/apache/camel/k/webhook/WebhookContextCustomizerConfigurer.java
+++ b/camel-k-runtime-webhook/src/generated/java/org/apache/camel/k/webhook/WebhookContextCustomizerConfigurer.java
@@ -15,6 +15,13 @@ import org.apache.camel.k.webhook.WebhookContextCustomizer;
@SuppressWarnings("unchecked")
public class WebhookContextCustomizerConfigurer extends org.apache.camel.support.component.PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
+ private static final Map<String, Object> ALL_OPTIONS;
+ static {
+ Map<String, Object> map = new CaseInsensitiveMap();
+ map.put("Action", org.apache.camel.k.webhook.WebhookAction.class);
+ ALL_OPTIONS = map;
+ }
+
@Override
public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
org.apache.camel.k.webhook.WebhookContextCustomizer target = (org.apache.camel.k.webhook.WebhookContextCustomizer) obj;
@@ -27,9 +34,7 @@ public class WebhookContextCustomizerConfigurer extends org.apache.camel.support
@Override
public Map<String, Object> getAllOptions(Object target) {
- Map<String, Object> answer = new CaseInsensitiveMap();
- answer.put("Action", org.apache.camel.k.webhook.WebhookAction.class);
- return answer;
+ return ALL_OPTIONS;
}
@Override
diff --git a/components/camel-kamelet/src/generated/java/org/apache/camel/component/kamelet/KameletComponentConfigurer.java b/components/camel-kamelet/src/generated/java/org/apache/camel/component/kamelet/KameletComponentConfigurer.java
index 7c3717a..32acfce 100644
--- a/components/camel-kamelet/src/generated/java/org/apache/camel/component/kamelet/KameletComponentConfigurer.java
+++ b/components/camel-kamelet/src/generated/java/org/apache/camel/component/kamelet/KameletComponentConfigurer.java
@@ -15,6 +15,17 @@ import org.apache.camel.support.component.PropertyConfigurerSupport;
@SuppressWarnings("unchecked")
public class KameletComponentConfigurer extends PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
+ private static final Map<String, Object> ALL_OPTIONS;
+ static {
+ Map<String, Object> map = new CaseInsensitiveMap();
+ map.put("bridgeErrorHandler", boolean.class);
+ map.put("block", boolean.class);
+ map.put("lazyStartProducer", boolean.class);
+ map.put("timeout", long.class);
+ map.put("basicPropertyBinding", boolean.class);
+ ALL_OPTIONS = map;
+ }
+
@Override
public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
KameletComponent target = (KameletComponent) obj;
@@ -33,13 +44,7 @@ public class KameletComponentConfigurer extends PropertyConfigurerSupport implem
@Override
public Map<String, Object> getAllOptions(Object target) {
- Map<String, Object> answer = new CaseInsensitiveMap();
- answer.put("basicPropertyBinding", boolean.class);
- answer.put("block", boolean.class);
- answer.put("bridgeErrorHandler", boolean.class);
- answer.put("lazyStartProducer", boolean.class);
- answer.put("timeout", long.class);
- return answer;
+ return ALL_OPTIONS;
}
@Override
diff --git a/components/camel-kamelet/src/generated/java/org/apache/camel/component/kamelet/KameletEndpointConfigurer.java b/components/camel-kamelet/src/generated/java/org/apache/camel/component/kamelet/KameletEndpointConfigurer.java
index 6869355..dc0964d 100644
--- a/components/camel-kamelet/src/generated/java/org/apache/camel/component/kamelet/KameletEndpointConfigurer.java
+++ b/components/camel-kamelet/src/generated/java/org/apache/camel/component/kamelet/KameletEndpointConfigurer.java
@@ -15,6 +15,23 @@ import org.apache.camel.support.component.PropertyConfigurerSupport;
@SuppressWarnings("unchecked")
public class KameletEndpointConfigurer extends PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
+ private static final Map<String, Object> ALL_OPTIONS;
+ static {
+ Map<String, Object> map = new CaseInsensitiveMap();
+ map.put("templateId", java.lang.String.class);
+ map.put("routeId", java.lang.String.class);
+ map.put("bridgeErrorHandler", boolean.class);
+ map.put("exceptionHandler", org.apache.camel.spi.ExceptionHandler.class);
+ map.put("exchangePattern", org.apache.camel.ExchangePattern.class);
+ map.put("block", boolean.class);
+ map.put("kameletProperties", java.util.Map.class);
+ map.put("lazyStartProducer", boolean.class);
+ map.put("timeout", long.class);
+ map.put("basicPropertyBinding", boolean.class);
+ map.put("synchronous", boolean.class);
+ ALL_OPTIONS = map;
+ }
+
@Override
public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
KameletEndpoint target = (KameletEndpoint) obj;
@@ -40,17 +57,7 @@ public class KameletEndpointConfigurer extends PropertyConfigurerSupport impleme
@Override
public Map<String, Object> getAllOptions(Object target) {
- Map<String, Object> answer = new CaseInsensitiveMap();
- answer.put("basicPropertyBinding", boolean.class);
- answer.put("block", boolean.class);
- answer.put("bridgeErrorHandler", boolean.class);
- answer.put("exceptionHandler", org.apache.camel.spi.ExceptionHandler.class);
- answer.put("exchangePattern", org.apache.camel.ExchangePattern.class);
- answer.put("kameletProperties", java.util.Map.class);
- answer.put("lazyStartProducer", boolean.class);
- answer.put("synchronous", boolean.class);
- answer.put("timeout", long.class);
- return answer;
+ return ALL_OPTIONS;
}
@Override
diff --git a/components/camel-kamelet/src/generated/resources/org/apache/camel/component/kamelet/kamelet.json b/components/camel-kamelet/src/generated/resources/org/apache/camel/component/kamelet/kamelet.json
index 62499cc..eff6911 100644
--- a/components/camel-kamelet/src/generated/resources/org/apache/camel/component/kamelet/kamelet.json
+++ b/components/camel-kamelet/src/generated/resources/org/apache/camel/component/kamelet/kamelet.json
@@ -16,16 +16,17 @@
"extendsScheme": "",
"syntax": "kamelet:templateId\/routeId",
"async": false,
+ "api": false,
"consumerOnly": false,
"producerOnly": false,
"lenientProperties": true
},
"componentProperties": {
"bridgeErrorHandler": { "kind": "property", "displayName": "Bridge Error Handler", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by [...]
- "block": { "kind": "property", "displayName": "Block", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "true", "description": "If sending a message to a kamelet endpoint which has no active consumer, then we can tell the producer to block and wait for the consumer to become active." },
+ "block": { "kind": "property", "displayName": "Block", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": true, "description": "If sending a message to a kamelet endpoint which has no active consumer, then we can tell the producer to block and wait for the consumer to become active." },
"lazyStartProducer": { "kind": "property", "displayName": "Lazy Start Producer", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": 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 fail during starting and cause the r [...]
- "timeout": { "kind": "property", "displayName": "Timeout", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "secret": false, "defaultValue": "30000", "description": "The timeout value to use if block is enabled." },
- "basicPropertyBinding": { "kind": "property", "displayName": "Basic Property Binding", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Whether the component should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities" }
+ "timeout": { "kind": "property", "displayName": "Timeout", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "secret": false, "defaultValue": 30000, "description": "The timeout value to use if block is enabled." },
+ "basicPropertyBinding": { "kind": "property", "displayName": "Basic Property Binding", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": true, "secret": false, "defaultValue": false, "description": "Whether the component should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities" }
},
"properties": {
"templateId": { "kind": "path", "displayName": "Template Id", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "secret": false, "description": "The Route Template ID" },
@@ -33,11 +34,11 @@
"bridgeErrorHandler": { "kind": "parameter", "displayName": "Bridge Error Handler", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled b [...]
"exceptionHandler": { "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, "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 default the consumer will deal with [...]
"exchangePattern": { "kind": "parameter", "displayName": "Exchange Pattern", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut", "InOptionalOut" ], "deprecated": false, "secret": false, "description": "Sets the exchange pattern when the consumer creates an exchange." },
- "block": { "kind": "parameter", "displayName": "Block", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "true", "description": "If sending a message to a direct endpoint which has no active consumer, then we can tell the producer to block and wait for the consumer to become active." },
+ "block": { "kind": "parameter", "displayName": "Block", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": true, "description": "If sending a message to a direct endpoint which has no active consumer, then we can tell the producer to block and wait for the consumer to become active." },
"kameletProperties": { "kind": "parameter", "displayName": "Kamelet Properties", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "java.util.Map<java.lang.String, java.lang.Object>", "deprecated": false, "secret": false, "defaultValue": "true", "description": "Custom properties for kamelet" },
"lazyStartProducer": { "kind": "parameter", "displayName": "Lazy Start Producer", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": 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 fail during starting and cause the [...]
- "timeout": { "kind": "parameter", "displayName": "Timeout", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "secret": false, "defaultValue": "30000", "description": "The timeout value to use if block is enabled." },
+ "timeout": { "kind": "parameter", "displayName": "Timeout", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "secret": false, "defaultValue": 30000, "description": "The timeout value to use if block is enabled." },
"basicPropertyBinding": { "kind": "parameter", "displayName": "Basic Property Binding", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities" },
- "synchronous": { "kind": "parameter", "displayName": "Synchronous", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "false", "description": "Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported)." }
+ "synchronous": { "kind": "parameter", "displayName": "Synchronous", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported)." }
}
}
diff --git a/components/camel-knative/camel-knative/src/generated/java/org/apache/camel/component/knative/KnativeComponentConfigurer.java b/components/camel-knative/camel-knative/src/generated/java/org/apache/camel/component/knative/KnativeComponentConfigurer.java
index a3d240a..cd042ce 100644
--- a/components/camel-knative/camel-knative/src/generated/java/org/apache/camel/component/knative/KnativeComponentConfigurer.java
+++ b/components/camel-knative/camel-knative/src/generated/java/org/apache/camel/component/knative/KnativeComponentConfigurer.java
@@ -15,6 +15,29 @@ import org.apache.camel.support.component.PropertyConfigurerSupport;
@SuppressWarnings("unchecked")
public class KnativeComponentConfigurer extends PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
+ private static final Map<String, Object> ALL_OPTIONS;
+ static {
+ Map<String, Object> map = new CaseInsensitiveMap();
+ map.put("ceOverride", java.util.Map.class);
+ map.put("cloudEventsSpecVersion", java.lang.String.class);
+ map.put("cloudEventsType", java.lang.String.class);
+ map.put("configuration", org.apache.camel.component.knative.KnativeConfiguration.class);
+ map.put("environment", org.apache.camel.component.knative.spi.KnativeEnvironment.class);
+ map.put("environmentPath", java.lang.String.class);
+ map.put("filters", java.util.Map.class);
+ map.put("serviceName", java.lang.String.class);
+ map.put("transport", org.apache.camel.component.knative.spi.KnativeTransport.class);
+ map.put("transportOptions", java.util.Map.class);
+ map.put("bridgeErrorHandler", boolean.class);
+ map.put("replyWithCloudEvent", boolean.class);
+ map.put("reply", java.lang.Boolean.class);
+ map.put("lazyStartProducer", boolean.class);
+ map.put("apiVersion", java.lang.String.class);
+ map.put("basicPropertyBinding", boolean.class);
+ map.put("kind", java.lang.String.class);
+ ALL_OPTIONS = map;
+ }
+
private org.apache.camel.component.knative.KnativeConfiguration getOrCreateConfiguration(KnativeComponent target) {
if (target.getConfiguration() == null) {
target.setConfiguration(new org.apache.camel.component.knative.KnativeConfiguration());
@@ -60,25 +83,7 @@ public class KnativeComponentConfigurer extends PropertyConfigurerSupport implem
@Override
public Map<String, Object> getAllOptions(Object target) {
- Map<String, Object> answer = new CaseInsensitiveMap();
- answer.put("apiVersion", java.lang.String.class);
- answer.put("basicPropertyBinding", boolean.class);
- answer.put("bridgeErrorHandler", boolean.class);
- answer.put("ceOverride", java.util.Map.class);
- answer.put("cloudEventsSpecVersion", java.lang.String.class);
- answer.put("cloudEventsType", java.lang.String.class);
- answer.put("configuration", org.apache.camel.component.knative.KnativeConfiguration.class);
- answer.put("environment", org.apache.camel.component.knative.spi.KnativeEnvironment.class);
- answer.put("environmentPath", java.lang.String.class);
- answer.put("filters", java.util.Map.class);
- answer.put("kind", java.lang.String.class);
- answer.put("lazyStartProducer", boolean.class);
- answer.put("reply", java.lang.Boolean.class);
- answer.put("replyWithCloudEvent", boolean.class);
- answer.put("serviceName", java.lang.String.class);
- answer.put("transport", org.apache.camel.component.knative.spi.KnativeTransport.class);
- answer.put("transportOptions", java.util.Map.class);
- return answer;
+ return ALL_OPTIONS;
}
@Override
diff --git a/components/camel-knative/camel-knative/src/generated/java/org/apache/camel/component/knative/KnativeEndpointConfigurer.java b/components/camel-knative/camel-knative/src/generated/java/org/apache/camel/component/knative/KnativeEndpointConfigurer.java
index d99b510..0e2d5be 100644
--- a/components/camel-knative/camel-knative/src/generated/java/org/apache/camel/component/knative/KnativeEndpointConfigurer.java
+++ b/components/camel-knative/camel-knative/src/generated/java/org/apache/camel/component/knative/KnativeEndpointConfigurer.java
@@ -15,6 +15,31 @@ import org.apache.camel.support.component.PropertyConfigurerSupport;
@SuppressWarnings("unchecked")
public class KnativeEndpointConfigurer extends PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
+ private static final Map<String, Object> ALL_OPTIONS;
+ static {
+ Map<String, Object> map = new CaseInsensitiveMap();
+ map.put("type", org.apache.camel.component.knative.spi.Knative.Type.class);
+ map.put("name", java.lang.String.class);
+ map.put("ceOverride", java.util.Map.class);
+ map.put("cloudEventsSpecVersion", java.lang.String.class);
+ map.put("cloudEventsType", java.lang.String.class);
+ map.put("environment", org.apache.camel.component.knative.spi.KnativeEnvironment.class);
+ map.put("filters", java.util.Map.class);
+ map.put("serviceName", java.lang.String.class);
+ map.put("transportOptions", java.util.Map.class);
+ map.put("bridgeErrorHandler", boolean.class);
+ map.put("replyWithCloudEvent", boolean.class);
+ map.put("exceptionHandler", org.apache.camel.spi.ExceptionHandler.class);
+ map.put("exchangePattern", org.apache.camel.ExchangePattern.class);
+ map.put("reply", java.lang.Boolean.class);
+ map.put("lazyStartProducer", boolean.class);
+ map.put("apiVersion", java.lang.String.class);
+ map.put("basicPropertyBinding", boolean.class);
+ map.put("kind", java.lang.String.class);
+ map.put("synchronous", boolean.class);
+ ALL_OPTIONS = map;
+ }
+
@Override
public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
KnativeEndpoint target = (KnativeEndpoint) obj;
@@ -54,25 +79,7 @@ public class KnativeEndpointConfigurer extends PropertyConfigurerSupport impleme
@Override
public Map<String, Object> getAllOptions(Object target) {
- Map<String, Object> answer = new CaseInsensitiveMap();
- answer.put("apiVersion", java.lang.String.class);
- answer.put("basicPropertyBinding", boolean.class);
- answer.put("bridgeErrorHandler", boolean.class);
- answer.put("ceOverride", java.util.Map.class);
- answer.put("cloudEventsSpecVersion", java.lang.String.class);
- answer.put("cloudEventsType", java.lang.String.class);
- answer.put("environment", org.apache.camel.component.knative.spi.KnativeEnvironment.class);
- answer.put("exceptionHandler", org.apache.camel.spi.ExceptionHandler.class);
- answer.put("exchangePattern", org.apache.camel.ExchangePattern.class);
- answer.put("filters", java.util.Map.class);
- answer.put("kind", java.lang.String.class);
- answer.put("lazyStartProducer", boolean.class);
- answer.put("reply", java.lang.Boolean.class);
- answer.put("replyWithCloudEvent", boolean.class);
- answer.put("serviceName", java.lang.String.class);
- answer.put("synchronous", boolean.class);
- answer.put("transportOptions", java.util.Map.class);
- return answer;
+ return ALL_OPTIONS;
}
@Override
diff --git a/components/camel-knative/camel-knative/src/generated/resources/org/apache/camel/component/knative/knative.json b/components/camel-knative/camel-knative/src/generated/resources/org/apache/camel/component/knative/knative.json
index c7aeef6..c859f0b 100644
--- a/components/camel-knative/camel-knative/src/generated/resources/org/apache/camel/component/knative/knative.json
+++ b/components/camel-knative/camel-knative/src/generated/resources/org/apache/camel/component/knative/knative.json
@@ -16,6 +16,7 @@
"extendsScheme": "",
"syntax": "knative:type\/name",
"async": false,
+ "api": false,
"consumerOnly": false,
"producerOnly": false,
"lenientProperties": false
@@ -32,11 +33,11 @@
"transport": { "kind": "property", "displayName": "Transport", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.knative.spi.KnativeTransport", "deprecated": false, "secret": false, "description": "The transport implementation." },
"transportOptions": { "kind": "property", "displayName": "Transport Options", "group": "common", "label": "", "required": false, "type": "object", "javaType": "java.util.Map<java.lang.String, java.lang.Object>", "prefix": "transport.", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.knative.KnativeConfiguration", "configurationField": "configuration", "description": "Set the transport options." },
"bridgeErrorHandler": { "kind": "property", "displayName": "Bridge Error Handler", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by [...]
- "replyWithCloudEvent": { "kind": "property", "displayName": "Reply With Cloud Event", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "false", "configurationClass": "org.apache.camel.component.knative.KnativeConfiguration", "configurationField": "configuration", "description": "Transforms the reply into a cloud event that will be processed by the caller. When listening to even [...]
+ "replyWithCloudEvent": { "kind": "property", "displayName": "Reply With Cloud Event", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.knative.KnativeConfiguration", "configurationField": "configuration", "description": "Transforms the reply into a cloud event that will be processed by the caller. When listening to events [...]
"reply": { "kind": "property", "displayName": "Reply", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "secret": false, "defaultValue": "true", "configurationClass": "org.apache.camel.component.knative.KnativeConfiguration", "configurationField": "configuration", "description": "If the consumer should construct a full reply to knative request." },
"lazyStartProducer": { "kind": "property", "displayName": "Lazy Start Producer", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": 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 fail during starting and cause the r [...]
"apiVersion": { "kind": "property", "displayName": "Api Version", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.knative.KnativeConfiguration", "configurationField": "configuration", "description": "The version of the k8s resource referenced by the endpoint." },
- "basicPropertyBinding": { "kind": "property", "displayName": "Basic Property Binding", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Whether the component should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities" },
+ "basicPropertyBinding": { "kind": "property", "displayName": "Basic Property Binding", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": true, "secret": false, "defaultValue": false, "description": "Whether the component should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities" },
"kind": { "kind": "property", "displayName": "Kind", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.knative.KnativeConfiguration", "configurationField": "configuration", "description": "The type of the k8s resource referenced by the endpoint." }
},
"properties": {
@@ -50,7 +51,7 @@
"serviceName": { "kind": "parameter", "displayName": "Service Name", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.knative.KnativeConfiguration", "configurationField": "configuration", "description": "The name of the service to lookup from the KnativeEnvironment." },
"transportOptions": { "kind": "parameter", "displayName": "Transport Options", "group": "common", "label": "", "required": false, "type": "object", "javaType": "java.util.Map<java.lang.String, java.lang.Object>", "prefix": "transport.", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.knative.KnativeConfiguration", "configurationField": "configuration", "description": "Set the transport options." },
"bridgeErrorHandler": { "kind": "parameter", "displayName": "Bridge Error Handler", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled b [...]
- "replyWithCloudEvent": { "kind": "parameter", "displayName": "Reply With Cloud Event", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "false", "configurationClass": "org.apache.camel.component.knative.KnativeConfiguration", "configurationField": "configuration", "description": "Transforms the reply into a cloud event that will be processed by the caller. When listening to eve [...]
+ "replyWithCloudEvent": { "kind": "parameter", "displayName": "Reply With Cloud Event", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.knative.KnativeConfiguration", "configurationField": "configuration", "description": "Transforms the reply into a cloud event that will be processed by the caller. When listening to event [...]
"exceptionHandler": { "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, "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 default the consumer will deal with [...]
"exchangePattern": { "kind": "parameter", "displayName": "Exchange Pattern", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut", "InOptionalOut" ], "deprecated": false, "secret": false, "description": "Sets the exchange pattern when the consumer creates an exchange." },
"reply": { "kind": "parameter", "displayName": "Reply", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "secret": false, "defaultValue": "true", "configurationClass": "org.apache.camel.component.knative.KnativeConfiguration", "configurationField": "configuration", "description": "If the consumer should construct a full reply to knative request." },
@@ -58,6 +59,6 @@
"apiVersion": { "kind": "parameter", "displayName": "Api Version", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.knative.KnativeConfiguration", "configurationField": "configuration", "description": "The version of the k8s resource referenced by the endpoint." },
"basicPropertyBinding": { "kind": "parameter", "displayName": "Basic Property Binding", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities" },
"kind": { "kind": "parameter", "displayName": "Kind", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.knative.KnativeConfiguration", "configurationField": "configuration", "description": "The type of the k8s resource referenced by the endpoint." },
- "synchronous": { "kind": "parameter", "displayName": "Synchronous", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "false", "description": "Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported)." }
+ "synchronous": { "kind": "parameter", "displayName": "Synchronous", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported)." }
}
}
diff --git a/components/camel-wrap/src/generated/java/org/apache/camel/component/wrap/WrapComponentConfigurer.java b/components/camel-wrap/src/generated/java/org/apache/camel/component/wrap/WrapComponentConfigurer.java
index 39d4f46..2b3d402 100644
--- a/components/camel-wrap/src/generated/java/org/apache/camel/component/wrap/WrapComponentConfigurer.java
+++ b/components/camel-wrap/src/generated/java/org/apache/camel/component/wrap/WrapComponentConfigurer.java
@@ -15,6 +15,15 @@ import org.apache.camel.support.component.PropertyConfigurerSupport;
@SuppressWarnings("unchecked")
public class WrapComponentConfigurer extends PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
+ private static final Map<String, Object> ALL_OPTIONS;
+ static {
+ Map<String, Object> map = new CaseInsensitiveMap();
+ map.put("bridgeErrorHandler", boolean.class);
+ map.put("lazyStartProducer", boolean.class);
+ map.put("basicPropertyBinding", boolean.class);
+ ALL_OPTIONS = map;
+ }
+
@Override
public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
WrapComponent target = (WrapComponent) obj;
@@ -31,11 +40,7 @@ public class WrapComponentConfigurer extends PropertyConfigurerSupport implement
@Override
public Map<String, Object> getAllOptions(Object target) {
- Map<String, Object> answer = new CaseInsensitiveMap();
- answer.put("basicPropertyBinding", boolean.class);
- answer.put("bridgeErrorHandler", boolean.class);
- answer.put("lazyStartProducer", boolean.class);
- return answer;
+ return ALL_OPTIONS;
}
@Override
diff --git a/components/camel-wrap/src/generated/java/org/apache/camel/component/wrap/WrapEndpointConfigurer.java b/components/camel-wrap/src/generated/java/org/apache/camel/component/wrap/WrapEndpointConfigurer.java
index 97940e9..63b0e48 100644
--- a/components/camel-wrap/src/generated/java/org/apache/camel/component/wrap/WrapEndpointConfigurer.java
+++ b/components/camel-wrap/src/generated/java/org/apache/camel/component/wrap/WrapEndpointConfigurer.java
@@ -15,6 +15,19 @@ import org.apache.camel.support.component.PropertyConfigurerSupport;
@SuppressWarnings("unchecked")
public class WrapEndpointConfigurer extends PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
+ private static final Map<String, Object> ALL_OPTIONS;
+ static {
+ Map<String, Object> map = new CaseInsensitiveMap();
+ map.put("delegateUri", java.lang.String.class);
+ map.put("bridgeErrorHandler", boolean.class);
+ map.put("exceptionHandler", org.apache.camel.spi.ExceptionHandler.class);
+ map.put("exchangePattern", org.apache.camel.ExchangePattern.class);
+ map.put("lazyStartProducer", boolean.class);
+ map.put("basicPropertyBinding", boolean.class);
+ map.put("synchronous", boolean.class);
+ ALL_OPTIONS = map;
+ }
+
@Override
public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
WrapEndpoint target = (WrapEndpoint) obj;
@@ -36,14 +49,7 @@ public class WrapEndpointConfigurer extends PropertyConfigurerSupport implements
@Override
public Map<String, Object> getAllOptions(Object target) {
- Map<String, Object> answer = new CaseInsensitiveMap();
- answer.put("basicPropertyBinding", boolean.class);
- answer.put("bridgeErrorHandler", boolean.class);
- answer.put("exceptionHandler", org.apache.camel.spi.ExceptionHandler.class);
- answer.put("exchangePattern", org.apache.camel.ExchangePattern.class);
- answer.put("lazyStartProducer", boolean.class);
- answer.put("synchronous", boolean.class);
- return answer;
+ return ALL_OPTIONS;
}
@Override
diff --git a/components/camel-wrap/src/generated/resources/org/apache/camel/component/wrap/wrap.json b/components/camel-wrap/src/generated/resources/org/apache/camel/component/wrap/wrap.json
index 2ae5976..47d8425 100644
--- a/components/camel-wrap/src/generated/resources/org/apache/camel/component/wrap/wrap.json
+++ b/components/camel-wrap/src/generated/resources/org/apache/camel/component/wrap/wrap.json
@@ -16,6 +16,7 @@
"extendsScheme": "",
"syntax": "wrap:delegateUri",
"async": false,
+ "api": false,
"consumerOnly": false,
"producerOnly": false,
"lenientProperties": true
@@ -23,7 +24,7 @@
"componentProperties": {
"bridgeErrorHandler": { "kind": "property", "displayName": "Bridge Error Handler", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by [...]
"lazyStartProducer": { "kind": "property", "displayName": "Lazy Start Producer", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": 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 fail during starting and cause the r [...]
- "basicPropertyBinding": { "kind": "property", "displayName": "Basic Property Binding", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Whether the component should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities" }
+ "basicPropertyBinding": { "kind": "property", "displayName": "Basic Property Binding", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": true, "secret": false, "defaultValue": false, "description": "Whether the component should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities" }
},
"properties": {
"delegateUri": { "kind": "path", "displayName": "Delegate Uri", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "secret": false, "description": "The delegated uri" },
@@ -32,6 +33,6 @@
"exchangePattern": { "kind": "parameter", "displayName": "Exchange Pattern", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut", "InOptionalOut" ], "deprecated": false, "secret": false, "description": "Sets the exchange pattern when the consumer creates an exchange." },
"lazyStartProducer": { "kind": "parameter", "displayName": "Lazy Start Producer", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": 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 fail during starting and cause the [...]
"basicPropertyBinding": { "kind": "parameter", "displayName": "Basic Property Binding", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities" },
- "synchronous": { "kind": "parameter", "displayName": "Synchronous", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "false", "description": "Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported)." }
+ "synchronous": { "kind": "parameter", "displayName": "Synchronous", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported)." }
}
}
[camel-k-runtime] 02/04: yaml: use EndpointUriFactory to compute
endpoint uri
Posted by lb...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lburgazzoli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-k-runtime.git
commit be8915851a1403c2c1428ab6ae4cfedb90381b68
Author: Luca Burgazzoli <lb...@gmail.com>
AuthorDate: Mon Oct 19 14:35:47 2020 +0200
yaml: use EndpointUriFactory to compute endpoint uri
---
.../camel/k/loader/yaml/support/StepParserSupport.java | 17 +++++++++++------
camel-k-loader-yaml/camel-k-loader-yaml/pom.xml | 5 -----
.../camel/k/loader/yaml/RoutesWithEndpointTest.groovy | 4 ++--
.../resources/routes/RoutesWithEndpointTest_from.yaml | 2 +-
.../resources/routes/RoutesWithEndpointTest_route.yaml | 2 +-
5 files changed, 15 insertions(+), 15 deletions(-)
diff --git a/camel-k-loader-yaml/camel-k-loader-yaml-common/src/main/java/org/apache/camel/k/loader/yaml/support/StepParserSupport.java b/camel-k-loader-yaml/camel-k-loader-yaml-common/src/main/java/org/apache/camel/k/loader/yaml/support/StepParserSupport.java
index 1889c18..017ad30 100644
--- a/camel-k-loader-yaml/camel-k-loader-yaml-common/src/main/java/org/apache/camel/k/loader/yaml/support/StepParserSupport.java
+++ b/camel-k-loader-yaml/camel-k-loader-yaml-common/src/main/java/org/apache/camel/k/loader/yaml/support/StepParserSupport.java
@@ -17,10 +17,8 @@
package org.apache.camel.k.loader.yaml.support;
import java.net.URISyntaxException;
-import java.util.HashMap;
import java.util.List;
import java.util.Map;
-import java.util.Objects;
import java.util.stream.Collectors;
import org.apache.camel.CamelContext;
@@ -31,6 +29,7 @@ import org.apache.camel.k.loader.yaml.spi.StepParser;
import org.apache.camel.k.loader.yaml.spi.StepParserException;
import org.apache.camel.model.OutputNode;
import org.apache.camel.model.ProcessorDefinition;
+import org.apache.camel.spi.EndpointUriFactory;
import org.apache.camel.util.ObjectHelper;
public final class StepParserSupport {
@@ -89,11 +88,17 @@ public final class StepParserSupport {
}
public static String createEndpointUri(CamelContext context, String scheme, Map<String, Object> parameters) {
- try {
- Map<String, String> params = new HashMap<>();
- parameters.forEach((k, v) -> params.put(k, Objects.toString(v)));
+ final EndpointUriFactory factory = context.adapt(ExtendedCamelContext.class).getEndpointUriFactory(scheme);
- return context.adapt(ExtendedCamelContext.class).getRuntimeCamelCatalog().asEndpointUri(scheme, params, false);
+ if (factory == null) {
+ throw new IllegalArgumentException("Cannot compute endpoint URI: unable to find an EndpointUriFactory for scheme " + scheme);
+ }
+ if (!factory.isEnabled(scheme)) {
+ throw new IllegalArgumentException("Cannot compute endpoint URI: scheme " + scheme + " is not enabled");
+ }
+
+ try {
+ return factory.buildUri(scheme, parameters);
} catch (URISyntaxException e) {
throw new IllegalArgumentException(e);
}
diff --git a/camel-k-loader-yaml/camel-k-loader-yaml/pom.xml b/camel-k-loader-yaml/camel-k-loader-yaml/pom.xml
index 3fd3c70..4b6f176 100644
--- a/camel-k-loader-yaml/camel-k-loader-yaml/pom.xml
+++ b/camel-k-loader-yaml/camel-k-loader-yaml/pom.xml
@@ -36,11 +36,6 @@
<!-- ****************************** -->
<dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-core-catalog</artifactId>
- </dependency>
-
- <dependency>
<groupId>org.apache.camel.k</groupId>
<artifactId>camel-k-runtime-core</artifactId>
</dependency>
diff --git a/camel-k-loader-yaml/camel-k-loader-yaml/src/test/groovy/org/apache/camel/k/loader/yaml/RoutesWithEndpointTest.groovy b/camel-k-loader-yaml/camel-k-loader-yaml/src/test/groovy/org/apache/camel/k/loader/yaml/RoutesWithEndpointTest.groovy
index 1f9cbfc..f27ab3b 100644
--- a/camel-k-loader-yaml/camel-k-loader-yaml/src/test/groovy/org/apache/camel/k/loader/yaml/RoutesWithEndpointTest.groovy
+++ b/camel-k-loader-yaml/camel-k-loader-yaml/src/test/groovy/org/apache/camel/k/loader/yaml/RoutesWithEndpointTest.groovy
@@ -43,7 +43,7 @@ class RoutesWithEndpointTest extends TestSupport {
timeout == 1_234_000
}
with (te, TelegramEndpoint) {
- endpointUri == 'telegram://bots?authorizationToken=%23property:telegram.token'
+ endpointUri == 'telegram://bots?authorizationToken=RAW(myToken+)'
configuration.authorizationToken == 'myToken+'
}
with (me, MockEndpoint) {
@@ -74,7 +74,7 @@ class RoutesWithEndpointTest extends TestSupport {
timeout == 1_234_000
}
with (te, TelegramEndpoint) {
- endpointUri == 'telegram://bots?authorizationToken=%23property:telegram.token'
+ endpointUri == 'telegram://bots?authorizationToken=RAW(myToken+)'
configuration.authorizationToken == 'myToken+'
}
with (me, MockEndpoint) {
diff --git a/camel-k-loader-yaml/camel-k-loader-yaml/src/test/resources/routes/RoutesWithEndpointTest_from.yaml b/camel-k-loader-yaml/camel-k-loader-yaml/src/test/resources/routes/RoutesWithEndpointTest_from.yaml
index 196e6c4..d7b6861 100644
--- a/camel-k-loader-yaml/camel-k-loader-yaml/src/test/resources/routes/RoutesWithEndpointTest_from.yaml
+++ b/camel-k-loader-yaml/camel-k-loader-yaml/src/test/resources/routes/RoutesWithEndpointTest_from.yaml
@@ -21,6 +21,6 @@
steps:
- telegram:
type: "bots"
- authorization-token: "#property:telegram.token"
+ authorization-token: "{{telegram.token}}"
- mock:
name: "telegram"
\ No newline at end of file
diff --git a/camel-k-loader-yaml/camel-k-loader-yaml/src/test/resources/routes/RoutesWithEndpointTest_route.yaml b/camel-k-loader-yaml/camel-k-loader-yaml/src/test/resources/routes/RoutesWithEndpointTest_route.yaml
index 1f0e92d..c060c3b 100644
--- a/camel-k-loader-yaml/camel-k-loader-yaml/src/test/resources/routes/RoutesWithEndpointTest_route.yaml
+++ b/camel-k-loader-yaml/camel-k-loader-yaml/src/test/resources/routes/RoutesWithEndpointTest_route.yaml
@@ -22,6 +22,6 @@
steps:
- telegram:
type: "bots"
- authorization-token: "#property:telegram.token"
+ authorization-token: "{{telegram.token}}"
- mock:
name: "telegram"
\ No newline at end of file
[camel-k-runtime] 03/04: yaml: use URISupport to create query string
Posted by lb...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lburgazzoli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-k-runtime.git
commit 77ca0b7d61b6dac9d9d09beddf2ebabe4cada025
Author: Luca Burgazzoli <lb...@gmail.com>
AuthorDate: Mon Oct 19 14:51:39 2020 +0200
yaml: use URISupport to create query string
---
.../camel/k/loader/yaml/support/StepParserSupport.java | 18 ++++++++++--------
1 file changed, 10 insertions(+), 8 deletions(-)
diff --git a/camel-k-loader-yaml/camel-k-loader-yaml-common/src/main/java/org/apache/camel/k/loader/yaml/support/StepParserSupport.java b/camel-k-loader-yaml/camel-k-loader-yaml-common/src/main/java/org/apache/camel/k/loader/yaml/support/StepParserSupport.java
index 017ad30..fc44afe 100644
--- a/camel-k-loader-yaml/camel-k-loader-yaml-common/src/main/java/org/apache/camel/k/loader/yaml/support/StepParserSupport.java
+++ b/camel-k-loader-yaml/camel-k-loader-yaml-common/src/main/java/org/apache/camel/k/loader/yaml/support/StepParserSupport.java
@@ -19,7 +19,6 @@ package org.apache.camel.k.loader.yaml.support;
import java.net.URISyntaxException;
import java.util.List;
import java.util.Map;
-import java.util.stream.Collectors;
import org.apache.camel.CamelContext;
import org.apache.camel.ExtendedCamelContext;
@@ -31,6 +30,7 @@ import org.apache.camel.model.OutputNode;
import org.apache.camel.model.ProcessorDefinition;
import org.apache.camel.spi.EndpointUriFactory;
import org.apache.camel.util.ObjectHelper;
+import org.apache.camel.util.URISupport;
public final class StepParserSupport {
private StepParserSupport() {
@@ -74,13 +74,15 @@ public final class StepParserSupport {
String answer = uri;
if (parameters != null) {
- String queryString = parameters.entrySet().stream()
- .filter(entry -> entry.getValue() != null)
- .map(entry -> String.format("%s=%s", entry.getKey(), entry.getValue()))
- .collect(Collectors.joining("&"));
-
- if (ObjectHelper.isNotEmpty(queryString)) {
- answer += "?" + queryString;
+ String queryString;
+
+ try {
+ queryString = URISupport.createQueryString(parameters, false);
+ if (ObjectHelper.isNotEmpty(queryString)) {
+ answer += "?" + queryString;
+ }
+ } catch (URISyntaxException e) {
+ throw new IllegalArgumentException(e);
}
}
[camel-k-runtime] 01/04: chore(deps): update to camel-quarkus 1.3.0
Posted by lb...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lburgazzoli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-k-runtime.git
commit cfd08e6c7f3b537b224753c72551ec4d8d9ace40
Author: Luca Burgazzoli <lb...@gmail.com>
AuthorDate: Thu Oct 15 16:14:29 2020 +0200
chore(deps): update to camel-quarkus 1.3.0
---
components/camel-knative/camel-knative/pom.xml | 3 +++
pom.xml | 14 ++++----------
tooling/camel-k-test/pom.xml | 4 ----
3 files changed, 7 insertions(+), 14 deletions(-)
diff --git a/components/camel-knative/camel-knative/pom.xml b/components/camel-knative/camel-knative/pom.xml
index 0d59bc1..df1b560 100644
--- a/components/camel-knative/camel-knative/pom.xml
+++ b/components/camel-knative/camel-knative/pom.xml
@@ -103,6 +103,8 @@
</execution>
</executions>
</plugin>
+ <!--
+ TODO: re-enable after fix for https://issues.apache.org/jira/browse/CAMEL-15706
<plugin>
<groupId>org.apache.camel</groupId>
<artifactId>camel-package-maven-plugin</artifactId>
@@ -116,6 +118,7 @@
</execution>
</executions>
</plugin>
+ -->
<plugin>
<groupId>org.codehaus.mojo</groupId>
<artifactId>build-helper-maven-plugin</artifactId>
diff --git a/pom.xml b/pom.xml
index 831da1b..da193ed 100644
--- a/pom.xml
+++ b/pom.xml
@@ -22,7 +22,7 @@
<parent>
<groupId>org.apache.camel</groupId>
<artifactId>camel-dependencies</artifactId>
- <version>3.5.0</version>
+ <version>3.6.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>
@@ -38,12 +38,12 @@
<maven.compiler.source>11</maven.compiler.source>
<maven.compiler.target>11</maven.compiler.target>
- <camel-version>3.5.0</camel-version>
+ <camel-version>3.6.0</camel-version>
<!-- quarkus -->
- <camel-quarkus-version>1.1.0</camel-quarkus-version>
+ <camel-quarkus-version>1.3.0</camel-quarkus-version>
<graalvm-version>20.2.0</graalvm-version>
- <quarkus-version>1.8.0.Final</quarkus-version>
+ <quarkus-version>1.9.0.Final</quarkus-version>
<!-- camel-k -->
<joor-version>0.9.13</joor-version>
@@ -55,7 +55,6 @@
<immutables-version>2.8.8</immutables-version>
<semver4j-version>3.1.0</semver4j-version>
<jaeger-version>1.4.0</jaeger-version>
- <junit-pioneer-version>1.0.0</junit-pioneer-version>
<!-- overridden camel dependencies versions -->
<javapoet-version>1.13.0</javapoet-version>
@@ -748,11 +747,6 @@
<version>${junit-jupiter-version}</version>
</dependency>
<dependency>
- <groupId>org.junit-pioneer</groupId>
- <artifactId>junit-pioneer</artifactId>
- <version>${junit-pioneer-version}</version>
- </dependency>
- <dependency>
<groupId>org.assertj</groupId>
<artifactId>assertj-core</artifactId>
<version>${assertj-version}</version>
diff --git a/tooling/camel-k-test/pom.xml b/tooling/camel-k-test/pom.xml
index a9b5285..b9e434c 100644
--- a/tooling/camel-k-test/pom.xml
+++ b/tooling/camel-k-test/pom.xml
@@ -33,10 +33,6 @@
<groupId>org.junit.jupiter</groupId>
<artifactId>junit-jupiter</artifactId>
</dependency>
- <dependency>
- <groupId>org.junit-pioneer</groupId>
- <artifactId>junit-pioneer</artifactId>
- </dependency>
<dependency>
<groupId>org.assertj</groupId>