[GitHub] [camel-quarkus] github-actions[bot] commented on issue #2926: [CI] - Quarkus Main Branch Build Failure
github-actions[bot] commented on issue #2926: URL: https://github.com/apache/camel-quarkus/issues/2926#issuecomment-955637615 The [quarkus-main](https://github.com/apache/camel-quarkus/tree/quarkus-main) branch build has failed: * Build ID: 1403686220-556-ea181d70-9333-4294-bf4d-c4717e49ea38 * Camel Quarkus Commit: f53d04a88ed297508dcb4f1bdc95ec3aa4d20aa1 * Quarkus Main Commit: 1ba20292a45baaa731c5b870d353910b6d53e775 * Link to build: https://github.com/apache/camel-quarkus/actions/runs/1403686220 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] github-actions[bot] commented on issue #2927: [CI] - Camel Main Branch Build Failure
github-actions[bot] commented on issue #2927: URL: https://github.com/apache/camel-quarkus/issues/2927#issuecomment-955632953 The [camel-main](https://github.com/apache/camel-quarkus/tree/camel-main) branch build has failed: * Build ID: 1403458556-452-c2a74a15-d4c9-41a8-ac21-b96ec435b528 * Camel Quarkus Commit: 0f14434229f7d4a0f96d3e6f8f53d8eb96fc11ee * Camel Main Commit: 1ba20292a45baaa731c5b870d353910b6d53e775 * Link to build: https://github.com/apache/camel-quarkus/actions/runs/1403458556 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-kafka-connector] branch main updated: Updated CHANGELOG.md
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/main by this push: new ada8e47 Updated CHANGELOG.md ada8e47 is described below commit ada8e47ae9e84ab9d03d2493f6918f8beb2f4a3c Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Sun Oct 31 03:03:41 2021 + Updated CHANGELOG.md --- CHANGELOG.md | 8 1 file changed, 8 insertions(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index c4f8f27..b0195d8 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -4,6 +4,10 @@ [Full Changelog](https://github.com/apache/camel-kafka-connector/compare/camel-kafka-connector-0.11.0...HEAD) +**Fixed bugs:** + +- Error with Syslog Source Connector [\#665](https://github.com/apache/camel-kafka-connector/issues/665) + **Closed issues:** - Using kinesis sink with STS assumeRole credentials? [\#1272](https://github.com/apache/camel-kafka-connector/issues/1272) @@ -12,9 +16,13 @@ - AWS SQS Source Message Delete [\#1266](https://github.com/apache/camel-kafka-connector/issues/1266) - Modular packaging of connectors? [\#1264](https://github.com/apache/camel-kafka-connector/issues/1264) - Bearer Token with HTTP sink? [\#1255](https://github.com/apache/camel-kafka-connector/issues/1255) +- Run slow tests on Apache CI [\#786](https://github.com/apache/camel-kafka-connector/issues/786) **Merged pull requests:** +- chore: regen. [\#1281](https://github.com/apache/camel-kafka-connector/pull/1281) ([valdar](https://github.com/valdar)) +- GenerateCamelKafkaConnectorsMojo : Added possibility to exclude conne… [\#1280](https://github.com/apache/camel-kafka-connector/pull/1280) ([valdar](https://github.com/valdar)) +- Camel3.12 [\#1279](https://github.com/apache/camel-kafka-connector/pull/1279) ([valdar](https://github.com/valdar)) - Main latest to next2 [\#1278](https://github.com/apache/camel-kafka-connector/pull/1278) ([djencks](https://github.com/djencks)) - \[Github Actions\] Periodic Sync Camel-kafka-connector main Branch [\#1277](https://github.com/apache/camel-kafka-connector/pull/1277) ([github-actions[bot]](https://github.com/apps/github-actions)) - camel kafka connector main latest to next [\#1275](https://github.com/apache/camel-kafka-connector/pull/1275) ([djencks](https://github.com/djencks))
[GitHub] [camel-kafka-connector] valdar merged pull request #1281: chore: regen.
valdar merged pull request #1281: URL: https://github.com/apache/camel-kafka-connector/pull/1281 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-kafka-connector] branch main updated: chore: regen.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/main by this push: new 0fe96d7 chore: regen. 0fe96d7 is described below commit 0fe96d7dd2f664940e798c95b3c485a6a9f14377 Author: Andrea Tarocchi AuthorDate: Sun Oct 31 01:57:05 2021 +0200 chore: regen. --- connectors/pom.xml | 3 + docs/modules/ROOT/nav.adoc | 112 --- docs/modules/ROOT/pages/reference/index.adoc | 44 +-- 3 files changed, 4 insertions(+), 155 deletions(-) diff --git a/connectors/pom.xml b/connectors/pom.xml index 1318df7..75ae12e 100644 --- a/connectors/pom.xml +++ b/connectors/pom.xml @@ -120,6 +120,9 @@ ref robotframework + +syslog + diff --git a/docs/modules/ROOT/nav.adoc b/docs/modules/ROOT/nav.adoc index 8e2642e..b4aa73f 100644 --- a/docs/modules/ROOT/nav.adoc +++ b/docs/modules/ROOT/nav.adoc @@ -111,14 +111,8 @@ xref:reference/connectors/camel-aws-sqs-source-kafka-source-connector.adoc[Source Docs] *** camel-aws2-athena-kafka-connector xref:reference/connectors/camel-aws2-athena-kafka-sink-connector.adoc[Sink Docs] -*** camel-aws2-cw-kafka-connector - xref:reference/connectors/camel-aws2-cw-kafka-sink-connector.adoc[Sink Docs] -*** camel-aws2-ddb-kafka-connector - xref:reference/connectors/camel-aws2-ddb-kafka-sink-connector.adoc[Sink Docs] *** camel-aws2-ddbstream-kafka-connector xref:reference/connectors/camel-aws2-ddbstream-kafka-source-connector.adoc[Source Docs] -*** camel-aws2-ec2-kafka-connector - xref:reference/connectors/camel-aws2-ec2-kafka-sink-connector.adoc[Sink Docs] *** camel-aws2-ecs-kafka-connector xref:reference/connectors/camel-aws2-ecs-kafka-sink-connector.adoc[Sink Docs] *** camel-aws2-eks-kafka-connector @@ -129,27 +123,14 @@ xref:reference/connectors/camel-aws2-iam-kafka-sink-connector.adoc[Sink Docs] *** camel-aws2-kinesis-firehose-kafka-connector xref:reference/connectors/camel-aws2-kinesis-firehose-kafka-sink-connector.adoc[Sink Docs] -*** camel-aws2-kinesis-kafka-connector - xref:reference/connectors/camel-aws2-kinesis-kafka-source-connector.adoc[Source Docs] - xref:reference/connectors/camel-aws2-kinesis-kafka-sink-connector.adoc[Sink Docs] *** camel-aws2-kms-kafka-connector xref:reference/connectors/camel-aws2-kms-kafka-sink-connector.adoc[Sink Docs] -*** camel-aws2-lambda-kafka-connector - xref:reference/connectors/camel-aws2-lambda-kafka-sink-connector.adoc[Sink Docs] *** camel-aws2-mq-kafka-connector xref:reference/connectors/camel-aws2-mq-kafka-sink-connector.adoc[Sink Docs] *** camel-aws2-msk-kafka-connector xref:reference/connectors/camel-aws2-msk-kafka-sink-connector.adoc[Sink Docs] -*** camel-aws2-s3-kafka-connector - xref:reference/connectors/camel-aws2-s3-kafka-source-connector.adoc[Source Docs] - xref:reference/connectors/camel-aws2-s3-kafka-sink-connector.adoc[Sink Docs] *** camel-aws2-ses-kafka-connector xref:reference/connectors/camel-aws2-ses-kafka-sink-connector.adoc[Sink Docs] -*** camel-aws2-sns-kafka-connector - xref:reference/connectors/camel-aws2-sns-kafka-sink-connector.adoc[Sink Docs] -*** camel-aws2-sqs-kafka-connector - xref:reference/connectors/camel-aws2-sqs-kafka-source-connector.adoc[Source Docs] - xref:reference/connectors/camel-aws2-sqs-kafka-sink-connector.adoc[Sink Docs] *** camel-aws2-sts-kafka-connector xref:reference/connectors/camel-aws2-sts-kafka-sink-connector.adoc[Sink Docs] *** camel-aws2-translate-kafka-connector @@ -157,16 +138,10 @@ *** camel-azure-cosmosdb-kafka-connector xref:reference/connectors/camel-azure-cosmosdb-kafka-source-connector.adoc[Source Docs] xref:reference/connectors/camel-azure-cosmosdb-kafka-sink-connector.adoc[Sink Docs] -*** camel-azure-eventhubs-kafka-connector - xref:reference/connectors/camel-azure-eventhubs-kafka-source-connector.adoc[Source Docs] - xref:reference/connectors/camel-azure-eventhubs-kafka-sink-connector.adoc[Sink Docs] *** camel-azure-eventhubs-sink-kafka-connector xref:reference/connectors/camel-azure-eventhubs-sink-kafka-sink-connector.adoc[Sink Docs] *** camel-azure-eventhubs-source-kafka-connector xref:reference/connectors/camel-azure-eventhubs-source-kafka-source-connector.adoc[Source Docs] -*** camel-azure-storage-blob-kafka-connector - xref:reference/connectors/camel-azure-storage-blob-kafka-source-connector.adoc[Source Docs] - xref:reference/connectors/camel-azure-storage-blob-kafka-sink-connector.adoc[Sink Docs] ***
[camel-kafka-connector] branch main updated: GenerateCamelKafkaConnectorsMojo : Added possibility to exclude connectors from automatic deletion during generation.
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/main by this push:
new fd25e49 GenerateCamelKafkaConnectorsMojo : Added possibility to
exclude connectors from automatic deletion during generation.
fd25e49 is described below
commit fd25e49824f5798ff1a2570a37a0e8d3246a2556
Author: Andrea Tarocchi
AuthorDate: Sun Oct 31 01:22:26 2021 +0200
GenerateCamelKafkaConnectorsMojo : Added possibility to exclude connectors
from automatic deletion during generation.
---
.../maven/GenerateCamelKafkaConnectorsMojo.java | 16
.../maven_project/pom.xml| 3 +++
2 files changed, 15 insertions(+), 4 deletions(-)
diff --git
a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojo.java
b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojo.java
index aff55e1..275469d 100644
---
a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojo.java
+++
b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojo.java
@@ -148,6 +148,12 @@ public class GenerateCamelKafkaConnectorsMojo extends
AbstractCamelKafkaConnecto
@Parameter(defaultValue = "", readonly = true)
private List excludedComponents = Collections.EMPTY_LIST;
+/**
+ * The Exclusion List of connectors that must be skipped while deleting
kafka connector.
+ */
+@Parameter(defaultValue = "", readonly = true)
+private List excludedConnectorsFromDeletion = Collections.EMPTY_LIST;
+
@Component
private ProjectDependenciesResolver projectDependenciesResolver;
@@ -335,13 +341,15 @@ public class GenerateCamelKafkaConnectorsMojo extends
AbstractCamelKafkaConnecto
if (existingConnectorNames != null) {
List connectorsToRemove =
Stream.of(existingConnectorNames).sorted().filter(filename -> {
String componentName = extractComponentName(filename);
-// set to remove connectors that are not generated
from camel components or a kamelet
-return
!sanitizedGeneratedFromComponentsConnectorsNames.contains(componentName) &&
!sanitizedGeneratedFromKameletsConnectorsNames.contains(componentName);
+// set to remove connectors that are not generated
from camel components or a kamelet and are not excluded in
excludedConnectorsFromDeletion
+return
!sanitizedGeneratedFromComponentsConnectorsNames.contains(componentName)
+&&
!sanitizedGeneratedFromKameletsConnectorsNames.contains(componentName)
+&&
!excludedConnectorsFromDeletion.contains(componentName);
}).collect(Collectors.toList());
getLog().info("Connectors previously generated found to be
removed: " + connectorsToRemove);
-for (String component: connectorsToRemove) {
+for (String connectorToBeRemoved: connectorsToRemove) {
executeMojo(
plugin(
@@ -351,7 +359,7 @@ public class GenerateCamelKafkaConnectorsMojo extends
AbstractCamelKafkaConnecto
),
goal("camel-kafka-connector-delete"),
configuration(
-element(name("name"), component),
+element(name("name"),
connectorToBeRemoved),
element(name("connectorsProjectName"),
connectorsProjectName)
),
executionEnvironment(
diff --git
a/tooling/camel-kafka-connector-generator-maven-plugin/src/test/resources-its/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojoIT/maven_project/pom.xml
b/tooling/camel-kafka-connector-generator-maven-plugin/src/test/resources-its/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojoIT/maven_project/pom.xml
index 7ac1eaa..a3816c1 100644
---
a/tooling/camel-kafka-connector-generator-maven-plugin/src/test/resources-its/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojoIT/maven_project/pom.xml
+++
b/tooling/camel-kafka-connector-generator-maven-plugin/src/test/resources-its/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojoIT/maven_project/pom.xml
@@ -131,6 +131,9 @@
ref
[GitHub] [camel-kafka-connector] valdar merged pull request #1280: GenerateCamelKafkaConnectorsMojo : Added possibility to exclude conne…
valdar merged pull request #1280: URL: https://github.com/apache/camel-kafka-connector/pull/1280 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] valdar opened a new pull request #1280: GenerateCamelKafkaConnectorsMojo : Added possibility to exclude conne…
valdar opened a new pull request #1280: URL: https://github.com/apache/camel-kafka-connector/pull/1280 …ctors from automatic deletion during generation. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] valdar commented on issue #786: Run slow tests on Apache CI
valdar commented on issue #786: URL: https://github.com/apache/camel-kafka-connector/issues/786#issuecomment-955603873 I think this is done given the resolution of https://issues.apache.org/jira/browse/INFRA-21197, @orpiske feel free to reopen it if needed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] valdar closed issue #786: Run slow tests on Apache CI
valdar closed issue #786: URL: https://github.com/apache/camel-kafka-connector/issues/786 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] valdar closed issue #665: Error with Syslog Source Connector
valdar closed issue #665: URL: https://github.com/apache/camel-kafka-connector/issues/665 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] valdar commented on issue #665: Error with Syslog Source Connector
valdar commented on issue #665: URL: https://github.com/apache/camel-kafka-connector/issues/665#issuecomment-955603548 @vbbhatia14 I am closing this because I am pretty sure it is fixed, feel free to reopen it if needed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] valdar merged pull request #1279: Camel3.12
valdar merged pull request #1279: URL: https://github.com/apache/camel-kafka-connector/pull/1279 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-kafka-connector] 03/04: fixed googlepubsub itests.
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit f03ff05edbd59e0c95dc7e2bf1ae03a61718c0bf
Author: Andrea Tarocchi
AuthorDate: Fri Oct 29 15:49:22 2021 +0200
fixed googlepubsub itests.
---
.../connectors/camel-hwcloud-dms-sink.json | 213 +++
.../camel-hwcloud-imagerecognition-sink.json | 139 ++
.../connectors/camel-hwcloud-obs-sink.json | 113
.../connectors/camel-hwcloud-obs-source.json | 293 +
.../connectors/camel-json-patch-sink.json | 54
.../google/pubsub/clients/GooglePubEasy.java | 38 +++
.../sink/CamelGooglePubSubPropertyFactory.java | 6 +-
.../pubsub/sink/CamelSinkGooglePubSubITCase.java | 9 +-
8 files changed, 862 insertions(+), 3 deletions(-)
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-hwcloud-dms-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-hwcloud-dms-sink.json
new file mode 100644
index 000..c5960bd
--- /dev/null
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-hwcloud-dms-sink.json
@@ -0,0 +1,213 @@
+{
+ "connector": {
+ "class":
"org.apache.camel.kafkaconnector.hwclouddms.CamelHwclouddmsSinkConnector",
+ "artifactId": "camel-hwcloud-dms-kafka-connector",
+ "groupId": "org.apache.camel.kafkaconnector",
+ "id": "camel-hwcloud-dms-sink",
+ "type": "sink",
+ "version": "0.12.0-SNAPSHOT",
+ "description": "To integrate with a fully managed,
high-performance message queuing service on Huawei Cloud"
+ },
+ "properties": {
+ "camel.sink.path.operation": {
+ "name": "camel.sink.path.operation",
+ "description": "Operation to be performed",
+ "priority": "HIGH",
+ "required": "true"
+ },
+ "camel.sink.endpoint.accessKey": {
+ "name": "camel.sink.endpoint.accessKey",
+ "description": "Access key for the cloud user",
+ "priority": "HIGH",
+ "required": "true"
+ },
+ "camel.sink.endpoint.accessUser": {
+ "name": "camel.sink.endpoint.accessUser",
+ "description": "The username of a RabbitMQ instance.
This option is mandatory when creating a RabbitMQ instance.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.sink.endpoint.availableZones": {
+ "name": "camel.sink.endpoint.availableZones",
+ "description": "The ID of an available zone. This
option is mandatory when creating an instance and it cannot be an empty array.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.sink.endpoint.endpoint": {
+ "name": "camel.sink.endpoint.endpoint",
+ "description": "DMS url. Carries higher precedence than
region parameter based client initialization",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.sink.endpoint.engine": {
+ "name": "camel.sink.endpoint.engine",
+ "description": "The message engine. Either kafka or
rabbitmq. If the parameter is not specified, all instances will be queried One
of: [kafka] [rabbitmq]",
+ "priority": "MEDIUM",
+ "required": "false",
+ "enum": [
+ "kafka",
+ "rabbitmq"
+ ]
+ },
+ "camel.sink.endpoint.engineVersion": {
+ "name": "camel.sink.endpoint.engineVersion",
+ "description": "The version of the message engine. This
option is mandatory when creating an instance.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.sink.endpoint.ignoreSslVerification": {
+ "name": "camel.sink.endpoint.ignoreSslVerification",
+ "description": "Ignore SSL verification",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.sink.endpoint.instanceId": {
+ "name": "camel.sink.endpoint.instanceId",
+ "description": "The id of the instance. This
[camel-kafka-connector] branch main updated (c4d394d -> 95516c6)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. from c4d394d Updated CHANGELOG.md new ad2c7b4 Updated to camel 3.12 new 9355af9 chore: regen. new f03ff05 fixed googlepubsub itests. new 95516c6 Adjusted itest netty-http retry timeout. 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: .../resources/connectors/camel-activemq-sink.json | 8 +- .../connectors/camel-activemq-source.json | 8 +- .../resources/connectors/camel-amqp-sink.json | 8 +- .../resources/connectors/camel-amqp-source.json| 8 +- .../resources/connectors/camel-as2-sink.json | 6 + .../resources/connectors/camel-as2-source.json | 6 + .../connectors/camel-aws-secrets-manager-sink.json | 6 +- .../connectors/camel-aws2-ddbstream-source.json| 54 ++-- .../resources/connectors/camel-file-source.json| 2 +- .../resources/connectors/camel-ftps-source.json| 2 +- .../connectors/camel-google-pubsub-sink.json | 44 +--- .../connectors/camel-google-pubsub-source.json | 56 +++-- .../camel-google-sheets-stream-source.json | 18 +- .../resources/connectors/camel-graphql-sink.json | 12 + .../resources/connectors/camel-https-sink.json | 22 +- .../connectors/camel-hwcloud-dms-sink.json | 213 .../camel-hwcloud-functiongraph-sink.json | 8 +- .../connectors/camel-hwcloud-iam-sink.json | 8 +- ...on => camel-hwcloud-imagerecognition-sink.json} | 95 --- .../connectors/camel-hwcloud-obs-sink.json | 64 ++--- .../connectors/camel-hwcloud-obs-source.json | 273 +++-- .../connectors/camel-hwcloud-smn-sink.json | 8 +- .../resources/connectors/camel-influxdb-sink.json | 14 ++ ...idator-sink.json => camel-json-patch-sink.json} | 50 +--- .../connectors/camel-json-validator-sink.json | 6 +- .../resources/connectors/camel-log-sink.json | 9 +- .../resources/connectors/camel-netty-sink.json | 2 +- .../resources/connectors/camel-netty-source.json | 2 +- .../connectors/camel-paho-mqtt5-sink.json | 14 ++ .../connectors/camel-paho-mqtt5-source.json| 14 ++ .../resources/connectors/camel-pulsar-sink.json| 36 +++ .../resources/connectors/camel-pulsar-source.json | 64 + .../resources/connectors/camel-resteasy-sink.json | 6 + .../resources/connectors/camel-sftp-source.json| 2 +- .../resources/connectors/camel-sjms2-source.json | 6 +- .../resources/connectors/camel-stitch-sink.json| 2 +- .../resources/connectors/camel-websocket-sink.json | 7 + .../connectors/camel-websocket-source.json | 14 ++ .../resources/descriptors/connectors.properties| 5 + .../generated/resources/camel-activemq-sink.json | 8 +- .../generated/resources/camel-activemq-source.json | 8 +- .../docs/camel-activemq-kafka-sink-connector.adoc | 4 +- .../camel-activemq-kafka-source-connector.adoc | 4 +- .../activemq/CamelActivemqSinkConnectorConfig.java | 8 +- .../CamelActivemqSourceConnectorConfig.java| 8 +- .../src/generated/resources/camel-amqp-sink.json | 8 +- .../src/generated/resources/camel-amqp-source.json | 8 +- .../main/docs/camel-amqp-kafka-sink-connector.adoc | 4 +- .../docs/camel-amqp-kafka-source-connector.adoc| 4 +- .../amqp/CamelAmqpSinkConnectorConfig.java | 8 +- .../amqp/CamelAmqpSourceConnectorConfig.java | 8 +- .../src/generated/resources/camel-as2-sink.json| 6 + .../src/generated/resources/camel-as2-source.json | 6 + .../main/docs/camel-as2-kafka-sink-connector.adoc | 3 +- .../docs/camel-as2-kafka-source-connector.adoc | 3 +- .../as2/CamelAs2SinkConnectorConfig.java | 4 + .../as2/CamelAs2SourceConnectorConfig.java | 4 + .../resources/camel-aws-secrets-manager-sink.json | 6 +- ...l-aws-secrets-manager-kafka-sink-connector.adoc | 4 +- .../CamelAwssecretsmanagerSinkConnector.properties | 4 +- .../CamelAwssecretsmanagerSinkConnectorConfig.java | 4 +- .../resources/camel-aws2-ddbstream-source.json | 54 ++-- ...amel-aws2-ddbstream-kafka-source-connector.adoc | 8 +- .../CamelAws2ddbstreamSourceConnectorConfig.java | 24 +- .../src/generated/resources/camel-file-source.json | 2 +- .../docs/camel-file-kafka-source-connector.adoc| 2 +- .../file/CamelFileSourceConnectorConfig.java | 2 +- .../src/generated/resources/camel-ftps-source.json | 2 +- .../docs/camel-ftps-kafka-source-connector.adoc| 2 +- .../ftps/CamelFtpsSourceConnectorConfig.java | 2 +-
[camel-kafka-connector] 04/04: Adjusted itest netty-http retry timeout.
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 95516c61f1c7b04f4dafdd54de3694349d74f223
Author: Andrea Tarocchi
AuthorDate: Sat Oct 30 11:48:31 2021 +0200
Adjusted itest netty-http retry timeout.
---
.../kafkaconnector/nettyhttp/source/CamelSourceNettyHTTPITCase.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/tests/itests-netty-http/src/test/java/org/apache/camel/kafkaconnector/nettyhttp/source/CamelSourceNettyHTTPITCase.java
b/tests/itests-netty-http/src/test/java/org/apache/camel/kafkaconnector/nettyhttp/source/CamelSourceNettyHTTPITCase.java
index 0174eb1..f021ee4 100644
---
a/tests/itests-netty-http/src/test/java/org/apache/camel/kafkaconnector/nettyhttp/source/CamelSourceNettyHTTPITCase.java
+++
b/tests/itests-netty-http/src/test/java/org/apache/camel/kafkaconnector/nettyhttp/source/CamelSourceNettyHTTPITCase.java
@@ -101,7 +101,7 @@ public class CamelSourceNettyHTTPITCase extends
CamelSourceTestSupport {
} else {
retriesLeft--;
try {
-Thread.sleep(100);
+Thread.sleep(1000);
} catch (InterruptedException interruptedException) {
interruptedException.printStackTrace();
}
[camel-kafka-connector] 01/04: Updated to camel 3.12
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit ad2c7b477a778e450e694a15b0a686aaf8cb101e Author: Andrea Tarocchi AuthorDate: Thu Oct 28 00:14:36 2021 +0200 Updated to camel 3.12 --- parent/pom.xml | 2 +- pom.xml| 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/parent/pom.xml b/parent/pom.xml index b3bf491..3654e55 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -28,7 +28,7 @@ UTF-8 2.8.0 -3.11.1 +3.12.0 0.3.0 1.8.0 1.3.2.Final diff --git a/pom.xml b/pom.xml index 73f3c03..a839010 100644 --- a/pom.xml +++ b/pom.xml @@ -23,7 +23,7 @@ org.apache.camel camel-dependencies -3.11.1 +3.12.0 org.apache.camel.kafkaconnector
[camel] branch regen_bot updated (5c0d97b -> ec6a3a3)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from 5c0d97b CAMEL-16861: Cleanup docs add b09522e Polished add ec6a3a3 CAMEL-17150: camel-yaml-dsl - Should be able to load camel-k yaml file No new revisions were added by this update. Summary of changes: .../camel/main/KameletDependencyDownloader.java| 2 - .../camel/dsl/yaml/KameletRoutesBuilderLoader.java | 4 ++ .../camel/dsl/yaml/YamlRoutesBuilderLoader.java| 53 +- 3 files changed, 55 insertions(+), 4 deletions(-)
[camel] branch main updated (5c0d97b -> ec6a3a3)
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel.git. from 5c0d97b CAMEL-16861: Cleanup docs new b09522e Polished new ec6a3a3 CAMEL-17150: camel-yaml-dsl - Should be able to load camel-k yaml file The 2 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: .../camel/main/KameletDependencyDownloader.java| 2 - .../camel/dsl/yaml/KameletRoutesBuilderLoader.java | 4 ++ .../camel/dsl/yaml/YamlRoutesBuilderLoader.java| 53 +- 3 files changed, 55 insertions(+), 4 deletions(-)
[camel] 02/02: CAMEL-17150: camel-yaml-dsl - Should be able to load camel-k yaml file
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit ec6a3a3424bb0a30180948bc8a7cbc3e1bf9fdd3
Author: Claus Ibsen
AuthorDate: Sat Oct 30 14:56:11 2021 +0200
CAMEL-17150: camel-yaml-dsl - Should be able to load camel-k yaml file
---
.../camel/dsl/yaml/KameletRoutesBuilderLoader.java | 4 ++
.../camel/dsl/yaml/YamlRoutesBuilderLoader.java| 53 +-
2 files changed, 55 insertions(+), 2 deletions(-)
diff --git
a/dsl/camel-yaml-dsl/camel-yaml-dsl/src/main/java/org/apache/camel/dsl/yaml/KameletRoutesBuilderLoader.java
b/dsl/camel-yaml-dsl/camel-yaml-dsl/src/main/java/org/apache/camel/dsl/yaml/KameletRoutesBuilderLoader.java
index c8ed68d..1f770ca 100644
---
a/dsl/camel-yaml-dsl/camel-yaml-dsl/src/main/java/org/apache/camel/dsl/yaml/KameletRoutesBuilderLoader.java
+++
b/dsl/camel-yaml-dsl/camel-yaml-dsl/src/main/java/org/apache/camel/dsl/yaml/KameletRoutesBuilderLoader.java
@@ -47,6 +47,10 @@ public class KameletRoutesBuilderLoader extends
YamlRoutesBuilderLoaderSupport {
protected RouteBuilder builder(Node node) {
Node template = nodeAt(node, "/spec/template");
if (template == null) {
+// fallback till flows get removed
+template = nodeAt(node, "/spec/flows");
+}
+if (template == null) {
// fallback till flow get removed
template = nodeAt(node, "/spec/flow");
}
diff --git
a/dsl/camel-yaml-dsl/camel-yaml-dsl/src/main/java/org/apache/camel/dsl/yaml/YamlRoutesBuilderLoader.java
b/dsl/camel-yaml-dsl/camel-yaml-dsl/src/main/java/org/apache/camel/dsl/yaml/YamlRoutesBuilderLoader.java
index 50348b5..30cd3fa 100644
---
a/dsl/camel-yaml-dsl/camel-yaml-dsl/src/main/java/org/apache/camel/dsl/yaml/YamlRoutesBuilderLoader.java
+++
b/dsl/camel-yaml-dsl/camel-yaml-dsl/src/main/java/org/apache/camel/dsl/yaml/YamlRoutesBuilderLoader.java
@@ -16,11 +16,15 @@
*/
package org.apache.camel.dsl.yaml;
+import java.util.List;
+import java.util.Objects;
+
import org.apache.camel.CamelContextAware;
import org.apache.camel.api.management.ManagedResource;
import org.apache.camel.builder.ErrorHandlerBuilder;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.builder.RouteConfigurationBuilder;
+import org.apache.camel.dsl.yaml.common.YamlDeserializerSupport;
import org.apache.camel.dsl.yaml.deserializers.OutputAwareFromDefinition;
import org.apache.camel.model.OnExceptionDefinition;
import org.apache.camel.model.RouteConfigurationDefinition;
@@ -31,9 +35,14 @@ import org.apache.camel.model.rest.RestDefinition;
import org.apache.camel.model.rest.VerbDefinition;
import org.apache.camel.spi.CamelContextCustomizer;
import org.apache.camel.spi.annotations.RoutesLoader;
+import org.snakeyaml.engine.v2.nodes.MappingNode;
import org.snakeyaml.engine.v2.nodes.Node;
+import org.snakeyaml.engine.v2.nodes.NodeTuple;
+import org.snakeyaml.engine.v2.nodes.NodeType;
import static
org.apache.camel.dsl.yaml.common.YamlDeserializerSupport.asSequenceNode;
+import static org.apache.camel.dsl.yaml.common.YamlDeserializerSupport.asText;
+import static org.apache.camel.dsl.yaml.common.YamlDeserializerSupport.nodeAt;
@ManagedResource(description = "Managed YAML RoutesBuilderLoader")
@RoutesLoader(YamlRoutesBuilderLoader.EXTENSION)
@@ -48,7 +57,9 @@ public class YamlRoutesBuilderLoader extends
YamlRoutesBuilderLoaderSupport {
return new RouteConfigurationBuilder() {
@Override
public void configure() throws Exception {
-for (Node node : asSequenceNode(root).getValue()) {
+Node target = preConfigureNode(root);
+
+for (Node node : asSequenceNode(target).getValue()) {
Object item =
getDeserializationContext().mandatoryResolve(node).construct(node);
if (item instanceof OutputAwareFromDefinition) {
@@ -96,7 +107,9 @@ public class YamlRoutesBuilderLoader extends
YamlRoutesBuilderLoaderSupport {
@Override
public void configuration() throws Exception {
-for (Node node : asSequenceNode(root).getValue()) {
+Node target = preConfigureNode(root);
+
+for (Node node : asSequenceNode(target).getValue()) {
Object item =
getDeserializationContext().mandatoryResolve(node).construct(node);
if (item instanceof RouteConfigurationDefinition) {
CamelContextAware.trySetCamelContext(getRouteConfigurationCollection(),
getCamelContext());
@@ -107,4 +120,40 @@ public class YamlRoutesBuilderLoader extends
YamlRoutesBuilderLoaderSupport {
};
}
+private static Node preConfigureNode(Node root) {
+Node target = root;
+
+// check if the yaml is a camel-k yaml with embedded routes (called
[camel] 01/02: Polished
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit b09522e199455f843d9d53ababcddc07f603f304
Author: Claus Ibsen
AuthorDate: Sat Oct 30 13:58:05 2021 +0200
Polished
---
.../main/java/org/apache/camel/main/KameletDependencyDownloader.java| 2 --
1 file changed, 2 deletions(-)
diff --git
a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/KameletDependencyDownloader.java
b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/KameletDependencyDownloader.java
index 1fb3d04..59d7aa9 100644
---
a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/KameletDependencyDownloader.java
+++
b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/KameletDependencyDownloader.java
@@ -26,7 +26,6 @@ import java.util.Map;
import java.util.Set;
import groovy.grape.Grape;
-import groovy.lang.GroovyClassLoader;
import org.apache.camel.CamelContext;
import org.apache.camel.CamelContextAware;
import org.apache.camel.builder.RouteBuilder;
@@ -51,7 +50,6 @@ public class KameletDependencyDownloader extends
YamlRoutesBuilderLoaderSupport
private CamelContext camelContext;
private final String cp = System.getProperty("java.class.path");
private final Set downloaded = new HashSet<>();
-private GroovyClassLoader groovyClassLoader;
public KameletDependencyDownloader(String extension) {
super(extension);
[camel] branch regen_bot updated (f80ec9f -> 5c0d97b)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch regen_bot
in repository https://gitbox.apache.org/repos/asf/camel.git.
from f80ec9f CAMEL-17149: camel-main - Binding beans should allow to refer
to other beans in the constructor parameters
add b8ccc32 CAMEL-16861: Cleanup docs
add 3052960 CAMEL-16861: Cleanup docs
add 5c0d97b CAMEL-16861: Cleanup docs
No new revisions were added by this update.
Summary of changes:
docs/user-manual-nav.adoc.template | 2 +-
docs/user-manual/modules/ROOT/nav.adoc | 2 +-
...configuration-of-camelcontext-using-spring.adoc | 125 ++---
...{backlogdebugger.adoc => backlog-debugger.adoc} | 3 -
.../modules/ROOT/pages/batch-consumer.adoc | 29 ++---
.../modules/ROOT/pages/bean-binding.adoc | 21 +---
.../modules/ROOT/pages/bean-injection.adoc | 1 -
.../modules/ROOT/pages/bean-integration.adoc | 8 +-
.../modules/ROOT/pages/browsable-endpoint.adoc | 4 +-
docs/user-manual/modules/ROOT/pages/building.adoc | 14 +--
docs/user-manual/modules/ROOT/pages/index.adoc | 2 +-
11 files changed, 69 insertions(+), 142 deletions(-)
rename docs/user-manual/modules/ROOT/pages/{backlogdebugger.adoc =>
backlog-debugger.adoc} (97%)
[camel] branch regen_bot updated (cf3b5c2 -> f80ec9f)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch regen_bot
in repository https://gitbox.apache.org/repos/asf/camel.git.
from cf3b5c2 Polished
add d00d4c3 CAMEL-17135: camel-debezium - Fixed configuration component
level options not working correctly.
add f80ec9f CAMEL-17149: camel-main - Binding beans should allow to refer
to other beans in the constructor parameters
No new revisions were added by this update.
Summary of changes:
.../component/debezium/DebeziumComponent.java | 3 +-
.../EmbeddedDebeziumConfiguration.java | 15 -
.../debezium/DebeziumMongodbComponent.java | 7 +
.../debezium/DebeziumMongodbComponentTest.java | 36 --
.../component/debezium/DebeziumMySqlComponent.java | 7 +
.../debezium/DebeziumMySqlComponentTest.java | 35 -
.../debezium/DebeziumPostgresComponent.java| 7 +
.../debezium/DebeziumPostgresComponentTest.java| 34
.../debezium/DebeziumSqlserverComponent.java | 8 ++---
.../debezium/DebeziumSqlserverComponentTest.java | 34
.../java/org/apache/camel/main/MyAddress.java} | 21 ++---
...ctorTest.java => MainBeansConstructorTest.java} | 29 +++--
.../apache/camel/main/{MyFoo.java => MyOrder.java} | 21 ++---
.../camel/support/PropertyBindingSupport.java | 15 -
14 files changed, 66 insertions(+), 206 deletions(-)
copy core/camel-main/src/{test/java/org/apache/camel/main/MyFoo.java =>
generated/java/org/apache/camel/main/MyAddress.java} (75%)
copy
core/camel-main/src/test/java/org/apache/camel/main/{MainRoutesCollectorTest.java
=> MainBeansConstructorTest.java} (61%)
copy core/camel-main/src/test/java/org/apache/camel/main/{MyFoo.java =>
MyOrder.java} (72%)
[camel] 03/03: CAMEL-16861: Cleanup docs
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git commit 5c0d97ba5ba9464d490ce47a0ceff63fba588e50 Author: Claus Ibsen AuthorDate: Sat Oct 30 11:37:39 2021 +0200 CAMEL-16861: Cleanup docs --- .../modules/ROOT/pages/batch-consumer.adoc | 29 +++--- .../modules/ROOT/pages/bean-binding.adoc | 21 +--- .../modules/ROOT/pages/bean-injection.adoc | 1 - .../modules/ROOT/pages/bean-integration.adoc | 8 +++--- .../modules/ROOT/pages/browsable-endpoint.adoc | 4 +-- docs/user-manual/modules/ROOT/pages/building.adoc | 14 ++- 6 files changed, 29 insertions(+), 48 deletions(-) diff --git a/docs/user-manual/modules/ROOT/pages/batch-consumer.adoc b/docs/user-manual/modules/ROOT/pages/batch-consumer.adoc index 0d98102..c373887 100644 --- a/docs/user-manual/modules/ROOT/pages/batch-consumer.adoc +++ b/docs/user-manual/modules/ROOT/pages/batch-consumer.adoc @@ -8,34 +8,39 @@ To support batching the consumer must implement the `org.apache.camel.BatchConsu A range of Camel components support batching such as: +* xref:components::aws2-ddb-component.adoc[AWS2 DDB] +* xref:components::aws2-kinesis-component.adoc[AWS2 Kinesis] +* xref:components::aws2-s3-component.adoc[AWS2 S3] +* xref:components::aws2-sqs-component.adoc[AWS2 SQS] * xref:components::file-component.adoc[File] * xref:components::ftp-component.adoc[FTP] +* xref:components::ironmq-component.adoc[IronMQ] +* xref:components::jooq-component.adoc[Jooq] * xref:components::jpa-component.adoc[JPA] * xref:components::mail-component.adoc[Mail] +* xref:components::minio-component.adoc[Minio] * xref:components::mybatis-component.adoc[MyBatis] -* xref:components::snmp-component.adoc[SNMP] +* xref:components::slack-component.adoc[Slack] +* xref:components::splunk-component.adoc[Splunk] * xref:components::sql-component.adoc[SQL] -[[BatchConsumer-ConsumerOptions]] -== Consumer Options +== Options The `BatchConsumer` supports the following options: [width="100%",cols="20%,80%",options="header",] |=== |Option |Description - -|maxMessagesPerPoll |An integer to define a maximum messages to gather per poll. By default +|`maxMessagesPerPoll` |An integer to define a maximum messages to gather per poll. By default, no maximum is set. Can be used to set a limit of e.g. 1000 to avoid when starting up the server that there are thousands of files. Set a value of -0 or negative to disabled it. +0 or negative to disabled it as unlimited. |=== Very often a `BatchConsumer` is scheduled and is based of the `ScheduledBatchPollingConsumer` that has many options for configuring the scheduling. These options are listed with _(scheduler)_ as label in the endpoints options in the xref:components::index.adoc[Components] documentation. -[[BatchConsumer-ExchangeProperties]] == Exchange Properties The following properties is set on the Exchange for @@ -44,13 +49,9 @@ each Exchange polled in the same batch. [width="100%",cols="20%,80%",options="header",] |=== |Property |Description - -|CamelBatchSize |The total number of Exchanges that was polled in -this batch. - -|CamelBatchIndex |The current index of the batch. Starts from 0. - -|CamelBatchComplete |A boolean indicating the last Exchange in the batch. +|`CamelBatchSize` |The total number of Exchanges that was polled in this batch. +|`CamelBatchIndex` |The current index of the batch. Starts from 0. +|`CamelBatchComplete` |A boolean indicating the last Exchange in the batch. Is only `true` for the last entry. |=== diff --git a/docs/user-manual/modules/ROOT/pages/bean-binding.adoc b/docs/user-manual/modules/ROOT/pages/bean-binding.adoc index 6c1d022..4d2b08f 100644 --- a/docs/user-manual/modules/ROOT/pages/bean-binding.adoc +++ b/docs/user-manual/modules/ROOT/pages/bean-binding.adoc @@ -6,7 +6,6 @@ the method when it is invoked. NOTE: This requires to include `camel-bean` as dependency on the classpath. -[[BeanBinding-Choosingthemethodtoinvoke]] == Choosing the method to invoke The binding of a Camel xref:components:eips:message.adoc[Message] to a bean method call @@ -42,9 +41,8 @@ will be preferred since Camel can't invoke class methods on such beans In cases where Camel cannot choose a method to invoke, an `AmbiguousMethodCallException` is thrown. -By default the return value is set on the outbound message body. +By default, the return value is set on the outbound message body. -[[BeanBinding-Asynchronousprocessing]] == Asynchronous processing You can return a `CompletionStage` implementation (e.g. a
[camel] branch main updated (f80ec9f -> 5c0d97b)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git.
from f80ec9f CAMEL-17149: camel-main - Binding beans should allow to refer
to other beans in the constructor parameters
new b8ccc32 CAMEL-16861: Cleanup docs
new 3052960 CAMEL-16861: Cleanup docs
new 5c0d97b CAMEL-16861: Cleanup docs
The 3 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:
docs/user-manual-nav.adoc.template | 2 +-
docs/user-manual/modules/ROOT/nav.adoc | 2 +-
...configuration-of-camelcontext-using-spring.adoc | 125 ++---
...{backlogdebugger.adoc => backlog-debugger.adoc} | 3 -
.../modules/ROOT/pages/batch-consumer.adoc | 29 ++---
.../modules/ROOT/pages/bean-binding.adoc | 21 +---
.../modules/ROOT/pages/bean-injection.adoc | 1 -
.../modules/ROOT/pages/bean-integration.adoc | 8 +-
.../modules/ROOT/pages/browsable-endpoint.adoc | 4 +-
docs/user-manual/modules/ROOT/pages/building.adoc | 14 +--
docs/user-manual/modules/ROOT/pages/index.adoc | 2 +-
11 files changed, 69 insertions(+), 142 deletions(-)
rename docs/user-manual/modules/ROOT/pages/{backlogdebugger.adoc =>
backlog-debugger.adoc} (97%)
[camel] 01/03: CAMEL-16861: Cleanup docs
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git commit b8ccc328ad45c50a8a79d19a1838c971cf035df4 Author: Claus Ibsen AuthorDate: Sat Oct 30 11:20:36 2021 +0200 CAMEL-16861: Cleanup docs --- ...configuration-of-camelcontext-using-spring.adoc | 125 ++--- 1 file changed, 37 insertions(+), 88 deletions(-) diff --git a/docs/user-manual/modules/ROOT/pages/advanced-configuration-of-camelcontext-using-spring.adoc b/docs/user-manual/modules/ROOT/pages/advanced-configuration-of-camelcontext-using-spring.adoc index 690694f..4fea9fb 100644 --- a/docs/user-manual/modules/ROOT/pages/advanced-configuration-of-camelcontext-using-spring.adoc +++ b/docs/user-manual/modules/ROOT/pages/advanced-configuration-of-camelcontext-using-spring.adoc @@ -18,84 +18,36 @@ more than 1 bean of this type, then Camel will *not* use it. [width="100%",cols="34%,33%,33%",options="header",] |=== |Type |Number of beans |Description -|PackageScanClassResolver |0..1 |To use a 3rd party package scan -resolver. More details at xref:pluggable-class-resolvers.adoc[Pluggable -Class Resolvers]. - -|ClassResolver |0..1 |To use a 3rd party class resolver. More details at -xref:pluggable-class-resolvers.adoc[Pluggable Class Resolvers]. - -|FactoryFinderResolver |0..1 |To use a 3rd party factory finder. - -|Registry |0..1 |To use a 3rd party bean registry. By default Camel will -use Spring ApplicationContext (when using Spring) as registry. - -|Debugger |0..1 |To use a xref:debugger.adoc[Debugger] usually for -tooling. - -|Tracer |0..1 |To use a 3rd party xref:tracer.adoc[Tracer]. - -|TraceFormatter |0..1 |To use a bean that has the tracing options -configured. - +|AsyncProcessorAwaitManager |0..1 |To use a 3rd part async process await manager. +|BacklogTracer |0..1 |To use a 3rd party xref:backlog-tracer.adoc[BacklogTracer]. +|ClassResolver |0..1 |To use a 3rd party class resolver. More details at xref:pluggable-class-resolvers.adoc[Pluggable Class Resolvers]. +|Debugger |0..1 |To use a xref:debugger.adoc[Debugger] usually for tooling. |Delayer |0..1 |To use a 3rd part xref:components:eips:delay-eip.adoc[Delayer]. - -|ManagementStrategy |0..1 |To use a 3rd part strategy for -xref:jmx.adoc[management], for example JMX management. - -|ManagementNamingStrategy |0..1 |To use a 3rd part strategy -for naming MBeans for xref:jmx.adoc[management]. - -|NodeIdFactory |0..1 |To use a 3rd part node id factory. - |EventFactory |0..1 |To use a 3rd part event factory. - -|EventNotifier |0..1 |To use a 3rd part event notifier. In -Camel 2.2 onwards you can have multiple notifiers, see next table. - -|InflightRepository |0..1 |To use a 3rd part inflight -repository. - -|ShutdownStrategy |0..1 |To use a 3rd part shutdown -strategy. - -|ExecutorServiceStrategy |0..1 |To use a 3rd part -executor service strategy. More details at -xref:threading-model.adoc[Threading Model]. - -|ExecutorServiceManager |0..1 |To use a 3rd part executor -service manager. More details at xref:threading-model.adoc[Threading -Model]. - -|ThreadPoolFactory |0..1 |To use a 3rd part thread pool -factory. More details at xref:threading-model.adoc[Threading Model]. - -|ProcessorFactory |0..1 |To use a 3rd part processor -factory. - -|UuidGenerator |0..1 |To use a 3rd part -xref:uuidgenerator.adoc[UuidGenerator]. - -|StreamCachingStrategy |0..1 |To use a 3rd part -xref:stream-caching.adoc[Stream caching] strategy. - -|UnitOfWorkFactory |0..1 |To use 3rd part -`UnitOfWork` implementations created by the factory. - -|RuntimeEndpointRegistry |0..1 |To use a 3rd party -RuntimeEndpointRegistry implementation. - -|Logger |0..1 |To use provided org.slf4j.Logger -for xref:components::log-component.adoc[Log] component and xref:components:eips:log-eip.adoc[log() EIP]. - -|AsyncProcessorAwaitManager |0..1 |To use a 3rd part async -process await manager. - -|ModelJAXBContextFactory |0..1 |To use a 3rd party model -JAXB ContextFactory - -|MessageHistoryFactory |0..1 |To use a 3rd party -MessageHistoryFactory implementation. +|ExecutorServiceManager |0..1 |To use a 3rd part executor service manager. More details at xref:threading-model.adoc[Threading Model]. +|ExecutorServiceStrategy |0..1 |To use a 3rd part executor service strategy. More details at xref:threading-model.adoc[Threading Model]. +|FactoryFinderResolver |0..1 |To use a 3rd party factory finder. +|HeadersMapFactory |0..1|To use a 3rd party HeadersMapFactory implementation. +|HealthCheckRegistry |0..1|To use a 3rd party xref:health-check.adoc[HealthCheckRegistry] implementation. +|InflightRepository |0..1 |To use a 3rd part inflight repository. +|Logger |0..1 |To use provided org.slf4j.Logger for xref:components::log-component.adoc[Log] component and xref:components:eips:log-eip.adoc[log() EIP]. +|ManagementObjectNameStrategy
[camel] 02/03: CAMEL-16861: Cleanup docs
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 30529605e044d687113d476263eef9d59afd6414
Author: Claus Ibsen
AuthorDate: Sat Oct 30 11:22:42 2021 +0200
CAMEL-16861: Cleanup docs
---
docs/user-manual-nav.adoc.template | 2 +-
docs/user-manual/modules/ROOT/nav.adoc | 2 +-
.../modules/ROOT/pages/{backlogdebugger.adoc => backlog-debugger.adoc} | 3 ---
docs/user-manual/modules/ROOT/pages/index.adoc | 2 +-
4 files changed, 3 insertions(+), 6 deletions(-)
diff --git a/docs/user-manual-nav.adoc.template
b/docs/user-manual-nav.adoc.template
index 137dcf1..3a39b74 100644
--- a/docs/user-manual-nav.adoc.template
+++ b/docs/user-manual-nav.adoc.template
@@ -6,7 +6,7 @@
* xref:architecture.adoc[Architecture]
** xref:async.adoc[Async]
** xref:asynchronous-routing-engine.adoc[Asynchronous Routing Engine]
- ** xref:backlogdebugger.adoc[Backlog debugger]
+ ** xref:backlog-debugger.adoc[Backlog debugger]
** xref:bam.adoc[Business Activity Monitoring]
** xref:batch-consumer.adoc[Batch Consumer]
** xref:browsable-endpoint.adoc[BrowsableEndpoint]
diff --git a/docs/user-manual/modules/ROOT/nav.adoc
b/docs/user-manual/modules/ROOT/nav.adoc
index 09371a7..d842afb 100644
--- a/docs/user-manual/modules/ROOT/nav.adoc
+++ b/docs/user-manual/modules/ROOT/nav.adoc
@@ -28,7 +28,7 @@
** xref:camel-3-migration-guide.adoc[Camel 2.x to 3.0 Migration Guide]
** xref:camel-3x-upgrade-guide.adoc[Camel 3.x Upgrade Guide]
* xref:architecture.adoc[Architecture]
-** xref:backlogdebugger.adoc[Backlog debugger]
+** xref:backlog-debugger.adoc[Backlog debugger]
** xref:backlog-tracer.adoc[Backlog Tracer]
** xref:batch-consumer.adoc[Batch Consumer]
** xref:bean-binding.adoc[Bean Binding]
diff --git a/docs/user-manual/modules/ROOT/pages/backlogdebugger.adoc
b/docs/user-manual/modules/ROOT/pages/backlog-debugger.adoc
similarity index 97%
rename from docs/user-manual/modules/ROOT/pages/backlogdebugger.adoc
rename to docs/user-manual/modules/ROOT/pages/backlog-debugger.adoc
index 17c0d4b..d1ec1f8 100644
--- a/docs/user-manual/modules/ROOT/pages/backlogdebugger.adoc
+++ b/docs/user-manual/modules/ROOT/pages/backlog-debugger.adoc
@@ -14,7 +14,6 @@ You can enable or disable the BacklogDebugger dynamically, by
calling
NOTE: This requires to enabled JMX by including `camel-management` JAR in the
classpath.
-[[BacklogDebugger-Options]]
== Options
[width="100%",cols="10%,20%,70%",options="header",]
@@ -37,7 +36,6 @@ Stream Caching.
is that the file content has to be read from the file.
|===
-[[BacklogDebugger-Operations]]
== Operations
[width="100%",cols="10%,20%,70%",options="header",]
@@ -90,7 +88,6 @@ Exchange at the node.
A timeout used for waiting for a message to arrive at a given breakpoint. `
|===
-[[BacklogDebugger-Enabling]]
== Enabling
You would need to enable this using the JMX API.
diff --git a/docs/user-manual/modules/ROOT/pages/index.adoc
b/docs/user-manual/modules/ROOT/pages/index.adoc
index 0ec0b5e..828ce11 100644
--- a/docs/user-manual/modules/ROOT/pages/index.adoc
+++ b/docs/user-manual/modules/ROOT/pages/index.adoc
@@ -65,7 +65,7 @@ For a deeper and better understanding of Apache Camel, an
xref:faq:what-is-camel
=== xref:architecture.adoc[Architecture]
-* xref:backlogdebugger.adoc[BacklogDebugger]
+* xref:backlog-debugger.adoc[BacklogDebugger]
* xref:backlog-tracer.adoc[BacklogTracer]
* xref:batch-consumer.adoc[Batch Consumer]
* xref:browsable-endpoint.adoc[BrowsableEndpoint]
[camel] branch regen_bot updated (d00d4c3 -> cf3b5c2)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. omit d00d4c3 CAMEL-17135: camel-debezium - Fixed configuration component level options not working correctly. This update removed existing revisions from the reference, leaving the reference pointing at a previous point in the repository history. * -- * -- N refs/heads/regen_bot (cf3b5c2) \ O -- O -- O (d00d4c3) Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: .../component/debezium/DebeziumComponent.java | 3 +- .../EmbeddedDebeziumConfiguration.java | 15 + .../debezium/DebeziumMongodbComponent.java | 7 - .../debezium/DebeziumMongodbComponentTest.java | 36 ++ .../component/debezium/DebeziumMySqlComponent.java | 7 - .../debezium/DebeziumMySqlComponentTest.java | 35 + .../debezium/DebeziumPostgresComponent.java| 7 - .../debezium/DebeziumPostgresComponentTest.java| 34 .../debezium/DebeziumSqlserverComponent.java | 8 +++-- .../debezium/DebeziumSqlserverComponentTest.java | 34 10 files changed, 165 insertions(+), 21 deletions(-)
[camel] branch regen_bot updated (87d3211 -> d00d4c3)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from 87d3211 Regen for commit a73696fac26abd9681dd3574202b2f52714e4fe7 (#6352) add cf3b5c2 Polished add d00d4c3 CAMEL-17135: camel-debezium - Fixed configuration component level options not working correctly. No new revisions were added by this update. Summary of changes: .../component/debezium/DebeziumComponent.java | 3 +- .../EmbeddedDebeziumConfiguration.java | 15 - .../debezium/DebeziumMongodbComponent.java | 7 + .../debezium/DebeziumMongodbComponentTest.java | 36 -- .../component/debezium/DebeziumMySqlComponent.java | 7 + .../debezium/DebeziumMySqlComponentTest.java | 35 - .../debezium/DebeziumPostgresComponent.java| 7 + .../debezium/DebeziumPostgresComponentTest.java| 34 .../debezium/DebeziumSqlserverComponent.java | 8 ++--- .../debezium/DebeziumSqlserverComponentTest.java | 34 .../DefaultScheduledPollConsumerScheduler.java | 2 +- 11 files changed, 22 insertions(+), 166 deletions(-)
[camel] branch main updated: CAMEL-17149: camel-main - Binding beans should allow to refer to other beans in the constructor parameters
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new f80ec9f CAMEL-17149: camel-main - Binding beans should allow to refer
to other beans in the constructor parameters
f80ec9f is described below
commit f80ec9f616aa21b00b8b61cffdc264cde69f3ca9
Author: Claus Ibsen
AuthorDate: Sat Oct 30 10:56:36 2021 +0200
CAMEL-17149: camel-main - Binding beans should allow to refer to other
beans in the constructor parameters
---
.../java/org/apache/camel/main/MyAddress.java | 36
.../camel/main/MainBeansConstructorTest.java | 49 ++
.../test/java/org/apache/camel/main/MyOrder.java | 36
.../camel/support/PropertyBindingSupport.java | 15 ++-
4 files changed, 135 insertions(+), 1 deletion(-)
diff --git
a/core/camel-main/src/generated/java/org/apache/camel/main/MyAddress.java
b/core/camel-main/src/generated/java/org/apache/camel/main/MyAddress.java
new file mode 100644
index 000..e0f59d8
--- /dev/null
+++ b/core/camel-main/src/generated/java/org/apache/camel/main/MyAddress.java
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.main;
+
+public class MyAddress {
+
+private int zip;
+private String street;
+
+public MyAddress(int zip, String street) {
+this.zip = zip;
+this.street = street;
+}
+
+public int getZip() {
+return zip;
+}
+
+public String getStreet() {
+return street;
+}
+}
diff --git
a/core/camel-main/src/test/java/org/apache/camel/main/MainBeansConstructorTest.java
b/core/camel-main/src/test/java/org/apache/camel/main/MainBeansConstructorTest.java
new file mode 100644
index 000..bdadb3f
--- /dev/null
+++
b/core/camel-main/src/test/java/org/apache/camel/main/MainBeansConstructorTest.java
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.main;
+
+import org.apache.camel.CamelContext;
+import org.junit.jupiter.api.Test;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+
+public class MainBeansConstructorTest {
+
+@Test
+public void testBindBeans() throws Exception {
+Main main = new Main();
+// create by class
+main.addProperty("camel.beans.address",
"#class:org.apache.camel.main.MyAddress(90210, 'Somestreet 123')");
+main.addProperty("camel.beans.order",
"#class:org.apache.camel.main.MyOrder('Acme', #bean:address)");
+// start
+main.start();
+
+CamelContext camelContext = main.getCamelContext();
+assertNotNull(camelContext);
+
+MyOrder order =
camelContext.getRegistry().lookupByNameAndType("order", MyOrder.class);
+assertNotNull(order);
+
+assertEquals("Acme", order.getCompany());
+assertEquals(90210, order.getAddress().getZip());
+assertEquals("Somestreet 123", order.getAddress().getStreet());
+
+main.stop();
+}
+
+}
diff --git a/core/camel-main/src/test/java/org/apache/camel/main/MyOrder.java
b/core/camel-main/src/test/java/org/apache/camel/main/MyOrder.java
new file mode 100644
index 000..376d08b
--- /dev/null
+++
[camel] branch camel-3.11.x updated: CAMEL-17135: camel-debezium - Fixed configuration component level options not working correctly.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-3.11.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-3.11.x by this push:
new 34b2b14 CAMEL-17135: camel-debezium - Fixed configuration component
level options not working correctly.
34b2b14 is described below
commit 34b2b1463b592c7975e861d5053d18920630619b
Author: Claus Ibsen
AuthorDate: Sat Oct 30 10:27:04 2021 +0200
CAMEL-17135: camel-debezium - Fixed configuration component level options
not working correctly.
---
.../component/debezium/DebeziumComponent.java | 3 +-
.../EmbeddedDebeziumConfiguration.java | 15 -
.../debezium/DebeziumMongodbComponent.java | 7 +
.../debezium/DebeziumMongodbComponentTest.java | 36 --
.../component/debezium/DebeziumMySqlComponent.java | 7 +
.../debezium/DebeziumMySqlComponentTest.java | 35 -
.../debezium/DebeziumPostgresComponent.java| 7 +
.../debezium/DebeziumPostgresComponentTest.java| 34
.../debezium/DebeziumSqlserverComponent.java | 8 ++---
.../debezium/DebeziumSqlserverComponentTest.java | 34
10 files changed, 21 insertions(+), 165 deletions(-)
diff --git
a/components/camel-debezium/camel-debezium-common/camel-debezium-common-component/src/main/java/org/apache/camel/component/debezium/DebeziumComponent.java
b/components/camel-debezium/camel-debezium-common/camel-debezium-common-component/src/main/java/org/apache/camel/component/debezium/DebeziumComponent.java
index 12d9e4f..1094995 100644
---
a/components/camel-debezium/camel-debezium-common/camel-debezium-common-component/src/main/java/org/apache/camel/component/debezium/DebeziumComponent.java
+++
b/components/camel-debezium/camel-debezium-common/camel-debezium-common-component/src/main/java/org/apache/camel/component/debezium/DebeziumComponent.java
@@ -41,7 +41,8 @@ public abstract class DebeziumComponent
@Override
protected DebeziumEndpoint createEndpoint(String uri, String remaining,
Map parameters)
throws Exception {
-final C configuration = getConfiguration();
+// use a copy on the endpoint
+final C configuration = (C) getConfiguration().copy();
if (ObjectHelper.isEmpty(remaining) &&
ObjectHelper.isEmpty(configuration.getName())) {
throw new IllegalArgumentException(
diff --git
a/components/camel-debezium/camel-debezium-common/camel-debezium-common-component/src/main/java/org/apache/camel/component/debezium/configuration/EmbeddedDebeziumConfiguration.java
b/components/camel-debezium/camel-debezium-common/camel-debezium-common-component/src/main/java/org/apache/camel/component/debezium/configuration/EmbeddedDebeziumConfiguration.java
index fea2a4f..a0f4bf2 100644
---
a/components/camel-debezium/camel-debezium-common/camel-debezium-common-component/src/main/java/org/apache/camel/component/debezium/configuration/EmbeddedDebeziumConfiguration.java
+++
b/components/camel-debezium/camel-debezium-common/camel-debezium-common-component/src/main/java/org/apache/camel/component/debezium/configuration/EmbeddedDebeziumConfiguration.java
@@ -23,6 +23,7 @@ import io.debezium.config.Configuration;
import io.debezium.config.Field;
import io.debezium.embedded.EmbeddedEngine;
import io.debezium.engine.spi.OffsetCommitPolicy;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.component.debezium.DebeziumConstants;
import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriParam;
@@ -32,7 +33,7 @@ import org.apache.camel.util.ObjectHelper;
import org.apache.kafka.connect.json.JsonConverter;
@UriParams
-public abstract class EmbeddedDebeziumConfiguration {
+public abstract class EmbeddedDebeziumConfiguration implements Cloneable {
private static final String LABEL_NAME = "consumer";
@@ -105,6 +106,18 @@ public abstract class EmbeddedDebeziumConfiguration {
this.connectorClass = configureConnectorClass();
}
+public Object copy() {
+try {
+EmbeddedDebeziumConfiguration answer =
(EmbeddedDebeziumConfiguration) clone();
+// make sure the map is copied in its own instance
+Map additionalPropertiesCopy = new
HashMap<>(additionalProperties);
+answer.setAdditionalProperties(additionalPropertiesCopy);
+return answer;
+} catch (CloneNotSupportedException e) {
+throw new RuntimeCamelException(e);
+}
+}
+
/**
* Configure the Debezium connector class that is supported by Debezium
*
diff --git
a/components/camel-debezium/camel-debezium-mongodb/src/main/java/org/apache/camel/component/debezium/DebeziumMongodbComponent.java
[camel] branch main updated: CAMEL-17135: camel-debezium - Fixed configuration component level options not working correctly.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new d00d4c3 CAMEL-17135: camel-debezium - Fixed configuration component
level options not working correctly.
d00d4c3 is described below
commit d00d4c32c70b0ebf850cb7f8a340f317c392fea8
Author: Claus Ibsen
AuthorDate: Sat Oct 30 10:27:04 2021 +0200
CAMEL-17135: camel-debezium - Fixed configuration component level options
not working correctly.
---
.../component/debezium/DebeziumComponent.java | 3 +-
.../EmbeddedDebeziumConfiguration.java | 15 -
.../debezium/DebeziumMongodbComponent.java | 7 +
.../debezium/DebeziumMongodbComponentTest.java | 36 --
.../component/debezium/DebeziumMySqlComponent.java | 7 +
.../debezium/DebeziumMySqlComponentTest.java | 35 -
.../debezium/DebeziumPostgresComponent.java| 7 +
.../debezium/DebeziumPostgresComponentTest.java| 34
.../debezium/DebeziumSqlserverComponent.java | 8 ++---
.../debezium/DebeziumSqlserverComponentTest.java | 34
10 files changed, 21 insertions(+), 165 deletions(-)
diff --git
a/components/camel-debezium/camel-debezium-common/camel-debezium-common-component/src/main/java/org/apache/camel/component/debezium/DebeziumComponent.java
b/components/camel-debezium/camel-debezium-common/camel-debezium-common-component/src/main/java/org/apache/camel/component/debezium/DebeziumComponent.java
index 12d9e4f..1094995 100644
---
a/components/camel-debezium/camel-debezium-common/camel-debezium-common-component/src/main/java/org/apache/camel/component/debezium/DebeziumComponent.java
+++
b/components/camel-debezium/camel-debezium-common/camel-debezium-common-component/src/main/java/org/apache/camel/component/debezium/DebeziumComponent.java
@@ -41,7 +41,8 @@ public abstract class DebeziumComponent
@Override
protected DebeziumEndpoint createEndpoint(String uri, String remaining,
Map parameters)
throws Exception {
-final C configuration = getConfiguration();
+// use a copy on the endpoint
+final C configuration = (C) getConfiguration().copy();
if (ObjectHelper.isEmpty(remaining) &&
ObjectHelper.isEmpty(configuration.getName())) {
throw new IllegalArgumentException(
diff --git
a/components/camel-debezium/camel-debezium-common/camel-debezium-common-component/src/main/java/org/apache/camel/component/debezium/configuration/EmbeddedDebeziumConfiguration.java
b/components/camel-debezium/camel-debezium-common/camel-debezium-common-component/src/main/java/org/apache/camel/component/debezium/configuration/EmbeddedDebeziumConfiguration.java
index 35fc1b3..453cff7 100644
---
a/components/camel-debezium/camel-debezium-common/camel-debezium-common-component/src/main/java/org/apache/camel/component/debezium/configuration/EmbeddedDebeziumConfiguration.java
+++
b/components/camel-debezium/camel-debezium-common/camel-debezium-common-component/src/main/java/org/apache/camel/component/debezium/configuration/EmbeddedDebeziumConfiguration.java
@@ -23,6 +23,7 @@ import io.debezium.config.Configuration;
import io.debezium.config.Field;
import io.debezium.embedded.EmbeddedEngine;
import io.debezium.engine.spi.OffsetCommitPolicy;
+import org.apache.camel.RuntimeCamelException;
import org.apache.camel.component.debezium.DebeziumConstants;
import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriParam;
@@ -32,7 +33,7 @@ import org.apache.camel.util.ObjectHelper;
import org.apache.kafka.connect.json.JsonConverter;
@UriParams
-public abstract class EmbeddedDebeziumConfiguration {
+public abstract class EmbeddedDebeziumConfiguration implements Cloneable {
private static final String LABEL_NAME = "consumer";
@@ -105,6 +106,18 @@ public abstract class EmbeddedDebeziumConfiguration {
this.connectorClass = configureConnectorClass();
}
+public Object copy() {
+try {
+EmbeddedDebeziumConfiguration answer =
(EmbeddedDebeziumConfiguration) clone();
+// make sure the map is copied in its own instance
+Map additionalPropertiesCopy = new
HashMap<>(additionalProperties);
+answer.setAdditionalProperties(additionalPropertiesCopy);
+return answer;
+} catch (CloneNotSupportedException e) {
+throw new RuntimeCamelException(e);
+}
+}
+
/**
* Configure the Debezium connector class that is supported by Debezium
*
diff --git
a/components/camel-debezium/camel-debezium-mongodb/src/main/java/org/apache/camel/component/debezium/DebeziumMongodbComponent.java
[camel-kamelets] branch regen_bot updated (cc8ba19 -> 87d4af8)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git. omit cc8ba19 Regen for commit 598dc1bce0ff65c94a7d7a653e744613a9acbee7 add 87d4af8 Regen for commit 598dc1bce0ff65c94a7d7a653e744613a9acbee7 (#555) This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (cc8ba19) \ N -- N -- N refs/heads/regen_bot (87d4af8) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes:
[GitHub] [camel-kamelets] davsclaus merged pull request #555: Generated sources regen
davsclaus merged pull request #555: URL: https://github.com/apache/camel-kamelets/pull/555 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-kamelets] branch main updated: Regen for commit 598dc1bce0ff65c94a7d7a653e744613a9acbee7 (#555)
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git The following commit(s) were added to refs/heads/main by this push: new 87d4af8 Regen for commit 598dc1bce0ff65c94a7d7a653e744613a9acbee7 (#555) 87d4af8 is described below commit 87d4af8973e765587a2a0ff5a40c62cd86609b19 Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Sat Oct 30 09:15:09 2021 +0200 Regen for commit 598dc1bce0ff65c94a7d7a653e744613a9acbee7 (#555) Signed-off-by: GitHub Co-authored-by: davsclaus --- .../src/main/resources/kamelets/mongodb-source.kamelet.yaml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/library/camel-kamelets/src/main/resources/kamelets/mongodb-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/mongodb-source.kamelet.yaml index 9b920b0..d9c164d 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/mongodb-source.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/kamelets/mongodb-source.kamelet.yaml @@ -43,7 +43,7 @@ spec: - urn:camel:group:credentials username: title: MongoDB Username -description: Username for accessing MongoDB. +description: Username for accessing MongoDB. The username must be present in the MongoDB's authentication database (authenticationDatabase). By default, the MongoDB authenticationDatabase is 'admin'. type: string x-descriptors: - urn:camel:group:credentials
[GitHub] [camel-kamelets] davsclaus closed issue #449: To-D doesn't work in a Kamelet
davsclaus closed issue #449: URL: https://github.com/apache/camel-kamelets/issues/449 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kamelets] github-actions[bot] opened a new pull request #555: Generated sources regen
github-actions[bot] opened a new pull request #555: URL: https://github.com/apache/camel-kamelets/pull/555 Regen bot :robot: found some uncommited changes after running build on :camel: kamelets main. Please do not delete `regen_bot` branch after merge/rebase. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-kamelets] branch regen_bot updated (8b91738 -> cc8ba19)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git. from 8b91738 Parameterize link to camel-k version. Fix the kamelets index page display add 598dc1b mongodb-source-kamelet decription update (#553) add cc8ba19 Regen for commit 598dc1bce0ff65c94a7d7a653e744613a9acbee7 No new revisions were added by this update. Summary of changes: .../src/main/resources/kamelets/mongodb-source.kamelet.yaml | 2 +- mongodb-source.kamelet.yaml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-)
[GitHub] [camel-kamelets] davsclaus merged pull request #553: mongodb-source-kamelet decription update
davsclaus merged pull request #553: URL: https://github.com/apache/camel-kamelets/pull/553 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-kamelets] branch main updated: mongodb-source-kamelet decription update (#553)
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git The following commit(s) were added to refs/heads/main by this push: new 598dc1b mongodb-source-kamelet decription update (#553) 598dc1b is described below commit 598dc1bce0ff65c94a7d7a653e744613a9acbee7 Author: Melissa Flinn <31925014+melissafl...@users.noreply.github.com> AuthorDate: Sat Oct 30 03:14:14 2021 -0400 mongodb-source-kamelet decription update (#553) --- mongodb-source.kamelet.yaml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mongodb-source.kamelet.yaml b/mongodb-source.kamelet.yaml index 9b920b0..d9c164d 100644 --- a/mongodb-source.kamelet.yaml +++ b/mongodb-source.kamelet.yaml @@ -43,7 +43,7 @@ spec: - urn:camel:group:credentials username: title: MongoDB Username -description: Username for accessing MongoDB. +description: Username for accessing MongoDB. The username must be present in the MongoDB's authentication database (authenticationDatabase). By default, the MongoDB authenticationDatabase is 'admin'. type: string x-descriptors: - urn:camel:group:credentials
[GitHub] [camel-kamelets] davsclaus commented on issue #554: Do not use kamelet-reify anymore
davsclaus commented on issue #554: URL: https://github.com/apache/camel-kamelets/issues/554#issuecomment-955163818 salesforce-source.kamelet.yaml infinispan-source.kamelet.yaml elasticsearch-search-source.kamelet.yaml elasticsearch-index-sink.kamelet.yaml -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kamelets] davsclaus opened a new issue #554: Do not use kamelet-reify anymore
davsclaus opened a new issue #554: URL: https://github.com/apache/camel-kamelets/issues/554 This is deprecated and to be removed so we should migrate the kamelets that use this old way. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch main updated: Polished
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new cf3b5c2 Polished
cf3b5c2 is described below
commit cf3b5c2b47542339649a29fe0f4b91da5d7bdfac
Author: Claus Ibsen
AuthorDate: Sat Oct 30 09:10:17 2021 +0200
Polished
---
.../org/apache/camel/support/DefaultScheduledPollConsumerScheduler.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/core/camel-support/src/main/java/org/apache/camel/support/DefaultScheduledPollConsumerScheduler.java
b/core/camel-support/src/main/java/org/apache/camel/support/DefaultScheduledPollConsumerScheduler.java
index 3d77a6a..a3f67db 100644
---
a/core/camel-support/src/main/java/org/apache/camel/support/DefaultScheduledPollConsumerScheduler.java
+++
b/core/camel-support/src/main/java/org/apache/camel/support/DefaultScheduledPollConsumerScheduler.java
@@ -32,7 +32,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * Default {@link ScheduledBatchPollingConsumer}.
+ * The default scheduler for {@link ScheduledPollConsumer}.
*/
public class DefaultScheduledPollConsumerScheduler extends ServiceSupport
implements ScheduledPollConsumerScheduler {
[camel] branch regen_bot updated (f9b1961 -> 87d3211)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from f9b1961 Regen add 87d3211 Regen for commit a73696fac26abd9681dd3574202b2f52714e4fe7 (#6352) No new revisions were added by this update. Summary of changes:
[camel] branch regen_bot updated (3347c03 -> f9b1961)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. discard 3347c03 Regen for commit 6d24ee80f25df4d33ff02e4759e7be018dd5a0ee add f9b1961 Regen This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (3347c03) \ N -- N -- N refs/heads/regen_bot (f9b1961) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes:
[GitHub] [camel] github-actions[bot] closed pull request #6358: Generated sources regen
github-actions[bot] closed pull request #6358: URL: https://github.com/apache/camel/pull/6358 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch regen_bot updated (03c3b0a -> 3347c03)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. omit 03c3b0a Regen for commit a73696fac26abd9681dd3574202b2f52714e4fe7 add 6d24ee8 CAMEL-17121: converted mongodb-gridfs to the repeatable tasks (#6356) add 3347c03 Regen for commit 6d24ee80f25df4d33ff02e4759e7be018dd5a0ee This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (03c3b0a) \ N -- N -- N refs/heads/regen_bot (3347c03) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: .../component/mongodb/gridfs/GridFsConsumer.java | 179 - .../task/budget/IterationBoundedBudget.java| 12 +- 2 files changed, 111 insertions(+), 80 deletions(-)
[GitHub] [camel] github-actions[bot] opened a new pull request #6358: Generated sources regen
github-actions[bot] opened a new pull request #6358: URL: https://github.com/apache/camel/pull/6358 Regen bot :robot: found some uncommited changes after running build on :camel: main. Please do not delete `regen_bot` branch after merge/rebase. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
