[camel-spring-boot] branch main updated: Regen
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/main by this push:
new c600fa0 Regen
c600fa0 is described below
commit c600fa04807a975bc1c167110bf2a1631acccf65
Author: Andrea Cosentino
AuthorDate: Fri Jan 21 08:35:03 2022 +0100
Regen
---
.../catalog/components/elasticsearch-rest.json | 4 ++--
.../camel/springboot/catalog/components/kafka.json | 4 ++--
.../src/main/docs/elasticsearch-rest.json | 2 +-
.../ElasticsearchComponentConfiguration.java | 4 +++-
.../camel-kafka-starter/src/main/docs/kafka.json | 4 ++--
.../springboot/KafkaComponentConfiguration.java| 4 ++--
.../kafka/springboot/KafkaComponentConverter.java | 4 ++--
tooling/camel-spring-boot-dependencies/pom.xml | 26 +++---
8 files changed, 27 insertions(+), 25 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/elasticsearch-rest.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/elasticsearch-rest.json
index d1e4451..505f54f 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/elasticsearch-rest.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/elasticsearch-rest.json
@@ -29,7 +29,7 @@
"socketTimeout": { "kind": "property", "displayName": "Socket Timeout",
"group": "producer", "label": "", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": 3, "description": "The timeout in ms to wait before the
socket will timeout." },
"autowiredEnabled": { "kind": "property", "displayName": "Autowired
Enabled", "group": "advanced", "label": "advanced", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which t [...]
"client": { "kind": "property", "displayName": "Client", "group":
"advanced", "label": "advanced", "required": false, "type": "object",
"javaType": "org.elasticsearch.client.RestClient", "deprecated": false,
"autowired": true, "secret": false, "description": "To use an existing
configured Elasticsearch client, instead of creating a client per endpoint.
This allow to customize the client with specific settings." },
-"enableSniffer": { "kind": "property", "displayName": "Enable Sniffer",
"group": "advanced", "label": "advanced", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "description": "Enable automatically discover
nodes from a running Elasticsearch cluster" },
+"enableSniffer": { "kind": "property", "displayName": "Enable Sniffer",
"group": "advanced", "label": "advanced", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "description": "Enable automatically discover
nodes from a running Elasticsearch cluster. If this option is used in
conjunction with Spring Boot then it's managed by the Spring Boot configuration
(see: Disable Sniffer in Spring Boot)." },
"sniffAfterFailureDelay": { "kind": "property", "displayName": "Sniff
After Failure Delay", "group": "advanced", "label": "advanced", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 6, "description": "The delay of a
sniff execution scheduled after a failure (in milliseconds)" },
"snifferInterval": { "kind": "property", "displayName": "Sniffer
Interval", "group": "advanced", "label": "advanced", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 30, "description": "The interval between
consecutive ordinary sniff executions in milliseconds. Will be honoured when
sniffOnFailure is disabled or when there are no failures between consecutive
sniff executions" },
"enableSSL": { "kind": "property", "displayName": "Enable SSL", "group":
"security", "label": "security", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "description": "Enable SSL" },
@@ -51,7 +51,7 @@
"socketTimeout": { "kind": "parameter", "displayName": "Socket Timeout",
"group":
[camel] branch main updated: Upgrade JBPM to version 7.64.0.Final
This is an automated email from the ASF dual-hosted git repository. acosentino 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 3222600 Upgrade JBPM to version 7.64.0.Final 3222600 is described below commit 32226001019fc75b87b6c12f60e9b0f7e68b0cac Author: Andrea Cosentino AuthorDate: Fri Jan 21 08:01:34 2022 +0100 Upgrade JBPM to version 7.64.0.Final --- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parent/pom.xml b/parent/pom.xml index fc233ba..3f54d5f 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -294,7 +294,7 @@ 1.0.4 2.3.3 2.5.0 -7.63.0.Final +7.64.0.Final 2.0.0.Final 3.4.0.Final 1.4.10.Final
[camel] branch regen_bot updated (5eb49af -> e3ec714)
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 5eb49af CAMEL-17527: Polish the grammar of SyncPropertiesMojo's documentation (#6798) add e3ec714 Upgrade AWS SDK v2 to version 2.17.115 No new revisions were added by this update. Summary of changes: parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[GitHub] [camel-k] oscerd commented on pull request #2832: feat(builder): Add Maven Daemon support
oscerd commented on pull request #2832: URL: https://github.com/apache/camel-k/pull/2832#issuecomment-1018249857 I think we need to resume the work on this. -- 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-k-runtime] branch release-1.11.x created (now 47dbafd)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch release-1.11.x in repository https://gitbox.apache.org/repos/asf/camel-k-runtime.git. at 47dbafd [maven-release-plugin] prepare release camel-k-runtime-project-1.11.0 No new revisions were added by this update.
[camel-kamelets] branch 0.7.x created (now d5743eb)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch 0.7.x in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git. at d5743eb [maven-release-plugin] prepare release v0.7.0 No new revisions were added by this update.
[camel] branch regen_bot updated (ddfba2e -> 5eb49af)
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 ddfba2e [CAMEL-17526]camel-fhir: the serverUrl configuration on camel-fhir endpoint shouldn't be ignored (#6796) add 5eb49af CAMEL-17527: Polish the grammar of SyncPropertiesMojo's documentation (#6798) No new revisions were added by this update. Summary of changes: tooling/maven/sync-properties-maven-plugin/pom.xml | 2 +- .../apache/camel/maven/sync/properties/SyncPropertiesMojo.java | 10 +- 2 files changed, 6 insertions(+), 6 deletions(-)
[camel] branch regen_bot updated (5043d07 -> ddfba2e)
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 5043d07 Regen for commit d579f8a7b352c50fb355c67f9b7c5d739cb40ff3 add ddfba2e [CAMEL-17526]camel-fhir: the serverUrl configuration on camel-fhir endpoint shouldn't be ignored (#6796) No new revisions were added by this update. Summary of changes: .../apache/camel/component/fhir/FhirComponent.java | 8 +++-- .../apache/camel/component/fhir/FhirCreateIT.java | 38 -- 2 files changed, 42 insertions(+), 4 deletions(-)
[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-1018231751 Build fixed with: * Camel Quarkus Commit: 197bfbb47a55e168425429178a9004a8bf7c68ba * Quarkus Main Commit: 73ffc7ef7f8882f0ba49bb89d8f7bfbe233a5f82 * Link to build: https://github.com/apache/camel-quarkus/actions/runs/1726616347 -- 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] closed issue #2926: [CI] - Quarkus Main Branch Build Failure
github-actions[bot] closed issue #2926: URL: https://github.com/apache/camel-quarkus/issues/2926 -- 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-performance-tests] 02/04: Kafka to Mongo Exchange Pooling: Add camel-jbang route
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit 17047f67151d719337087abe4753e51a8b3060cb Author: Andrea Cosentino AuthorDate: Fri Jan 21 06:59:57 2022 +0100 Kafka to Mongo Exchange Pooling: Add camel-jbang route --- .../data/sources/camel-jbang-route.yaml| 33 ++ 1 file changed, 33 insertions(+) diff --git a/profiling/kafka/kafka-mongo-exchange-pooling/data/sources/camel-jbang-route.yaml b/profiling/kafka/kafka-mongo-exchange-pooling/data/sources/camel-jbang-route.yaml new file mode 100644 index 000..3a5fcfc --- /dev/null +++ b/profiling/kafka/kafka-mongo-exchange-pooling/data/sources/camel-jbang-route.yaml @@ -0,0 +1,33 @@ +# +# 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. +# + +- route: +from: + uri: "kamelet:kafka-not-secured-source" + parameters: +bootstrapServers: "localhost:9092" +topic: "testtopic" + steps: +- to: +uri: "kamelet:mongodb-sink" +parameters: + collection: "log" + database: "test" + hosts: "127.0.0.1" + username: "mongoadmin" + password: "secret" +
[camel-performance-tests] 04/04: Kafka to NATS: Add camel-jbang route
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit 1b1604fbe80dae0dcc350658b0ab6d00926b1e92 Author: Andrea Cosentino AuthorDate: Fri Jan 21 07:30:52 2022 +0100 Kafka to NATS: Add camel-jbang route --- .../kafka-nats/data/sources/camel-jbang-route.yaml | 30 ++ 1 file changed, 30 insertions(+) diff --git a/profiling/kafka/kafka-nats/data/sources/camel-jbang-route.yaml b/profiling/kafka/kafka-nats/data/sources/camel-jbang-route.yaml new file mode 100644 index 000..6934128 --- /dev/null +++ b/profiling/kafka/kafka-nats/data/sources/camel-jbang-route.yaml @@ -0,0 +1,30 @@ +# +# 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. +# + +- route: +from: + uri: "kamelet:kafka-not-secured-source" + parameters: +bootstrapServers: "localhost:9092" +topic: "testtopic" + steps: +- to: +uri: "kamelet:nats-sink" +parameters: + servers: "localhost:4222" + topic: "camel-kafka-connector" +
[GitHub] [camel-performance-tests] oscerd merged pull request #85: Added Camel-Jbang profiling examples
oscerd merged pull request #85: URL: https://github.com/apache/camel-performance-tests/pull/85 -- 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-performance-tests] oscerd opened a new pull request #85: Added Camel-Jbang profiling examples
oscerd opened a new pull request #85: URL: https://github.com/apache/camel-performance-tests/pull/85 Related to #81 -- 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-performance-tests] 03/04: Kafka to NATS: Added a camel-jbang section to the README
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit 2d5cb6a301b3ec313aeebe28badc197d64c482a0 Author: Andrea Cosentino AuthorDate: Fri Jan 21 07:29:38 2022 +0100 Kafka to NATS: Added a camel-jbang section to the README --- profiling/kafka/kafka-nats/README.md | 12 1 file changed, 12 insertions(+) diff --git a/profiling/kafka/kafka-nats/README.md b/profiling/kafka/kafka-nats/README.md index bb6c26a..1c17f9e 100644 --- a/profiling/kafka/kafka-nats/README.md +++ b/profiling/kafka/kafka-nats/README.md @@ -124,6 +124,18 @@ docker run --rm -ti \ In this case we are allocating 128 Mb Memory to the container and 0.25% cpus. +## Running this profiling example with Camel-Jbang + +You could also leveraging the camel-jbang module. From Camel 3.15.0 (still to be released) it will support the profiling feature. + +What you need to do is simply running this commands: + +```shell script +jbang -Dcamel.jbang.version=3.15.0-SNAPSHOT camel@apache/camel run --jfr-profile=profile data/sources/camel-jbang-route.yaml +``` + +You'll get at jfr recording file once the application will be stopped in your working directory. + ## HEAP Sizing In the pom you can also set a different Heap Size. The default is 64 Mb.
[camel-performance-tests] 01/04: Kafka to Mongo with Exchange Pooling: Added a camel-jbang section to the README
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit 2b98631cc2a0ff5836d90494b51fb860d8399383 Author: Andrea Cosentino AuthorDate: Fri Jan 21 06:58:34 2022 +0100 Kafka to Mongo with Exchange Pooling: Added a camel-jbang section to the README --- profiling/kafka/kafka-mongo-exchange-pooling/README.md | 12 1 file changed, 12 insertions(+) diff --git a/profiling/kafka/kafka-mongo-exchange-pooling/README.md b/profiling/kafka/kafka-mongo-exchange-pooling/README.md index ea22f2f..22d5d89 100644 --- a/profiling/kafka/kafka-mongo-exchange-pooling/README.md +++ b/profiling/kafka/kafka-mongo-exchange-pooling/README.md @@ -135,6 +135,18 @@ docker run --rm -ti \ In this case we are allocating 128 Mb Memory to the container and 0.25% cpus. +## Running this profiling example with Camel-Jbang + +You could also leveraging the camel-jbang module. From Camel 3.15.0 (still to be released) it will support the profiling feature. + +What you need to do is simply running this commands: + +```shell script +jbang -Dcamel.jbang.version=3.15.0-SNAPSHOT camel@apache/camel run --jfr-profile=profile data/sources/camel-jbang-route.yaml +``` + +You'll get at jfr recording file once the application will be stopped in your working directory. + ## HEAP Sizing In the pom you can also set a different Heap Size. The default is 64 Mb.
[camel-performance-tests] branch main updated (fa3c01d -> 1b1604f)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git.
from fa3c01d Kafka to Mongo: Add camel-jbang route
new 2b98631 Kafka to Mongo with Exchange Pooling: Added a camel-jbang
section to the README
new 17047f6 Kafka to Mongo Exchange Pooling: Add camel-jbang route
new 2d5cb6a Kafka to NATS: Added a camel-jbang section to the README
new 1b1604f Kafka to NATS: Add camel-jbang route
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:
profiling/kafka/kafka-mongo-exchange-pooling/README.md | 12
.../data/sources/camel-jbang-route.yaml | 0
profiling/kafka/kafka-nats/README.md | 12
.../data/sources/{routes.yaml => camel-jbang-route.yaml} | 12 ++--
4 files changed, 30 insertions(+), 6 deletions(-)
copy profiling/kafka/{kafka-mongo =>
kafka-mongo-exchange-pooling}/data/sources/camel-jbang-route.yaml (100%)
copy profiling/kafka/kafka-nats/data/sources/{routes.yaml =>
camel-jbang-route.yaml} (84%)
[camel-performance-tests] branch jbang2 created (now 2bf99c5)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch jbang2 in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git. at 2bf99c5 Kafka to NATS: Add camel-jbang route No new revisions were added by this update.
[GitHub] [camel-k] djencks commented on pull request #2899: WIP See #2898 Generate CRD API docs as AsciiDoc
djencks commented on pull request #2899: URL: https://github.com/apache/camel-k/pull/2899#issuecomment-1018228167 Preview at https://pr-761--camel.netlify.app/camel-k/next/apis/camel.html -- 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-website] github-actions[bot] commented on pull request #761: DO NOT MERGE PREVIEW ONLY preview of AsciiDoc crd API docs
github-actions[bot] commented on pull request #761: URL: https://github.com/apache/camel-website/pull/761#issuecomment-1018222986 Preview is available at https://pr-761--camel.netlify.app -- 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: Upgrade AWS SDK v2 to version 2.17.115
This is an automated email from the ASF dual-hosted git repository. acosentino 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 e3ec714 Upgrade AWS SDK v2 to version 2.17.115 e3ec714 is described below commit e3ec714c2bab632803b381409108f5d39150de84 Author: Andrea Cosentino AuthorDate: Fri Jan 21 06:52:12 2022 +0100 Upgrade AWS SDK v2 to version 2.17.115 --- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parent/pom.xml b/parent/pom.xml index 6c634f3..fc233ba 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -80,7 +80,7 @@ 1.11.0 1.11.0 4.1.1 -2.17.114 +2.17.115 2.6.1 1.2.14 2.13.1
[camel] branch main updated (ddfba2e -> 5eb49af)
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 ddfba2e [CAMEL-17526]camel-fhir: the serverUrl configuration on camel-fhir endpoint shouldn't be ignored (#6796) add 5eb49af CAMEL-17527: Polish the grammar of SyncPropertiesMojo's documentation (#6798) No new revisions were added by this update. Summary of changes: tooling/maven/sync-properties-maven-plugin/pom.xml | 2 +- .../apache/camel/maven/sync/properties/SyncPropertiesMojo.java | 10 +- 2 files changed, 6 insertions(+), 6 deletions(-)
[camel] branch main updated (5043d07 -> ddfba2e)
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 5043d07 Regen for commit d579f8a7b352c50fb355c67f9b7c5d739cb40ff3 add ddfba2e [CAMEL-17526]camel-fhir: the serverUrl configuration on camel-fhir endpoint shouldn't be ignored (#6796) No new revisions were added by this update. Summary of changes: .../apache/camel/component/fhir/FhirComponent.java | 8 +++-- .../apache/camel/component/fhir/FhirCreateIT.java | 38 -- 2 files changed, 42 insertions(+), 4 deletions(-)
[GitHub] [camel] davsclaus merged pull request #6798: CAMEL-17527: Polish the grammar of SyncPropertiesMojo's documentation
davsclaus merged pull request #6798: URL: https://github.com/apache/camel/pull/6798 -- 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] davsclaus merged pull request #6796: [CAMEL-17526]camel-fhir: the serverUrl configuration on camel-fhir en…
davsclaus merged pull request #6796: URL: https://github.com/apache/camel/pull/6796 -- 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] davsclaus commented on pull request #6795: CAMEL-17491: do not add context path to the paths of the operations.
davsclaus commented on pull request #6795: URL: https://github.com/apache/camel/pull/6795#issuecomment-1018206701 Can you add a note about this in the 3.15 upgrade doc - see under the root/docs folder -- 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-k] djencks opened a new pull request #2899: WIP See #2898 Generate CRD API docs as AsciiDoc
djencks opened a new pull request #2899: URL: https://github.com/apache/camel-k/pull/2899 See https://github.com/apache/camel-k/issues/2898. This presumably needs more work. - I forked the github.com/ahmetb/gen-crd-api-reference-docs to github.com/djencks/gen-crd-api-reference-docs. I plan to submit a PR but it would be great to get some code review, this is my first foray into go. - I changed how the generator is installed to use`go run`. I think this is a good idea in any case, it will work on any system and doesn't need WGET which I can't get to work on my mac. - The templates render OK but produce a lot of unneeded whitespace and the lack of indentation makes them hard to read. I expect to contribute AsciiDoc generating templates back upstream. -- 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-website] djencks opened a new pull request #761: DO NOT MERGE PREVIEW ONLY preview of AsciiDoc crd API docs
djencks opened a new pull request #761: URL: https://github.com/apache/camel-website/pull/761 See https://github.com/apache/camel-k/issues/2898 -- 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-k] djencks opened a new issue #2898: [Docs/Website] Generate API documentation as AsciiDoc rather than html
djencks opened a new issue #2898: URL: https://github.com/apache/camel-k/issues/2898 Currently the API documentation (e.g. https://camel.apache.org/camel-k/next/apis/camel.html) has no styling, is hard to understand for this reason, and doesn't fit in with the rest of the Antora docs. It turns out to be moderately easy to extend the generator to generate plain text compatible with AsciiDoc and to rewrite the templates to generate AsciiDoc, with much better results. -- 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-k] scodeman commented on issue #2499: `Kamel local` chokes on traits
scodeman commented on issue #2499: URL: https://github.com/apache/camel-k/issues/2499#issuecomment-1018133087 This issue should not be closed, as mentionned by @pilhuhn, the local build could print a warning but not abort -- 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-quarkus] 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-quarkus.git The following commit(s) were added to refs/heads/main by this push: new 1002e74 Updated CHANGELOG.md 1002e74 is described below commit 1002e74c8759ce189c8062fff8bd8a4c49a344bf Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Fri Jan 21 03:12:19 2022 + Updated CHANGELOG.md --- CHANGELOG.md | 4 1 file changed, 4 insertions(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index e14c53e..82dd2b9 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -6,14 +6,18 @@ **Closed issues:** +- java.lang.IllegalStateException: The stream has no active subscriptions smallrye-reactive-messaging-camel [\#3474](https://github.com/apache/camel-quarkus/issues/3474) +- Health check `CamelBeanBuildItem` should use the check id as the name [\#3470](https://github.com/apache/camel-quarkus/issues/3470) - Ban netty-all [\#3464](https://github.com/apache/camel-quarkus/issues/3464) - quarkus 2.6 - debezium mysql error [\#3463](https://github.com/apache/camel-quarkus/issues/3463) - aws2-quarkus-client Verify that no client except quarkus one is used during test [\#3447](https://github.com/apache/camel-quarkus/issues/3447) - \[Quarkus 2.7.0\] : CI : Found Banned Dependency: commons-logging:commons-logging [\#3421](https://github.com/apache/camel-quarkus/issues/3421) +- \[quarkus-main\]crypto test failure in native mode [\#3402](https://github.com/apache/camel-quarkus/issues/3402) - Refactor aws2-quarkus-client-ddb\(s3\) by copying files \(not duplicating\) [\#3236](https://github.com/apache/camel-quarkus/issues/3236) **Merged pull requests:** +- Avoid creating `CamelBeanBuildItem` for health checks if they are disabled [\#3475](https://github.com/apache/camel-quarkus/pull/3475) ([jamesnetherton](https://github.com/jamesnetherton)) - Upgrade Quarkus to 2.7.0.CR1 [\#3473](https://github.com/apache/camel-quarkus/pull/3473) ([jamesnetherton](https://github.com/jamesnetherton)) - Improve documentation on setting up the Salesforce developer account [\#3469](https://github.com/apache/camel-quarkus/pull/3469) ([zbendhiba](https://github.com/zbendhiba)) - Update Salesforce Integration tests to Salesforce API upgrade [\#3467](https://github.com/apache/camel-quarkus/pull/3467) ([zbendhiba](https://github.com/zbendhiba))
[camel-k] 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-k.git The following commit(s) were added to refs/heads/main by this push: new a1b0232 Updated CHANGELOG.md a1b0232 is described below commit a1b0232cbf4f0216cd5128bddc1901ae941402eb Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Fri Jan 21 03:09:47 2022 + Updated CHANGELOG.md --- CHANGELOG.md | 6 ++ 1 file changed, 6 insertions(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index 30d49e6..ecf6240 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -4,8 +4,14 @@ [Full Changelog](https://github.com/apache/camel-k/compare/v1.8.0...HEAD) +**Closed issues:** + +- Stale bot is setting issue `stale` where marked as `never-stale` [\#2893](https://github.com/apache/camel-k/issues/2893) +- camel-k-client binary is missing in the latest release assets [\#2892](https://github.com/apache/camel-k/issues/2892) + **Merged pull requests:** +- Update stale.yaml [\#2894](https://github.com/apache/camel-k/pull/2894) ([squakez](https://github.com/squakez)) - Fix \#2788: use kamelets 0.7.0 and align with new dir structure [\#2887](https://github.com/apache/camel-k/pull/2887) ([nicolaferraro](https://github.com/nicolaferraro)) - doc: add more details about installation on IKS/ICR [\#2882](https://github.com/apache/camel-k/pull/2882) ([tadayosi](https://github.com/tadayosi)) - fix: Install Kamelets as unstructured resources [\#2881](https://github.com/apache/camel-k/pull/2881) ([astefanutti](https://github.com/astefanutti))
[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-1018114893 The [camel-main](https://github.com/apache/camel-quarkus/tree/camel-main) branch build has failed: * Build ID: 1726215126-534-65c8ef3a-2daa-4db6-8852-28f5f6219b35 * Camel Quarkus Commit: e35c2c4e3cbc3e5a685fae34213eb2831e9ed51c * Camel Main Commit: 73ffc7ef7f8882f0ba49bb89d8f7bfbe233a5f82 * Link to build: https://github.com/apache/camel-quarkus/actions/runs/1726215126 -- 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] skepticoitusInteruptus opened a new pull request #6798: CAMEL-17527: Polish the grammar of SyncPropertiesMojo's documentation
skepticoitusInteruptus opened a new pull request #6798: URL: https://github.com/apache/camel/pull/6798 This pull request proposes _polishing up_ the Javadoc description of the otherwise functionally correct [_SyncPropertiesMojo_](https://bit.ly/syncPropsMojo). -- 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-k] github-actions[bot] commented on issue #2395: Log warnings with kamelets
github-actions[bot] commented on issue #2395: URL: https://github.com/apache/camel-k/issues/2395#issuecomment-1018037725 This issue has been automatically marked as stale due to 90 days of inactivity. It will be closed if no further activity occurs within 15 days. If you think that’s incorrect or the issue should never stale, please simply write any comment. Thanks for your contributions! -- 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 (a058503 -> 5043d07)
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 a058503 Regen for commit d579f8a7b352c50fb355c67f9b7c5d739cb40ff3 add 5043d07 Regen for commit d579f8a7b352c50fb355c67f9b7c5d739cb40ff3 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 (a058503) \ N -- N -- N refs/heads/regen_bot (5043d07) 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] oscerd merged pull request #6797: Generated sources regen
oscerd merged pull request #6797: URL: https://github.com/apache/camel/pull/6797 -- 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: Regen for commit d579f8a7b352c50fb355c67f9b7c5d739cb40ff3
This is an automated email from the ASF dual-hosted git repository.
acosentino 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 5043d07 Regen for commit d579f8a7b352c50fb355c67f9b7c5d739cb40ff3
5043d07 is described below
commit 5043d0720abeef31bb45664798e397c3fa107f35
Author: davsclaus
AuthorDate: Thu Jan 20 20:13:11 2022 +
Regen for commit d579f8a7b352c50fb355c67f9b7c5d739cb40ff3
Signed-off-by: GitHub
---
.../resources/org/apache/camel/catalog/components/kafka.json | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/kafka.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/kafka.json
index 4a3781f..ddaeb8b 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/kafka.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/kafka.json
@@ -61,7 +61,7 @@
"specificAvroReader": { "kind": "property", "displayName": "Specific Avro
Reader", "group": "consumer", "label": "confluent,consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "This enables the use of a specific Avro reader
for use with the Confluent Platf [...]
"topicIsPattern": { "kind": "property", "displayName": "Topic Is Pattern",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Whether the topic is a pattern (regular
expression). This can be used to subscribe to dynamic num [...]
"valueDeserializer": { "kind": "property", "displayName": "Value
Deserializer", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringDeserializer",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Deserializer class for
value th [...]
-"kafkaManualCommitFactory": { "kind": "property", "displayName": "Kafka
Manual Commit Factory", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.component.kafka.KafkaManualCommitFactory", "deprecated":
false, "autowired": true, "secret": false, "description": "Factory to use for
creating KafkaManualCommit instances. This allows to plugin a custom factory to
create custom KafkaManualCommit instances in cas [...]
+"kafkaManualCommitFactory": { "kind": "property", "displayName": "Kafka
Manual Commit Factory", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.component.kafka.consumer.KafkaManualCommitFactory",
"deprecated": false, "autowired": true, "secret": false, "description":
"Factory to use for creating KafkaManualCommit instances. This allows to plugin
a custom factory to create custom KafkaManualCommit instanc [...]
"pollExceptionStrategy": { "kind": "property", "displayName": "Poll
Exception Strategy", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.component.kafka.PollExceptionStrategy", "deprecated": false,
"autowired": true, "secret": false, "description": "To use a custom strategy
with the consumer to control how to handle exceptions thrown from the Kafka
broker while pooling messages." },
"bufferMemorySize": { "kind": "property", "displayName": "Buffer Memory
Size", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "33554432", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The total bytes of memory the producer can use
to buffer records waiting to be [...]
"compressionCodec": { "kind": "property", "displayName": "Compression
Codec", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "none", "gzip", "snappy",
"lz4" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "none", "configurationClass":
[camel] branch regen_bot_3.14.x updated (6479760 -> 0f9e3a5)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch regen_bot_3.14.x
in repository https://gitbox.apache.org/repos/asf/camel.git.
from 6479760 CAMEL-17519: Expose MainSupprt.internalBeforeStart so that it
can be overridden
add 0f9e3a5 CAMEL-17520: camel-core - Endpoints which are lenient
properties should be configured as optional. This fixes using square brackets
in http endpoint query parameters.
No new revisions were added by this update.
Summary of changes:
...tersGetTest.java => HttpSquareBracketTest.java} | 21 -
.../org/apache/camel/support/DefaultEndpoint.java | 5 +++-
.../camel/support/PropertyBindingSupport.java | 35 --
3 files changed, 43 insertions(+), 18 deletions(-)
copy
components/camel-http/src/test/java/org/apache/camel/component/http/{HttpsSslContextParametersGetTest.java
=> HttpSquareBracketTest.java} (75%)
[camel] branch regen_bot updated (9949d5e -> a058503)
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 9949d5e Regen for commit 8667ce9631201e7636da4ecaf38e874277e586d2 add d579f8a Fixed test add a058503 Regen for commit d579f8a7b352c50fb355c67f9b7c5d739cb40ff3 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 (9949d5e) \ N -- N -- N refs/heads/regen_bot (a058503) 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: .../src/test/java/org/apache/camel/catalog/CamelCatalogTest.java| 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[camel] branch regen_bot updated (e4d8e29 -> 9949d5e)
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 e4d8e29 CAMEL-17503: fix websocket client unable to reconnect to
Server after server reboot (#6792)
add edfd096 CAMEL-17520: camel-core - Endpoints which are lenient
properties should be configured as optional. This fixes using square brackets
in http endpoint query parameters.
add 8667ce9 Regen
add 9949d5e Regen for commit 8667ce9631201e7636da4ecaf38e874277e586d2
No new revisions were added by this update.
Summary of changes:
...tersGetTest.java => HttpSquareBracketTest.java} | 21 -
.../org/apache/camel/support/DefaultEndpoint.java | 5 +++-
.../camel/support/PropertyBindingSupport.java | 35 --
3 files changed, 43 insertions(+), 18 deletions(-)
copy
components/camel-http/src/test/java/org/apache/camel/component/http/{HttpsSslContextParametersGetTest.java
=> HttpSquareBracketTest.java} (75%)
[GitHub] [camel] github-actions[bot] opened a new pull request #6797: Generated sources regen
github-actions[bot] opened a new pull request #6797: URL: https://github.com/apache/camel/pull/6797 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
[GitHub] [camel] ffang opened a new pull request #6796: [CAMEL-17526]camel-fhir: the serverUrl configuration on camel-fhir en…
ffang opened a new pull request #6796: URL: https://github.com/apache/camel/pull/6796 …dpoint shouldn't be ignored -- 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: Fixed test
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 d579f8a Fixed test
d579f8a is described below
commit d579f8a7b352c50fb355c67f9b7c5d739cb40ff3
Author: Claus Ibsen
AuthorDate: Thu Jan 20 20:24:00 2022 +0100
Fixed test
---
.../src/test/java/org/apache/camel/catalog/CamelCatalogTest.java| 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/catalog/camel-catalog/src/test/java/org/apache/camel/catalog/CamelCatalogTest.java
b/catalog/camel-catalog/src/test/java/org/apache/camel/catalog/CamelCatalogTest.java
index 7219d66..47b6d26 100644
---
a/catalog/camel-catalog/src/test/java/org/apache/camel/catalog/CamelCatalogTest.java
+++
b/catalog/camel-catalog/src/test/java/org/apache/camel/catalog/CamelCatalogTest.java
@@ -773,7 +773,7 @@ public class CamelCatalogTest {
assertEquals("foo", result.getLenient().iterator().next());
// data format
-result =
catalog.validateEndpointProperties("dataformat:zipdeflater:marshal?compressionLevel=2",
true);
+result =
catalog.validateEndpointProperties("dataformat:zipDeflater:marshal?compressionLevel=2",
true);
assertTrue(result.isSuccess());
// 2 slash after component name
[camel] branch camel-3.14.x updated: CAMEL-17520: camel-core - Endpoints which are lenient properties should be configured as optional. This fixes using square brackets in http endpoint query paramete
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-3.14.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-3.14.x by this push:
new 0f9e3a5 CAMEL-17520: camel-core - Endpoints which are lenient
properties should be configured as optional. This fixes using square brackets
in http endpoint query parameters.
0f9e3a5 is described below
commit 0f9e3a5ecfb31ccdd040d7e3e6e440b21ae52911
Author: Claus Ibsen
AuthorDate: Thu Jan 20 20:19:02 2022 +0100
CAMEL-17520: camel-core - Endpoints which are lenient properties should be
configured as optional. This fixes using square brackets in http endpoint query
parameters.
---
.../component/http/HttpSquareBracketTest.java | 72 ++
.../org/apache/camel/support/DefaultEndpoint.java | 5 +-
.../camel/support/PropertyBindingSupport.java | 35 ---
3 files changed, 102 insertions(+), 10 deletions(-)
diff --git
a/components/camel-http/src/test/java/org/apache/camel/component/http/HttpSquareBracketTest.java
b/components/camel-http/src/test/java/org/apache/camel/component/http/HttpSquareBracketTest.java
new file mode 100644
index 000..9571b73
--- /dev/null
+++
b/components/camel-http/src/test/java/org/apache/camel/component/http/HttpSquareBracketTest.java
@@ -0,0 +1,72 @@
+/*
+ * 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.component.http;
+
+import org.apache.camel.Exchange;
+import org.apache.camel.component.http.handler.BasicValidationHandler;
+import org.apache.http.impl.bootstrap.HttpServer;
+import org.apache.http.impl.bootstrap.ServerBootstrap;
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+
+import static org.apache.camel.component.http.HttpMethods.GET;
+
+public class HttpSquareBracketTest extends BaseHttpTest {
+
+private HttpServer localServer;
+
+private String baseUrl;
+
+@BeforeEach
+@Override
+public void setUp() throws Exception {
+super.setUp();
+
+localServer =
ServerBootstrap.bootstrap().setHttpProcessor(getBasicHttpProcessor())
+
.setConnectionReuseStrategy(getConnectionReuseStrategy()).setResponseFactory(getHttpResponseFactory())
+
.setExpectationVerifier(getHttpExpectationVerifier()).setSslContext(getSSLContext())
+.registerHandler("/",
+new BasicValidationHandler(
+GET.name(),
"country=dk[end-date]=2022-12-31[start-date]=2022-01-01", null,
+getExpectedContent()))
+.create();
+localServer.start();
+
+baseUrl = "http://; + localServer.getInetAddress().getHostName() + ":"
+ localServer.getLocalPort();
+}
+
+@AfterEach
+@Override
+public void tearDown() throws Exception {
+super.tearDown();
+
+if (localServer != null) {
+localServer.stop();
+}
+}
+
+@Test
+public void httpSquare() throws Exception {
+Exchange exchange = template.request(baseUrl +
"/?country=dk[start-date]=2022-01-01[end-date]=2022-12-31",
+exchange1 -> {
+});
+
+assertExchange(exchange);
+}
+
+}
diff --git
a/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpoint.java
b/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpoint.java
index 0d40247..3d4f13f 100644
---
a/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpoint.java
+++
b/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpoint.java
@@ -410,7 +410,10 @@ public abstract class DefaultEndpoint extends
ServiceSupport implements Endpoint
configurer = ((PropertyConfigurerAware)
bean).getPropertyConfigurer(bean);
}
// use configurer and ignore case as end users may type an option name
with mixed case
-
PropertyBindingSupport.build().withConfigurer(configurer).withIgnoreCase(true).bind(camelContext,
bean, parameters);
+
[camel] branch main updated (e4d8e29 -> 8667ce9)
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 e4d8e29 CAMEL-17503: fix websocket client unable to reconnect to
Server after server reboot (#6792)
new edfd096 CAMEL-17520: camel-core - Endpoints which are lenient
properties should be configured as optional. This fixes using square brackets
in http endpoint query parameters.
new 8667ce9 Regen
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:
.../org/apache/camel/catalog/components/kafka.json | 4 +--
...tersGetTest.java => HttpSquareBracketTest.java} | 21 -
.../org/apache/camel/support/DefaultEndpoint.java | 5 +++-
.../camel/support/PropertyBindingSupport.java | 35 --
4 files changed, 45 insertions(+), 20 deletions(-)
copy
components/camel-http/src/test/java/org/apache/camel/component/http/{HttpsSslContextParametersGetTest.java
=> HttpSquareBracketTest.java} (75%)
[camel] 01/02: CAMEL-17520: camel-core - Endpoints which are lenient properties should be configured as optional. This fixes using square brackets in http endpoint query 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
commit edfd096b0dd96c889fe08f3c6d29a94d8b8c7a48
Author: Claus Ibsen
AuthorDate: Thu Jan 20 20:19:02 2022 +0100
CAMEL-17520: camel-core - Endpoints which are lenient properties should be
configured as optional. This fixes using square brackets in http endpoint query
parameters.
---
.../component/http/HttpSquareBracketTest.java | 72 ++
.../org/apache/camel/support/DefaultEndpoint.java | 5 +-
.../camel/support/PropertyBindingSupport.java | 35 ---
3 files changed, 102 insertions(+), 10 deletions(-)
diff --git
a/components/camel-http/src/test/java/org/apache/camel/component/http/HttpSquareBracketTest.java
b/components/camel-http/src/test/java/org/apache/camel/component/http/HttpSquareBracketTest.java
new file mode 100644
index 000..9571b73
--- /dev/null
+++
b/components/camel-http/src/test/java/org/apache/camel/component/http/HttpSquareBracketTest.java
@@ -0,0 +1,72 @@
+/*
+ * 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.component.http;
+
+import org.apache.camel.Exchange;
+import org.apache.camel.component.http.handler.BasicValidationHandler;
+import org.apache.http.impl.bootstrap.HttpServer;
+import org.apache.http.impl.bootstrap.ServerBootstrap;
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+
+import static org.apache.camel.component.http.HttpMethods.GET;
+
+public class HttpSquareBracketTest extends BaseHttpTest {
+
+private HttpServer localServer;
+
+private String baseUrl;
+
+@BeforeEach
+@Override
+public void setUp() throws Exception {
+super.setUp();
+
+localServer =
ServerBootstrap.bootstrap().setHttpProcessor(getBasicHttpProcessor())
+
.setConnectionReuseStrategy(getConnectionReuseStrategy()).setResponseFactory(getHttpResponseFactory())
+
.setExpectationVerifier(getHttpExpectationVerifier()).setSslContext(getSSLContext())
+.registerHandler("/",
+new BasicValidationHandler(
+GET.name(),
"country=dk[end-date]=2022-12-31[start-date]=2022-01-01", null,
+getExpectedContent()))
+.create();
+localServer.start();
+
+baseUrl = "http://; + localServer.getInetAddress().getHostName() + ":"
+ localServer.getLocalPort();
+}
+
+@AfterEach
+@Override
+public void tearDown() throws Exception {
+super.tearDown();
+
+if (localServer != null) {
+localServer.stop();
+}
+}
+
+@Test
+public void httpSquare() throws Exception {
+Exchange exchange = template.request(baseUrl +
"/?country=dk[start-date]=2022-01-01[end-date]=2022-12-31",
+exchange1 -> {
+});
+
+assertExchange(exchange);
+}
+
+}
diff --git
a/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpoint.java
b/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpoint.java
index 0d40247..3d4f13f 100644
---
a/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpoint.java
+++
b/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpoint.java
@@ -410,7 +410,10 @@ public abstract class DefaultEndpoint extends
ServiceSupport implements Endpoint
configurer = ((PropertyConfigurerAware)
bean).getPropertyConfigurer(bean);
}
// use configurer and ignore case as end users may type an option name
with mixed case
-
PropertyBindingSupport.build().withConfigurer(configurer).withIgnoreCase(true).bind(camelContext,
bean, parameters);
+
PropertyBindingSupport.build().withConfigurer(configurer).withIgnoreCase(true)
+// if the endpoint is lenient then use optional
+.withOptional(isLenientProperties())
+.bind(camelContext, bean, parameters);
}
/**
diff --git
[camel] 02/02: Regen
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 8667ce9631201e7636da4ecaf38e874277e586d2
Author: Claus Ibsen
AuthorDate: Thu Jan 20 20:21:19 2022 +0100
Regen
---
.../resources/org/apache/camel/catalog/components/kafka.json | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/kafka.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/kafka.json
index ddaeb8b..4a3781f 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/kafka.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/kafka.json
@@ -61,7 +61,7 @@
"specificAvroReader": { "kind": "property", "displayName": "Specific Avro
Reader", "group": "consumer", "label": "confluent,consumer", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "This enables the use of a specific Avro reader
for use with the Confluent Platf [...]
"topicIsPattern": { "kind": "property", "displayName": "Topic Is Pattern",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "Whether the topic is a pattern (regular
expression). This can be used to subscribe to dynamic num [...]
"valueDeserializer": { "kind": "property", "displayName": "Value
Deserializer", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"org.apache.kafka.common.serialization.StringDeserializer",
"configurationClass": "org.apache.camel.component.kafka.KafkaConfiguration",
"configurationField": "configuration", "description": "Deserializer class for
value th [...]
-"kafkaManualCommitFactory": { "kind": "property", "displayName": "Kafka
Manual Commit Factory", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.component.kafka.consumer.KafkaManualCommitFactory",
"deprecated": false, "autowired": true, "secret": false, "description":
"Factory to use for creating KafkaManualCommit instances. This allows to plugin
a custom factory to create custom KafkaManualCommit instanc [...]
+"kafkaManualCommitFactory": { "kind": "property", "displayName": "Kafka
Manual Commit Factory", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.component.kafka.KafkaManualCommitFactory", "deprecated":
false, "autowired": true, "secret": false, "description": "Factory to use for
creating KafkaManualCommit instances. This allows to plugin a custom factory to
create custom KafkaManualCommit instances in cas [...]
"pollExceptionStrategy": { "kind": "property", "displayName": "Poll
Exception Strategy", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.component.kafka.PollExceptionStrategy", "deprecated": false,
"autowired": true, "secret": false, "description": "To use a custom strategy
with the consumer to control how to handle exceptions thrown from the Kafka
broker while pooling messages." },
"bufferMemorySize": { "kind": "property", "displayName": "Buffer Memory
Size", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "33554432", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "The total bytes of memory the producer can use
to buffer records waiting to be [...]
"compressionCodec": { "kind": "property", "displayName": "Compression
Codec", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "enum": [ "none", "gzip", "snappy",
"lz4" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "none", "configurationClass":
"org.apache.camel.component.kafka.KafkaConfiguration", "configurationField":
"configuration", "description": "This parameter allows you to specify the [...]
@@ -169,7 +169,7 @@
"valueDeserializer": { "kind": "parameter", "displayName": "Value
[GitHub] [camel] klease opened a new pull request #6795: CAMEL-17491: do not add context path to the paths of the operations.
klease opened a new pull request #6795: URL: https://github.com/apache/camel/pull/6795 Add a unit test to verify the absence of the context-path. -- 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-spring-boot-examples] ffang merged pull request #45: [CAMEL-17523]camel-spring-boot-examples：rest-jpa is broken
ffang merged pull request #45: URL: https://github.com/apache/camel-spring-boot-examples/pull/45 -- 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-spring-boot-examples] branch main updated: [CAMEL-17523]camel-spring-boot-examples：rest-jpa is broken (#45)
This is an automated email from the ASF dual-hosted git repository. ffang pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-spring-boot-examples.git The following commit(s) were added to refs/heads/main by this push: new 4d817d9 [CAMEL-17523]camel-spring-boot-examples：rest-jpa is broken (#45) 4d817d9 is described below commit 4d817d90fe30d90491629e073f7db6476bb8f024 Author: Freeman(Yue) Fang AuthorDate: Thu Jan 20 13:31:44 2022 -0500 [CAMEL-17523]camel-spring-boot-examples：rest-jpa is broken (#45) --- rest-jpa/src/main/resources/application-dev.yml | 2 ++ rest-jpa/src/main/resources/data.sql| 9 - rest-jpa/src/test/resources/application.yml | 6 ++ 3 files changed, 16 insertions(+), 1 deletion(-) diff --git a/rest-jpa/src/main/resources/application-dev.yml b/rest-jpa/src/main/resources/application-dev.yml index 8e6d62d..6cac4ce 100644 --- a/rest-jpa/src/main/resources/application-dev.yml +++ b/rest-jpa/src/main/resources/application-dev.yml @@ -33,6 +33,8 @@ spring: jpa: database: h2 database-platform: org.hibernate.dialect.H2Dialect +hibernate: + ddl-auto: update # The application configuration properties example: diff --git a/rest-jpa/src/main/resources/data.sql b/rest-jpa/src/main/resources/data.sql index b4dc5bc..78b70f7 100644 --- a/rest-jpa/src/main/resources/data.sql +++ b/rest-jpa/src/main/resources/data.sql @@ -15,7 +15,14 @@ -- limitations under the License. -- +create table books ( + id integer not null, +description varchar(255), +item varchar(255), +primary key (id) +); + INSERT INTO books (id, item, description) VALUES (1, 'Camel','Camel in Action'), - (2, 'ActiveMQ', 'ActiveMQ in Action'); \ No newline at end of file + (2, 'ActiveMQ', 'ActiveMQ in Action'); diff --git a/rest-jpa/src/test/resources/application.yml b/rest-jpa/src/test/resources/application.yml index 714fe90..2a5d066 100644 --- a/rest-jpa/src/test/resources/application.yml +++ b/rest-jpa/src/test/resources/application.yml @@ -22,6 +22,12 @@ camel: mapping: contextPath: /camel-rest-jpa/* +spring: + jpa: +hibernate: + ddl-auto: update + + example: generateOrderPeriod: 1000 processOrderPeriod: 3000
[GitHub] [camel-k] astefanutti opened a new pull request #2897: feat(trait): environment variables (1.6.x backport)
astefanutti opened a new pull request #2897: URL: https://github.com/apache/camel-k/pull/2897 Backport #2650 to 1.6.x branch as it's required by #2885. **Release Note** ```release-note feat(trait): environment variables ``` -- 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-performance-tests] oscerd merged pull request #84: Kafka to Mongo Camel-Jbang Profiling
oscerd merged pull request #84: URL: https://github.com/apache/camel-performance-tests/pull/84 -- 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-performance-tests] branch main updated (eda439a -> fa3c01d)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git.
from eda439a Kafka to Minio with Exchange Pooling: Add camel-jbang route
new eb36f30 Kafka to Mongo: Added a camel-jbang section to the README
new fa3c01d Kafka to Mongo: Add camel-jbang route
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:
profiling/kafka/kafka-mongo/README.md| 12
.../data/sources/camel-jbang-route.yaml | 12 ++--
2 files changed, 18 insertions(+), 6 deletions(-)
copy profiling/kafka/{kafka-minio-exchange-pooling =>
kafka-mongo}/data/sources/camel-jbang-route.yaml (80%)
[camel-performance-tests] 01/02: Kafka to Mongo: Added a camel-jbang section to the README
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit eb36f302c933f12531363bf47ac314ebf4f3d4ef Author: Andrea Cosentino AuthorDate: Thu Jan 20 18:34:03 2022 +0100 Kafka to Mongo: Added a camel-jbang section to the README --- profiling/kafka/kafka-mongo/README.md | 12 1 file changed, 12 insertions(+) diff --git a/profiling/kafka/kafka-mongo/README.md b/profiling/kafka/kafka-mongo/README.md index 1ca0860..05edec6 100644 --- a/profiling/kafka/kafka-mongo/README.md +++ b/profiling/kafka/kafka-mongo/README.md @@ -135,6 +135,18 @@ docker run --rm -ti \ In this case we are allocating 128 Mb Memory to the container and 0.25% cpus. +## Running this profiling example with Camel-Jbang + +You could also leveraging the camel-jbang module. From Camel 3.15.0 (still to be released) it will support the profiling feature. + +What you need to do is simply running this commands: + +```shell script +jbang -Dcamel.jbang.version=3.15.0-SNAPSHOT camel@apache/camel run --jfr-profile=profile data/sources/camel-jbang-route.yaml +``` + +You'll get at jfr recording file once the application will be stopped in your working directory. + ## HEAP Sizing In the pom you can also set a different Heap Size. The default is 64 Mb.
[camel-performance-tests] 02/02: Kafka to Mongo: Add camel-jbang route
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit fa3c01de989db5f27fc8cc423619ce6da0c8bf8e Author: Andrea Cosentino AuthorDate: Thu Jan 20 18:35:26 2022 +0100 Kafka to Mongo: Add camel-jbang route --- .../data/sources/camel-jbang-route.yaml| 33 ++ 1 file changed, 33 insertions(+) diff --git a/profiling/kafka/kafka-mongo/data/sources/camel-jbang-route.yaml b/profiling/kafka/kafka-mongo/data/sources/camel-jbang-route.yaml new file mode 100644 index 000..3a5fcfc --- /dev/null +++ b/profiling/kafka/kafka-mongo/data/sources/camel-jbang-route.yaml @@ -0,0 +1,33 @@ +# +# 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. +# + +- route: +from: + uri: "kamelet:kafka-not-secured-source" + parameters: +bootstrapServers: "localhost:9092" +topic: "testtopic" + steps: +- to: +uri: "kamelet:mongodb-sink" +parameters: + collection: "log" + database: "test" + hosts: "127.0.0.1" + username: "mongoadmin" + password: "secret" +
[GitHub] [camel-performance-tests] oscerd opened a new pull request #84: Kafka to Mongo Camel-Jbang Profiling
oscerd opened a new pull request #84: URL: https://github.com/apache/camel-performance-tests/pull/84 Related to #81 -- 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-performance-tests] 01/02: Kafka to Mongo: Added a camel-jbang section to the README
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch camel-jbang-1 in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit 0fb004d948207481eaef288400fbdc02d8661def Author: Andrea Cosentino AuthorDate: Thu Jan 20 18:34:03 2022 +0100 Kafka to Mongo: Added a camel-jbang section to the README --- profiling/kafka/kafka-mongo/README.md | 12 1 file changed, 12 insertions(+) diff --git a/profiling/kafka/kafka-mongo/README.md b/profiling/kafka/kafka-mongo/README.md index 1ca0860..05edec6 100644 --- a/profiling/kafka/kafka-mongo/README.md +++ b/profiling/kafka/kafka-mongo/README.md @@ -135,6 +135,18 @@ docker run --rm -ti \ In this case we are allocating 128 Mb Memory to the container and 0.25% cpus. +## Running this profiling example with Camel-Jbang + +You could also leveraging the camel-jbang module. From Camel 3.15.0 (still to be released) it will support the profiling feature. + +What you need to do is simply running this commands: + +```shell script +jbang -Dcamel.jbang.version=3.15.0-SNAPSHOT camel@apache/camel run --jfr-profile=profile data/sources/camel-jbang-route.yaml +``` + +You'll get at jfr recording file once the application will be stopped in your working directory. + ## HEAP Sizing In the pom you can also set a different Heap Size. The default is 64 Mb.
[camel-performance-tests] branch camel-jbang-1 created (now aba2f4c)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch camel-jbang-1 in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git. at aba2f4c Kafka to Mongo: Add camel-jbang route This branch includes the following new commits: new 0fb004d Kafka to Mongo: Added a camel-jbang section to the README new aba2f4c Kafka to Mongo: Add camel-jbang route 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.
[camel-performance-tests] 02/02: Kafka to Mongo: Add camel-jbang route
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch camel-jbang-1 in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit aba2f4c8a3ba542c85cc55a06e4a3e7d8f8db8fd Author: Andrea Cosentino AuthorDate: Thu Jan 20 18:35:26 2022 +0100 Kafka to Mongo: Add camel-jbang route --- .../data/sources/camel-jbang-route.yaml| 33 ++ 1 file changed, 33 insertions(+) diff --git a/profiling/kafka/kafka-mongo/data/sources/camel-jbang-route.yaml b/profiling/kafka/kafka-mongo/data/sources/camel-jbang-route.yaml new file mode 100644 index 000..3a5fcfc --- /dev/null +++ b/profiling/kafka/kafka-mongo/data/sources/camel-jbang-route.yaml @@ -0,0 +1,33 @@ +# +# 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. +# + +- route: +from: + uri: "kamelet:kafka-not-secured-source" + parameters: +bootstrapServers: "localhost:9092" +topic: "testtopic" + steps: +- to: +uri: "kamelet:mongodb-sink" +parameters: + collection: "log" + database: "test" + hosts: "127.0.0.1" + username: "mongoadmin" + password: "secret" +
[GitHub] [camel-k] astefanutti commented on issue #2896: Enabling prometheus causes KameletBindings to be stuck in status "Creating"
astefanutti commented on issue #2896:
URL: https://github.com/apache/camel-k/issues/2896#issuecomment-1017714700
You need to have the Prometheus operator installed in your cluster by
default, specifically the `PodMonitor` CRD.
In case, you don't want the auto-configuration of the Prometheus operator,
and only need the metrics exposed, you can disable it with the `pod-monitor`
option of the _prometheus_ trait, e.g. when patching the IntegrationPlatform:
```
$ echo '{"spec": {"traits": {"prometheus": { "configuration": {"enabled":
true, "podMonitor": false } } }}}' > monitoring-patch.json
```
See
https://camel.apache.org/camel-k/1.7.x/traits/prometheus.html#_configuration.
--
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_3.14.x updated (376462a -> 6479760)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot_3.14.x in repository https://gitbox.apache.org/repos/asf/camel.git. from 376462a CAMEL-17503: fix websocket client unable to reconnect to Server after server reboot (#6792) add 6479760 CAMEL-17519: Expose MainSupprt.internalBeforeStart so that it can be overridden No new revisions were added by this update. Summary of changes: .../main/java/org/apache/camel/main/MainSupport.java | 20 +++- 1 file changed, 15 insertions(+), 5 deletions(-)
[GitHub] [camel-k] k0pper opened a new issue #2896: Enabling prometheus causes KameletBindings to be stuck in status "Creating"
k0pper opened a new issue #2896:
URL: https://github.com/apache/camel-k/issues/2896
Hello,
I tried enabling Prometheus metrics with the Prometheus Trait and installing
the helm prometheus release
`echo '{"spec": {"traits": {"prometheus": { "configuration": {"enabled":
true } } }}}' > monitoring-patch.json`
`kubectl patch integrationplatform camel-k --patch "$(cat
monitoring-patch.json)" --namespace camel-k --type='merge'`
`helm install prometheus prometheus-community/prometheus --namespace camel-k`
Everything works kind of, but all the KameletBindings I try to create
afterwards are stuck in the "Creating" phase. They **do** get deployed and they
work as they should, but they never exit the "Creating" status.
Without the Prometheus Trait, everything works again, why?
Alex
--
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] JiriOndrusek edited a comment on pull request #3370: Sql test using derby doesn't start dev service and shows class loadin…
JiriOndrusek edited a comment on pull request #3370: URL: https://github.com/apache/camel-quarkus/pull/3370#issuecomment-1017657284 I rebased this PR to `main`. I can locally run tests (successfully) with external derby via docker in **JVM** mode Native mode fails with ``` ERROR [io.qua.run.Application] (main) Failed to start application (with profile prod): ERROR 08006: Insufficient data while reading from the network - expected a minimum of 6 bytes and received only 0 bytes. The connection has been terminated. ``` But native mode is not expected to be successful, see https://github.com/quarkusio/quarkus/issues/22058#issuecomment-989714178 -- 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] JiriOndrusek commented on pull request #3370: Sql test using derby doesn't start dev service and shows class loadin…
JiriOndrusek commented on pull request #3370: URL: https://github.com/apache/camel-quarkus/pull/3370#issuecomment-1017657284 I rebased this PR to `main`. I can locally run tests with external derby via docker in **JVM** mode Native mode fails with ``` ERROR [io.qua.run.Application] (main) Failed to start application (with profile prod): ERROR 08006: Insufficient data while reading from the network - expected a minimum of 6 bytes and received only 0 bytes. The connection has been terminated. ``` But native mode is not expected to be successful, see https://github.com/quarkusio/quarkus/issues/22058#issuecomment-989714178 -- 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 camel-3.14.x updated: CAMEL-17519: Expose MainSupprt.internalBeforeStart so that it can be overridden
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch camel-3.14.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-3.14.x by this push:
new 6479760 CAMEL-17519: Expose MainSupprt.internalBeforeStart so that it
can be overridden
6479760 is described below
commit 6479760fd37d0cf6aac526483dab2ca99118143c
Author: James Netherton
AuthorDate: Thu Jan 20 10:02:55 2022 +
CAMEL-17519: Expose MainSupprt.internalBeforeStart so that it can be
overridden
---
.../main/java/org/apache/camel/main/MainSupport.java | 20 +++-
1 file changed, 15 insertions(+), 5 deletions(-)
diff --git
a/core/camel-main/src/main/java/org/apache/camel/main/MainSupport.java
b/core/camel-main/src/main/java/org/apache/camel/main/MainSupport.java
index 1b925d8..824bfec 100644
--- a/core/camel-main/src/main/java/org/apache/camel/main/MainSupport.java
+++ b/core/camel-main/src/main/java/org/apache/camel/main/MainSupport.java
@@ -103,7 +103,10 @@ public abstract class MainSupport extends BaseMainSupport {
}
}
-private void internalBeforeStart() {
+/**
+ * Tasks to run before start() is called.
+ */
+protected void internalBeforeStart() {
// used while waiting to be done
durationMaxIdleSeconds =
mainConfigurationProperties.getDurationMaxIdleSeconds();
durationMaxMessages =
mainConfigurationProperties.getDurationMaxMessages();
@@ -112,10 +115,7 @@ public abstract class MainSupport extends BaseMainSupport {
durationMaxAction = mainConfigurationProperties.getDurationMaxAction();
// register main as bootstrap
-CamelContext context = getCamelContext();
-if (context != null) {
-context.adapt(ExtendedCamelContext.class).addBootstrap(new
MainBootstrapCloseable(this));
-}
+registerMainBootstrap();
}
/**
@@ -166,6 +166,16 @@ public abstract class MainSupport extends BaseMainSupport {
return this::completed;
}
+/**
+ * Registers {@link MainBootstrapCloseable} with the CamelContext.
+ */
+protected void registerMainBootstrap() {
+CamelContext context = getCamelContext();
+if (context != null) {
+context.adapt(ExtendedCamelContext.class).addBootstrap(new
MainBootstrapCloseable(this));
+}
+}
+
@Deprecated
public int getDuration() {
return mainConfigurationProperties.getDurationMaxSeconds();
[camel] branch camel-3.11.x updated: CAMEL-17519: Expose MainSupprt.internalBeforeStart so that it can be overridden
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton 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 e7a851a CAMEL-17519: Expose MainSupprt.internalBeforeStart so that it
can be overridden
e7a851a is described below
commit e7a851aeff3e3ecbaf9d2136377d75caff0e843e
Author: James Netherton
AuthorDate: Thu Jan 20 10:02:55 2022 +
CAMEL-17519: Expose MainSupprt.internalBeforeStart so that it can be
overridden
---
.../main/java/org/apache/camel/main/MainSupport.java | 20 +++-
1 file changed, 15 insertions(+), 5 deletions(-)
diff --git
a/core/camel-main/src/main/java/org/apache/camel/main/MainSupport.java
b/core/camel-main/src/main/java/org/apache/camel/main/MainSupport.java
index d49d760..216ecbf 100644
--- a/core/camel-main/src/main/java/org/apache/camel/main/MainSupport.java
+++ b/core/camel-main/src/main/java/org/apache/camel/main/MainSupport.java
@@ -102,7 +102,10 @@ public abstract class MainSupport extends BaseMainSupport {
}
}
-private void internalBeforeStart() {
+/**
+ * Tasks to run before start() is called.
+ */
+protected void internalBeforeStart() {
// used while waiting to be done
durationMaxIdleSeconds =
mainConfigurationProperties.getDurationMaxIdleSeconds();
durationMaxMessages =
mainConfigurationProperties.getDurationMaxMessages();
@@ -110,10 +113,7 @@ public abstract class MainSupport extends BaseMainSupport {
durationHitExitCode =
mainConfigurationProperties.getDurationHitExitCode();
// register main as bootstrap
-CamelContext context = getCamelContext();
-if (context != null) {
-context.adapt(ExtendedCamelContext.class).addBootstrap(new
MainBootstrapCloseable(this));
-}
+registerMainBootstrap();
}
/**
@@ -164,6 +164,16 @@ public abstract class MainSupport extends BaseMainSupport {
return this::completed;
}
+/**
+ * Registers {@link MainBootstrapCloseable} with the CamelContext.
+ */
+protected void registerMainBootstrap() {
+CamelContext context = getCamelContext();
+if (context != null) {
+context.adapt(ExtendedCamelContext.class).addBootstrap(new
MainBootstrapCloseable(this));
+}
+}
+
@Deprecated
public int getDuration() {
return mainConfigurationProperties.getDurationMaxSeconds();
[camel] branch regen_bot_3.14.x updated (16813a3 -> 376462a)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot_3.14.x in repository https://gitbox.apache.org/repos/asf/camel.git. from 16813a3 Fixed camel-soroush. Upgrade to jersey 2.35 add 376462a CAMEL-17503: fix websocket client unable to reconnect to Server after server reboot (#6792) No new revisions were added by this update. Summary of changes: .../apache/camel/component/ahc/ws/WsEndpoint.java | 8 ++- .../apache/camel/component/ahc/ws/TestServlet.java | 1 + .../component/ahc/ws/WsProducerConsumerTest.java | 27 +- 3 files changed, 34 insertions(+), 2 deletions(-)
[camel] branch regen_bot updated (78e2ee5 -> e4d8e29)
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 78e2ee5 Use latest Docker Solr Image 8.11.1 add 1cfcc47 Upgrade Testcontainers to version 1.16.3 add e4d8e29 CAMEL-17503: fix websocket client unable to reconnect to Server after server reboot (#6792) No new revisions were added by this update. Summary of changes: .../apache/camel/component/ahc/ws/WsEndpoint.java | 8 ++- .../apache/camel/component/ahc/ws/TestServlet.java | 1 + .../component/ahc/ws/WsProducerConsumerTest.java | 27 +- parent/pom.xml | 2 +- 4 files changed, 35 insertions(+), 3 deletions(-)
[camel] branch regen_bot updated (1cfcc47 -> 78e2ee5)
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 1cfcc47 Upgrade Testcontainers to version 1.16.3 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 (78e2ee5) \ O -- O -- O (1cfcc47) 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: parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[camel] branch regen_bot updated (c0863b1 -> 1cfcc47)
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 c0863b1 Upgrade Localstack to version 0.13.3 add 78e2ee5 Use latest Docker Solr Image 8.11.1 add 1cfcc47 Upgrade Testcontainers to version 1.16.3 No new revisions were added by this update. Summary of changes: parent/pom.xml | 2 +- .../camel/test/infra/solr/services/SolrLocalContainerService.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-)
[camel] branch regen_bot updated (8c64bb7 -> c0863b1)
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 8c64bb7 CAMEL-17519: Expose MainSupprt.internalBeforeStart so that it can be overridden add c0863b1 Upgrade Localstack to version 0.13.3 No new revisions were added by this update. Summary of changes: .../java/org/apache/camel/test/infra/aws2/services/AWSContainer.java| 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[GitHub] [camel-k] bouskaJ commented on pull request #2895: [TEST] - check IntegrationPlatform namespace with global operator
bouskaJ commented on pull request #2895: URL: https://github.com/apache/camel-k/pull/2895#issuecomment-1017595913 CI failures do not seem to be related to this PR. Can you rerun the CI? -- 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 camel-3.11.x updated: CAMEL-17503: fix websocket client unable to reconnect to Server after server reboot (#6792)
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 a795221 CAMEL-17503: fix websocket client unable to reconnect to
Server after server reboot (#6792)
a795221 is described below
commit a795221c591780830d00e5e2dbf8cfcc43c662f9
Author: CG
AuthorDate: Thu Jan 20 22:50:13 2022 +0800
CAMEL-17503: fix websocket client unable to reconnect to Server after
server reboot (#6792)
Co-authored-by: CG
---
.../apache/camel/component/ahc/ws/WsEndpoint.java | 8 ++-
.../apache/camel/component/ahc/ws/TestServlet.java | 1 +
.../component/ahc/ws/WsProducerConsumerTest.java | 27 +-
3 files changed, 34 insertions(+), 2 deletions(-)
diff --git
a/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java
b/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java
index 2dbce5d..bc72c41 100644
---
a/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java
+++
b/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java
@@ -172,9 +172,15 @@ public class WsEndpoint extends AhcEndpoint {
}
@Override
-public void onClose(WebSocket websocket, int code, String reason) {
+public void onClose(WebSocket socket, int code, String reason) {
LOG.debug("websocket closed - reconnecting");
try {
+if (websocket != null) {
+// set websocket to null and remove the listener
+websocket.removeWebSocketListener(listener);
+websocket.sendCloseFrame();
+websocket = null;
+}
reConnect();
} catch (Exception e) {
LOG.warn("Error re-connecting to websocket", e);
diff --git
a/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/TestServlet.java
b/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/TestServlet.java
index 440b9d1..99a924b 100644
---
a/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/TestServlet.java
+++
b/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/TestServlet.java
@@ -34,6 +34,7 @@ public class TestServlet {
@OnWebSocketConnect
public void handleConnect(Session session) {
this.session = session;
+send("Connected!");
}
@OnWebSocketMessage
diff --git
a/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/WsProducerConsumerTest.java
b/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/WsProducerConsumerTest.java
index 1f8a800..3711794 100644
---
a/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/WsProducerConsumerTest.java
+++
b/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/WsProducerConsumerTest.java
@@ -40,6 +40,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class WsProducerConsumerTest extends CamelTestSupport {
protected static final String TEST_MESSAGE = "Hello World!";
+protected static final String TEST_CONNECTED_MESSAGE = "Connected!";
protected static final int PORT = AvailablePortFinder.getNextAvailable();
private static final Logger LOG =
LoggerFactory.getLogger(WsProducerConsumerTest.class);
@@ -139,9 +140,27 @@ public class WsProducerConsumerTest extends
CamelTestSupport {
mock.assertIsSatisfied();
}
+@Test
+public void testRestartServer() throws Exception {
+MockEndpoint mock = getMockEndpoint("mock:restart-result");
+mock.expectedBodiesReceived(TEST_CONNECTED_MESSAGE);
+
+mock.assertIsSatisfied();
+
+LOG.info("Restarting Test Server");
+stopTestServer();
+startTestServer();
+
+resetMocks();
+
+mock.expectedBodiesReceived(TEST_CONNECTED_MESSAGE);
+
+mock.assertIsSatisfied();
+}
+
@Override
protected RouteBuilder[] createRouteBuilders() throws Exception {
-RouteBuilder[] rbs = new RouteBuilder[2];
+RouteBuilder[] rbs = new RouteBuilder[3];
rbs[0] = new RouteBuilder() {
public void configure() {
from("direct:input").routeId("foo")
@@ -154,6 +173,12 @@ public class WsProducerConsumerTest extends
CamelTestSupport {
.to("mock:result");
}
};
+rbs[2] = new RouteBuilder() {
+public void configure() {
+from("ahc-ws://localhost:" + PORT +
"/restart").routeId("restart")
+.to("mock:restart-result");
+}
+};
return rbs;
}
}
[camel] branch camel-3.14.x updated: CAMEL-17503: fix websocket client unable to reconnect to Server after server reboot (#6792)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-3.14.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-3.14.x by this push:
new 376462a CAMEL-17503: fix websocket client unable to reconnect to
Server after server reboot (#6792)
376462a is described below
commit 376462a8d239647cad83acda70d67cbad898dbc7
Author: CG
AuthorDate: Thu Jan 20 22:50:13 2022 +0800
CAMEL-17503: fix websocket client unable to reconnect to Server after
server reboot (#6792)
Co-authored-by: CG
---
.../apache/camel/component/ahc/ws/WsEndpoint.java | 8 ++-
.../apache/camel/component/ahc/ws/TestServlet.java | 1 +
.../component/ahc/ws/WsProducerConsumerTest.java | 27 +-
3 files changed, 34 insertions(+), 2 deletions(-)
diff --git
a/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java
b/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java
index b04ef88..1f6bb57 100644
---
a/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java
+++
b/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java
@@ -173,9 +173,15 @@ public class WsEndpoint extends AhcEndpoint {
}
@Override
-public void onClose(WebSocket websocket, int code, String reason) {
+public void onClose(WebSocket socket, int code, String reason) {
LOG.debug("websocket closed - reconnecting");
try {
+if (websocket != null) {
+// set websocket to null and remove the listener
+websocket.removeWebSocketListener(listener);
+websocket.sendCloseFrame();
+websocket = null;
+}
reConnect();
} catch (ExecutionException | InterruptedException e) {
LOG.warn("Error re-connecting to websocket", e);
diff --git
a/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/TestServlet.java
b/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/TestServlet.java
index 440b9d1..99a924b 100644
---
a/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/TestServlet.java
+++
b/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/TestServlet.java
@@ -34,6 +34,7 @@ public class TestServlet {
@OnWebSocketConnect
public void handleConnect(Session session) {
this.session = session;
+send("Connected!");
}
@OnWebSocketMessage
diff --git
a/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/WsProducerConsumerTest.java
b/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/WsProducerConsumerTest.java
index 1f8a800..3711794 100644
---
a/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/WsProducerConsumerTest.java
+++
b/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/WsProducerConsumerTest.java
@@ -40,6 +40,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class WsProducerConsumerTest extends CamelTestSupport {
protected static final String TEST_MESSAGE = "Hello World!";
+protected static final String TEST_CONNECTED_MESSAGE = "Connected!";
protected static final int PORT = AvailablePortFinder.getNextAvailable();
private static final Logger LOG =
LoggerFactory.getLogger(WsProducerConsumerTest.class);
@@ -139,9 +140,27 @@ public class WsProducerConsumerTest extends
CamelTestSupport {
mock.assertIsSatisfied();
}
+@Test
+public void testRestartServer() throws Exception {
+MockEndpoint mock = getMockEndpoint("mock:restart-result");
+mock.expectedBodiesReceived(TEST_CONNECTED_MESSAGE);
+
+mock.assertIsSatisfied();
+
+LOG.info("Restarting Test Server");
+stopTestServer();
+startTestServer();
+
+resetMocks();
+
+mock.expectedBodiesReceived(TEST_CONNECTED_MESSAGE);
+
+mock.assertIsSatisfied();
+}
+
@Override
protected RouteBuilder[] createRouteBuilders() throws Exception {
-RouteBuilder[] rbs = new RouteBuilder[2];
+RouteBuilder[] rbs = new RouteBuilder[3];
rbs[0] = new RouteBuilder() {
public void configure() {
from("direct:input").routeId("foo")
@@ -154,6 +173,12 @@ public class WsProducerConsumerTest extends
CamelTestSupport {
.to("mock:result");
}
};
+rbs[2] = new RouteBuilder() {
+public void configure() {
+from("ahc-ws://localhost:" + PORT +
"/restart").routeId("restart")
+.to("mock:restart-result");
+}
+};
return rbs;
}
}
[camel] branch main updated: CAMEL-17503: fix websocket client unable to reconnect to Server after server reboot (#6792)
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 e4d8e29 CAMEL-17503: fix websocket client unable to reconnect to
Server after server reboot (#6792)
e4d8e29 is described below
commit e4d8e291ab99058b3635c8c6f9cae8b8c41ff2ee
Author: CG
AuthorDate: Thu Jan 20 22:50:13 2022 +0800
CAMEL-17503: fix websocket client unable to reconnect to Server after
server reboot (#6792)
Co-authored-by: CG
---
.../apache/camel/component/ahc/ws/WsEndpoint.java | 8 ++-
.../apache/camel/component/ahc/ws/TestServlet.java | 1 +
.../component/ahc/ws/WsProducerConsumerTest.java | 27 +-
3 files changed, 34 insertions(+), 2 deletions(-)
diff --git
a/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java
b/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java
index b04ef88..1f6bb57 100644
---
a/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java
+++
b/components/camel-ahc-ws/src/main/java/org/apache/camel/component/ahc/ws/WsEndpoint.java
@@ -173,9 +173,15 @@ public class WsEndpoint extends AhcEndpoint {
}
@Override
-public void onClose(WebSocket websocket, int code, String reason) {
+public void onClose(WebSocket socket, int code, String reason) {
LOG.debug("websocket closed - reconnecting");
try {
+if (websocket != null) {
+// set websocket to null and remove the listener
+websocket.removeWebSocketListener(listener);
+websocket.sendCloseFrame();
+websocket = null;
+}
reConnect();
} catch (ExecutionException | InterruptedException e) {
LOG.warn("Error re-connecting to websocket", e);
diff --git
a/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/TestServlet.java
b/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/TestServlet.java
index 440b9d1..99a924b 100644
---
a/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/TestServlet.java
+++
b/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/TestServlet.java
@@ -34,6 +34,7 @@ public class TestServlet {
@OnWebSocketConnect
public void handleConnect(Session session) {
this.session = session;
+send("Connected!");
}
@OnWebSocketMessage
diff --git
a/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/WsProducerConsumerTest.java
b/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/WsProducerConsumerTest.java
index dc0452b..10ebeca 100644
---
a/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/WsProducerConsumerTest.java
+++
b/components/camel-ahc-ws/src/test/java/org/apache/camel/component/ahc/ws/WsProducerConsumerTest.java
@@ -41,6 +41,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class WsProducerConsumerTest extends CamelTestSupport {
protected static final String TEST_MESSAGE = "Hello World!";
+protected static final String TEST_CONNECTED_MESSAGE = "Connected!";
protected static final int PORT = AvailablePortFinder.getNextAvailable();
private static final Logger LOG =
LoggerFactory.getLogger(WsProducerConsumerTest.class);
@@ -143,9 +144,27 @@ public class WsProducerConsumerTest extends
CamelTestSupport {
mock.assertIsSatisfied();
}
+@Test
+public void testRestartServer() throws Exception {
+MockEndpoint mock = getMockEndpoint("mock:restart-result");
+mock.expectedBodiesReceived(TEST_CONNECTED_MESSAGE);
+
+mock.assertIsSatisfied();
+
+LOG.info("Restarting Test Server");
+stopTestServer();
+startTestServer();
+
+resetMocks();
+
+mock.expectedBodiesReceived(TEST_CONNECTED_MESSAGE);
+
+mock.assertIsSatisfied();
+}
+
@Override
protected RouteBuilder[] createRouteBuilders() throws Exception {
-RouteBuilder[] rbs = new RouteBuilder[2];
+RouteBuilder[] rbs = new RouteBuilder[3];
rbs[0] = new RouteBuilder() {
public void configure() {
from("direct:input").routeId("foo")
@@ -158,6 +177,12 @@ public class WsProducerConsumerTest extends
CamelTestSupport {
.to("mock:result");
}
};
+rbs[2] = new RouteBuilder() {
+public void configure() {
+from("ahc-ws://localhost:" + PORT +
"/restart").routeId("restart")
+.to("mock:restart-result");
+}
+};
return rbs;
}
}
[GitHub] [camel] davsclaus merged pull request #6792: CAMEL-17503: fix websocket client unable to reconnect to Server after…
davsclaus merged pull request #6792: URL: https://github.com/apache/camel/pull/6792 -- 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] davsclaus commented on pull request #6792: CAMEL-17503: fix websocket client unable to reconnect to Server after…
davsclaus commented on pull request #6792: URL: https://github.com/apache/camel/pull/6792#issuecomment-1017586505 Ok thanks I will manually cherry pick -- 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: Upgrade Testcontainers to version 1.16.3
This is an automated email from the ASF dual-hosted git repository. acosentino 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 1cfcc47 Upgrade Testcontainers to version 1.16.3 1cfcc47 is described below commit 1cfcc476d75d5c40cad92ad48adef8727c2c340e Author: Andrea Cosentino AuthorDate: Thu Jan 20 15:31:03 2022 +0100 Upgrade Testcontainers to version 1.16.3 --- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parent/pom.xml b/parent/pom.xml index 68fced7..6c634f3 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -525,7 +525,7 @@ 4.3.1 1.2.1 1.0.0 -1.16.2 +1.16.3 1.27 7.55.3 4.0.7
[camel] branch main updated: Use latest Docker Solr Image 8.11.1
This is an automated email from the ASF dual-hosted git repository.
acosentino 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 78e2ee5 Use latest Docker Solr Image 8.11.1
78e2ee5 is described below
commit 78e2ee5223774887f66bffc316de68b1bee3e426
Author: Andrea Cosentino
AuthorDate: Thu Jan 20 15:29:55 2022 +0100
Use latest Docker Solr Image 8.11.1
---
.../camel/test/infra/solr/services/SolrLocalContainerService.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/test-infra/camel-test-infra-solr/src/test/java/org/apache/camel/test/infra/solr/services/SolrLocalContainerService.java
b/test-infra/camel-test-infra-solr/src/test/java/org/apache/camel/test/infra/solr/services/SolrLocalContainerService.java
index 430e3dd..0a7a079 100644
---
a/test-infra/camel-test-infra-solr/src/test/java/org/apache/camel/test/infra/solr/services/SolrLocalContainerService.java
+++
b/test-infra/camel-test-infra-solr/src/test/java/org/apache/camel/test/infra/solr/services/SolrLocalContainerService.java
@@ -25,7 +25,7 @@ import org.testcontainers.containers.output.Slf4jLogConsumer;
import org.testcontainers.containers.wait.strategy.Wait;
public class SolrLocalContainerService implements SolrService,
ContainerService {
-public static final String CONTAINER_IMAGE = "solr:8.11.0";
+public static final String CONTAINER_IMAGE = "solr:8.11.1";
public static final String CONTAINER_NAME = "solr";
private static final int PORT = 8983;
[camel] branch main updated: Upgrade Localstack to version 0.13.3
This is an automated email from the ASF dual-hosted git repository.
acosentino 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 c0863b1 Upgrade Localstack to version 0.13.3
c0863b1 is described below
commit c0863b1600dc38eaeceaa81a0aaf742f7c4000ce
Author: Andrea Cosentino
AuthorDate: Thu Jan 20 14:58:50 2022 +0100
Upgrade Localstack to version 0.13.3
---
.../java/org/apache/camel/test/infra/aws2/services/AWSContainer.java| 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/test-infra/camel-test-infra-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSContainer.java
b/test-infra/camel-test-infra-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSContainer.java
index c2cedd1..9136920 100644
---
a/test-infra/camel-test-infra-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSContainer.java
+++
b/test-infra/camel-test-infra-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSContainer.java
@@ -36,7 +36,7 @@ import
software.amazon.awssdk.auth.credentials.AwsCredentialsProvider;
behave as in runtime.
*/
public class AWSContainer extends GenericContainer {
-public static final String LOCALSTACK_CONTAINER =
"localstack/localstack:0.12.20";
+public static final String LOCALSTACK_CONTAINER =
"localstack/localstack:0.13.3";
private static final Logger LOG =
LoggerFactory.getLogger(AWSLocalContainerService.class);
private static final int SERVICE_PORT = 4566;
[camel-performance-tests] 02/04: Kafka to Minio: Added a camel-jbang route
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit ed7ab0099b9554154dd8f7d3c1e2a71cba7b9408 Author: Andrea Cosentino AuthorDate: Thu Jan 20 14:32:05 2022 +0100 Kafka to Minio: Added a camel-jbang route --- .../data/sources/camel-jbang-route.yaml| 33 ++ 1 file changed, 33 insertions(+) diff --git a/profiling/kafka/kafka-minio/data/sources/camel-jbang-route.yaml b/profiling/kafka/kafka-minio/data/sources/camel-jbang-route.yaml new file mode 100644 index 000..13ccb3f --- /dev/null +++ b/profiling/kafka/kafka-minio/data/sources/camel-jbang-route.yaml @@ -0,0 +1,33 @@ +# +# 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. +# + +- route: +from: + uri: "kamelet:kafka-not-secured-source" + parameters: +bootstrapServers: "localhost:9092" +topic: "testtopic" + steps: +- to: +uri: "kamelet:minio-sink" +parameters: + bucketName: "camel-kafka-connector" + accessKey: "minio" + secretKey: "miniostorage" + endpoint: "http://127.0.0.1:9000; + autoCreateBucket: true +
[camel-performance-tests] 03/04: Kafka to Minio with Exchange pooling: Added a camel-jbang section to the README
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit 3d39d81504d7af20c68f9a08316df4e62aee169c Author: Andrea Cosentino AuthorDate: Thu Jan 20 14:34:06 2022 +0100 Kafka to Minio with Exchange pooling: Added a camel-jbang section to the README --- profiling/kafka/kafka-minio-exchange-pooling/README.md | 12 1 file changed, 12 insertions(+) diff --git a/profiling/kafka/kafka-minio-exchange-pooling/README.md b/profiling/kafka/kafka-minio-exchange-pooling/README.md index 71dad2d..4dfdf6f 100644 --- a/profiling/kafka/kafka-minio-exchange-pooling/README.md +++ b/profiling/kafka/kafka-minio-exchange-pooling/README.md @@ -124,6 +124,18 @@ docker run --rm -ti \ In this case we are allocating 128 Mb Memory to the container and 0.25% cpus. +## Running this profiling example with Camel-Jbang + +You could also leveraging the camel-jbang module. From Camel 3.15.0 (still to be released) it will support the profiling feature. + +What you need to do is simply running this commands: + +```shell script +jbang -Dcamel.jbang.version=3.15.0-SNAPSHOT camel@apache/camel run --jfr-profile=profile data/sources/camel-jbang-route.yaml +``` + +You'll get at jfr recording file once the application will be stopped in your working directory. + ## Send messages to Kafka You'll need also kafkacat to be able to inject the filename header and use the burst script
[GitHub] [camel-performance-tests] oscerd opened a new pull request #83: Kafka to Minio Add Camel-Jbang profiling
oscerd opened a new pull request #83: URL: https://github.com/apache/camel-performance-tests/pull/83 Related to #81 -- 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-performance-tests] oscerd merged pull request #83: Kafka to Minio Add Camel-Jbang profiling
oscerd merged pull request #83: URL: https://github.com/apache/camel-performance-tests/pull/83 -- 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-performance-tests] 04/04: Kafka to Minio with Exchange Pooling: Add camel-jbang route
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit eda439a0fb7e785a224ead22938224f90af4076a Author: Andrea Cosentino AuthorDate: Thu Jan 20 14:35:01 2022 +0100 Kafka to Minio with Exchange Pooling: Add camel-jbang route --- .../data/sources/camel-jbang-route.yaml| 33 ++ 1 file changed, 33 insertions(+) diff --git a/profiling/kafka/kafka-minio-exchange-pooling/data/sources/camel-jbang-route.yaml b/profiling/kafka/kafka-minio-exchange-pooling/data/sources/camel-jbang-route.yaml new file mode 100644 index 000..13ccb3f --- /dev/null +++ b/profiling/kafka/kafka-minio-exchange-pooling/data/sources/camel-jbang-route.yaml @@ -0,0 +1,33 @@ +# +# 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. +# + +- route: +from: + uri: "kamelet:kafka-not-secured-source" + parameters: +bootstrapServers: "localhost:9092" +topic: "testtopic" + steps: +- to: +uri: "kamelet:minio-sink" +parameters: + bucketName: "camel-kafka-connector" + accessKey: "minio" + secretKey: "miniostorage" + endpoint: "http://127.0.0.1:9000; + autoCreateBucket: true +
[camel-performance-tests] 01/04: Kafka to Minio: Added a camel-jbang section to the README
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit 60da34603013e9a3f381b4a5d7cb8ab91ee9f7c5 Author: Andrea Cosentino AuthorDate: Thu Jan 20 14:31:15 2022 +0100 Kafka to Minio: Added a camel-jbang section to the README --- profiling/kafka/kafka-minio/README.md | 12 1 file changed, 12 insertions(+) diff --git a/profiling/kafka/kafka-minio/README.md b/profiling/kafka/kafka-minio/README.md index 9b3b460..53c5efd 100644 --- a/profiling/kafka/kafka-minio/README.md +++ b/profiling/kafka/kafka-minio/README.md @@ -124,6 +124,18 @@ docker run --rm -ti \ In this case we are allocating 128 Mb Memory to the container and 0.25% cpus. +## Running this profiling example with Camel-Jbang + +You could also leveraging the camel-jbang module. From Camel 3.15.0 (still to be released) it will support the profiling feature. + +What you need to do is simply running this commands: + +```shell script +jbang -Dcamel.jbang.version=3.15.0-SNAPSHOT camel@apache/camel run --jfr-profile=profile data/sources/camel-jbang-route.yaml +``` + +You'll get at jfr recording file once the application will be stopped in your working directory. + ## HEAP Sizing In the pom you can also set a different Heap Size. The default is 64 Mb.
[camel-performance-tests] branch main updated (7e9e2c2 -> eda439a)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git.
from 7e9e2c2 Kafka to Azure Storage Blob with Exchange pooling: Added a
camel-jbang route
new 60da346 Kafka to Minio: Added a camel-jbang section to the README
new ed7ab00 Kafka to Minio: Added a camel-jbang route
new 3d39d81 Kafka to Minio with Exchange pooling: Added a camel-jbang
section to the README
new eda439a Kafka to Minio with Exchange Pooling: Add camel-jbang route
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:
profiling/kafka/kafka-minio-exchange-pooling/README.md | 12
.../sources/{routes.yaml => camel-jbang-route.yaml}| 18 +-
profiling/kafka/kafka-minio/README.md | 12
.../data/sources/camel-jbang-route.yaml} | 18 +-
4 files changed, 42 insertions(+), 18 deletions(-)
copy profiling/kafka/kafka-minio-exchange-pooling/data/sources/{routes.yaml =>
camel-jbang-route.yaml} (75%)
copy profiling/kafka/{kafka-minio-exchange-pooling/data/sources/routes.yaml =>
kafka-minio/data/sources/camel-jbang-route.yaml} (75%)
[camel-performance-tests] branch camel-jbang created (now b5df18b)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch camel-jbang in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git. at b5df18b Kafka to Minio with Exchange Pooling: Add camel-jbang route This branch includes the following new commits: new 52248a5 Kafka to Minio: Added a camel-jbang section to the README new f5c42ce Kafka to Minio: Added a camel-jbang route new fb4972e Kafka to Minio with Exchange pooling: Added a camel-jbang section to the README new b5df18b Kafka to Minio with Exchange Pooling: Add camel-jbang route 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.
[camel-performance-tests] 02/04: Kafka to Minio: Added a camel-jbang route
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch camel-jbang in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit f5c42cee50ed607f4555e8cdc9150235bfd17c81 Author: Andrea Cosentino AuthorDate: Thu Jan 20 14:32:05 2022 +0100 Kafka to Minio: Added a camel-jbang route --- .../data/sources/camel-jbang-route.yaml| 33 ++ 1 file changed, 33 insertions(+) diff --git a/profiling/kafka/kafka-minio/data/sources/camel-jbang-route.yaml b/profiling/kafka/kafka-minio/data/sources/camel-jbang-route.yaml new file mode 100644 index 000..13ccb3f --- /dev/null +++ b/profiling/kafka/kafka-minio/data/sources/camel-jbang-route.yaml @@ -0,0 +1,33 @@ +# +# 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. +# + +- route: +from: + uri: "kamelet:kafka-not-secured-source" + parameters: +bootstrapServers: "localhost:9092" +topic: "testtopic" + steps: +- to: +uri: "kamelet:minio-sink" +parameters: + bucketName: "camel-kafka-connector" + accessKey: "minio" + secretKey: "miniostorage" + endpoint: "http://127.0.0.1:9000; + autoCreateBucket: true +
[camel-performance-tests] 04/04: Kafka to Minio with Exchange Pooling: Add camel-jbang route
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch camel-jbang in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit b5df18b73881879313e442b6df9031bd277998b6 Author: Andrea Cosentino AuthorDate: Thu Jan 20 14:35:01 2022 +0100 Kafka to Minio with Exchange Pooling: Add camel-jbang route --- .../data/sources/camel-jbang-route.yaml| 33 ++ 1 file changed, 33 insertions(+) diff --git a/profiling/kafka/kafka-minio-exchange-pooling/data/sources/camel-jbang-route.yaml b/profiling/kafka/kafka-minio-exchange-pooling/data/sources/camel-jbang-route.yaml new file mode 100644 index 000..13ccb3f --- /dev/null +++ b/profiling/kafka/kafka-minio-exchange-pooling/data/sources/camel-jbang-route.yaml @@ -0,0 +1,33 @@ +# +# 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. +# + +- route: +from: + uri: "kamelet:kafka-not-secured-source" + parameters: +bootstrapServers: "localhost:9092" +topic: "testtopic" + steps: +- to: +uri: "kamelet:minio-sink" +parameters: + bucketName: "camel-kafka-connector" + accessKey: "minio" + secretKey: "miniostorage" + endpoint: "http://127.0.0.1:9000; + autoCreateBucket: true +
[camel-performance-tests] 03/04: Kafka to Minio with Exchange pooling: Added a camel-jbang section to the README
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch camel-jbang in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit fb4972e05538a88b99b21abb144ea7d9de095b81 Author: Andrea Cosentino AuthorDate: Thu Jan 20 14:34:06 2022 +0100 Kafka to Minio with Exchange pooling: Added a camel-jbang section to the README --- profiling/kafka/kafka-minio-exchange-pooling/README.md | 12 1 file changed, 12 insertions(+) diff --git a/profiling/kafka/kafka-minio-exchange-pooling/README.md b/profiling/kafka/kafka-minio-exchange-pooling/README.md index 71dad2d..4dfdf6f 100644 --- a/profiling/kafka/kafka-minio-exchange-pooling/README.md +++ b/profiling/kafka/kafka-minio-exchange-pooling/README.md @@ -124,6 +124,18 @@ docker run --rm -ti \ In this case we are allocating 128 Mb Memory to the container and 0.25% cpus. +## Running this profiling example with Camel-Jbang + +You could also leveraging the camel-jbang module. From Camel 3.15.0 (still to be released) it will support the profiling feature. + +What you need to do is simply running this commands: + +```shell script +jbang -Dcamel.jbang.version=3.15.0-SNAPSHOT camel@apache/camel run --jfr-profile=profile data/sources/camel-jbang-route.yaml +``` + +You'll get at jfr recording file once the application will be stopped in your working directory. + ## Send messages to Kafka You'll need also kafkacat to be able to inject the filename header and use the burst script
[camel-performance-tests] 01/04: Kafka to Minio: Added a camel-jbang section to the README
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch camel-jbang in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit 52248a539ddb1ae59a857e7ccf2e86f761735568 Author: Andrea Cosentino AuthorDate: Thu Jan 20 14:31:15 2022 +0100 Kafka to Minio: Added a camel-jbang section to the README --- profiling/kafka/kafka-minio/README.md | 12 1 file changed, 12 insertions(+) diff --git a/profiling/kafka/kafka-minio/README.md b/profiling/kafka/kafka-minio/README.md index 9b3b460..53c5efd 100644 --- a/profiling/kafka/kafka-minio/README.md +++ b/profiling/kafka/kafka-minio/README.md @@ -124,6 +124,18 @@ docker run --rm -ti \ In this case we are allocating 128 Mb Memory to the container and 0.25% cpus. +## Running this profiling example with Camel-Jbang + +You could also leveraging the camel-jbang module. From Camel 3.15.0 (still to be released) it will support the profiling feature. + +What you need to do is simply running this commands: + +```shell script +jbang -Dcamel.jbang.version=3.15.0-SNAPSHOT camel@apache/camel run --jfr-profile=profile data/sources/camel-jbang-route.yaml +``` + +You'll get at jfr recording file once the application will be stopped in your working directory. + ## HEAP Sizing In the pom you can also set a different Heap Size. The default is 64 Mb.
[camel-performance-tests] branch main updated (d34de70 -> 7e9e2c2)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git.
from d34de70 Kafka to Azure Storage Blob: Added a camel-jbang section to
the README
new 2c73a56 Kafka to Azure Storage Blob with Exchange pooling: Added a
camel-jbang section to the README
new 7e9e2c2 Kafka to Azure Storage Blob with Exchange pooling: Added a
camel-jbang route
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:
.../kafka-azure-storage-blob-exchange-pooling/README.md | 12
.../data/sources/camel-jbang-route.yaml | 0
2 files changed, 12 insertions(+)
copy profiling/kafka/{kafka-azure-storage-blob =>
kafka-azure-storage-blob-exchange-pooling}/data/sources/camel-jbang-route.yaml
(100%)
[GitHub] [camel-performance-tests] oscerd merged pull request #82: Kafka Azure Storage Blob Exchange Pooling Profling camel-jbang
oscerd merged pull request #82: URL: https://github.com/apache/camel-performance-tests/pull/82 -- 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-performance-tests] 02/02: Kafka to Azure Storage Blob with Exchange pooling: Added a camel-jbang route
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit 7e9e2c2100117ba86fdd0cfdce4823087fc11f97 Author: Andrea Cosentino AuthorDate: Thu Jan 20 14:23:24 2022 +0100 Kafka to Azure Storage Blob with Exchange pooling: Added a camel-jbang route --- .../data/sources/camel-jbang-route.yaml| 24 ++ 1 file changed, 24 insertions(+) diff --git a/profiling/kafka/kafka-azure-storage-blob-exchange-pooling/data/sources/camel-jbang-route.yaml b/profiling/kafka/kafka-azure-storage-blob-exchange-pooling/data/sources/camel-jbang-route.yaml new file mode 100644 index 000..cc557f3 --- /dev/null +++ b/profiling/kafka/kafka-azure-storage-blob-exchange-pooling/data/sources/camel-jbang-route.yaml @@ -0,0 +1,24 @@ +# +# 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. +# + +- route: +from: + uri: "kamelet:kafka-not-secured-source" + steps: +- to: +uri: "kamelet:azure-storage-blob-sink" +
[camel-performance-tests] 01/02: Kafka to Azure Storage Blob with Exchange pooling: Added a camel-jbang section to the README
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit 2c73a566a8cfc23b12b4544591a3030f810a82d2 Author: Andrea Cosentino AuthorDate: Thu Jan 20 14:21:36 2022 +0100 Kafka to Azure Storage Blob with Exchange pooling: Added a camel-jbang section to the README --- .../kafka-azure-storage-blob-exchange-pooling/README.md | 12 1 file changed, 12 insertions(+) diff --git a/profiling/kafka/kafka-azure-storage-blob-exchange-pooling/README.md b/profiling/kafka/kafka-azure-storage-blob-exchange-pooling/README.md index aa15705..2b319e5 100644 --- a/profiling/kafka/kafka-azure-storage-blob-exchange-pooling/README.md +++ b/profiling/kafka/kafka-azure-storage-blob-exchange-pooling/README.md @@ -113,6 +113,18 @@ docker run --rm -ti \ In this case we are allocating 128 Mb Memory to the container and 0.25% cpus. +## Running this profiling example with Camel-Jbang + +You could also leveraging the camel-jbang module. From Camel 3.15.0 (still to be released) it will support the profiling feature. + +What you need to do is simply running this commands: + +```shell script +jbang -Dcamel.jbang.version=3.15.0-SNAPSHOT camel@apache/camel run --jfr-profile=profile data/sources/camel-jbang-route.yaml +``` + +You'll get at jfr recording file once the application will be stopped in your working directory. + ## Send messages to Kafka You'll need also kafkacat to be able to inject the filename header and use the burst script
[GitHub] [camel-performance-tests] oscerd opened a new pull request #82: Kafka Azure Storage Blob Exchange Pooling Profling camel-jbang
oscerd opened a new pull request #82: URL: https://github.com/apache/camel-performance-tests/pull/82 Related to #81 -- 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-performance-tests] 01/02: Kafka to Azure Storage Blob with Exchange pooling: Added a camel-jbang section to the README
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch k-az-blob-ex-pooling-jbang in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit 9482b6d38e7f419338e50d7fc28e770dc6c37e8e Author: Andrea Cosentino AuthorDate: Thu Jan 20 14:21:36 2022 +0100 Kafka to Azure Storage Blob with Exchange pooling: Added a camel-jbang section to the README --- .../kafka-azure-storage-blob-exchange-pooling/README.md | 12 1 file changed, 12 insertions(+) diff --git a/profiling/kafka/kafka-azure-storage-blob-exchange-pooling/README.md b/profiling/kafka/kafka-azure-storage-blob-exchange-pooling/README.md index aa15705..2b319e5 100644 --- a/profiling/kafka/kafka-azure-storage-blob-exchange-pooling/README.md +++ b/profiling/kafka/kafka-azure-storage-blob-exchange-pooling/README.md @@ -113,6 +113,18 @@ docker run --rm -ti \ In this case we are allocating 128 Mb Memory to the container and 0.25% cpus. +## Running this profiling example with Camel-Jbang + +You could also leveraging the camel-jbang module. From Camel 3.15.0 (still to be released) it will support the profiling feature. + +What you need to do is simply running this commands: + +```shell script +jbang -Dcamel.jbang.version=3.15.0-SNAPSHOT camel@apache/camel run --jfr-profile=profile data/sources/camel-jbang-route.yaml +``` + +You'll get at jfr recording file once the application will be stopped in your working directory. + ## Send messages to Kafka You'll need also kafkacat to be able to inject the filename header and use the burst script
[camel-performance-tests] 02/02: Kafka to Azure Storage Blob with Exchange pooling: Added a camel-jbang route
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch k-az-blob-ex-pooling-jbang in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit 73b3d65fdf48af97e2fe87454cc9ae53e2987e15 Author: Andrea Cosentino AuthorDate: Thu Jan 20 14:23:24 2022 +0100 Kafka to Azure Storage Blob with Exchange pooling: Added a camel-jbang route --- .../data/sources/camel-jbang-route.yaml| 24 ++ 1 file changed, 24 insertions(+) diff --git a/profiling/kafka/kafka-azure-storage-blob-exchange-pooling/data/sources/camel-jbang-route.yaml b/profiling/kafka/kafka-azure-storage-blob-exchange-pooling/data/sources/camel-jbang-route.yaml new file mode 100644 index 000..cc557f3 --- /dev/null +++ b/profiling/kafka/kafka-azure-storage-blob-exchange-pooling/data/sources/camel-jbang-route.yaml @@ -0,0 +1,24 @@ +# +# 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. +# + +- route: +from: + uri: "kamelet:kafka-not-secured-source" + steps: +- to: +uri: "kamelet:azure-storage-blob-sink" +
