[camel-performance-tests] branch k-az-blob-ex-pooling-jbang created (now 73b3d65)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch k-az-blob-ex-pooling-jbang in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git. at 73b3d65 Kafka to Azure Storage Blob with Exchange pooling: Added a camel-jbang route This branch includes the following new commits: new 9482b6d Kafka to Azure Storage Blob with Exchange pooling: Added a camel-jbang section to the README new 73b3d65 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.
[GitHub] [camel] oscerd commented on pull request #6792: CAMEL-17503: fix websocket client unable to reconnect to Server after…
oscerd commented on pull request #6792: URL: https://github.com/apache/camel/pull/6792#issuecomment-1017494000 @davsclaus sadly in this case won't work. The branch needs to be on the same repository of the action and the commit should be just one. It usally creates the PR once the PR has been merged, but in this case it shouldn't have the permissions to do it. -- 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-1017492397 @oscerd how does those backport labels work? Will the bot automatic create PRs after this PR is merged or how? -- 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] 02/02: deadLetterChannel does not work in BaseRouteBuilder configure method #3436
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch camel-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit e35c2c4e3cbc3e5a685fae34213eb2831e9ed51c
Author: JiriOndrusek
AuthorDate: Mon Jan 10 13:26:13 2022 +0100
deadLetterChannel does not work in BaseRouteBuilder configure method #3436
---
.../it/Aws2SqsQuarkusClientTestEnvCustomizer.java | 3 ++
.../component/aws2/sqs/it/DeadLetterBuilder.java | 41 ++
.../quarkus/component/aws2/sqs/it/Aws2SqsTest.java | 20 +++
.../aws2/sqs/it/Aws2SqsTestEnvCustomizer.java | 23 +++-
4 files changed, 86 insertions(+), 1 deletion(-)
diff --git
a/integration-test-groups/aws2-quarkus-client/aws2-sqs/src/test/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsQuarkusClientTestEnvCustomizer.java
b/integration-test-groups/aws2-quarkus-client/aws2-sqs/src/test/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsQuarkusClientTestEnvCustomizer.java
index 361459f..64e290d 100644
---
a/integration-test-groups/aws2-quarkus-client/aws2-sqs/src/test/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsQuarkusClientTestEnvCustomizer.java
+++
b/integration-test-groups/aws2-quarkus-client/aws2-sqs/src/test/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsQuarkusClientTestEnvCustomizer.java
@@ -34,6 +34,9 @@ public class Aws2SqsQuarkusClientTestEnvCustomizer extends
Aws2SqsTestEnvCustomi
super.customize(envContext);
+//remove camel properties for client creation to ensure that client is
not created by camel component
+envContext.removeClient(localstackServices());
+
Map envContextProperties = envContext.getProperies();
envContext.property("quarkus.sqs.aws.credentials.static-provider.access-key-id",
envContext.getAccessKey());
diff --git
a/integration-test-groups/aws2/aws2-sqs/src/main/java/org/apache/camel/quarkus/component/aws2/sqs/it/DeadLetterBuilder.java
b/integration-test-groups/aws2/aws2-sqs/src/main/java/org/apache/camel/quarkus/component/aws2/sqs/it/DeadLetterBuilder.java
new file mode 100644
index 000..6d611ef
--- /dev/null
+++
b/integration-test-groups/aws2/aws2-sqs/src/main/java/org/apache/camel/quarkus/component/aws2/sqs/it/DeadLetterBuilder.java
@@ -0,0 +1,41 @@
+/*
+ * 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.quarkus.component.aws2.sqs.it;
+
+import javax.enterprise.context.ApplicationScoped;
+
+import org.apache.camel.builder.RouteBuilder;
+import org.eclipse.microprofile.config.ConfigProvider;
+
+@ApplicationScoped
+public class DeadLetterBuilder extends RouteBuilder {
+
+@Override
+public void configure() {
+String name =
ConfigProvider.getConfig().getValue("aws-sqs.failing-name", String.class);
+String deadLetterName =
ConfigProvider.getConfig().getValue("aws-sqs.deadletter-name", String.class);
+errorHandler(deadLetterChannel("aws2-sqs://" + deadLetterName)
+.log("Error processing message and sending to the Dead Letter
Queue: Body: " + body())
+.useOriginalMessage());
+
+from("aws2-sqs://" + name)
+.process(e -> {
+throw new IllegalArgumentException();
+});
+
+}
+}
diff --git
a/integration-test-groups/aws2/aws2-sqs/src/test/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsTest.java
b/integration-test-groups/aws2/aws2-sqs/src/test/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsTest.java
index b0a928b..87d924e 100644
---
a/integration-test-groups/aws2/aws2-sqs/src/test/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsTest.java
+++
b/integration-test-groups/aws2/aws2-sqs/src/test/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsTest.java
@@ -55,6 +55,14 @@ class Aws2SqsTest {
return ConfigProvider.getConfig().getValue("aws-sqs.queue-name",
String.class);
}
+private String getPredefinedFailingQueueName() {
+return ConfigProvider.getConfig().getValue("aws-sqs.failing-name",
String.class);
+}
+
+private String getPredefinedDeadletterQueueName() {
[camel-quarkus] branch camel-main updated (9fd3ca9 -> e35c2c4)
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a change to branch camel-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git.
discard 9fd3ca9 Update to latest Camel API changes
discard 2e41db8 deadLetterChannel does not work in BaseRouteBuilder configure
method #3436
discard 926757e Update to latest Camel API changes
discard ec1f387 Update to latest Camel API changes
discard cbbe496 Enable fhir tests Fixes #3416
discard e952c17 Update to latest Camel API changes
discard 137b93d Disable Fhir tests
discard dbfcc5a Upgrade Yaml Routes to Yaml 3.15 style
discard b01cca9 ⬆️ Upgrade to Camel 3.15
add 4b8f4d2 Updated CHANGELOG.md
add 3fdf723 Updated CHANGELOG.md
add 193d8d3 Updated CHANGELOG.md
add a2017c8 aws2-quarkus-client Verify that no client except quarkus one
is used during test #3447
add 6cad4cc Ban netty-all #3464
add ca8ad1c Refactor aws2-quarkus-client-ddb(s3) by copying files (not
duplicating) #3236
add 3f0f0c7 Update Salesforce Integration tests to Salesforce API upgrade
add 080bded Improve documentation on setting up the Salesforce
developer account
add ce20ec1 Updated CHANGELOG.md
add c060ee3 Upgrade Quarkus to 2.7.0.CR1
add 0d0f0f1 java.lang.UnsatisfiedLinkError: no awt in java.library.path
in native tests
add fc97c4b Updated CHANGELOG.md
add 73ffc7e Avoid creating CamelBeanBuildItem for health checks if they
are disabled
new 92de9f5 Upgrade to Camel 3.15.0
new e35c2c4 deadLetterChannel does not work in BaseRouteBuilder configure
method #3436
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 (9fd3ca9)
\
N -- N -- N refs/heads/camel-main (e35c2c4)
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.
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:
CHANGELOG.md | 46 ++-
docs/antora.yml| 2 +-
.../{avro-jackson.yml => avroJackson.yml} | 2 +-
docs/modules/ROOT/examples/dataformats/bindy.yml | 2 +-
.../{gzipdeflater.yml => gzipDeflater.yml} | 2 +-
.../dataformats/{jacksonxml.yml => jacksonXml.yml} | 4 +-
.../{mime-multipart.yml => mimeMultipart.yml} | 2 +-
.../{protobuf-jackson.yml => protobufJackson.yml} | 2 +-
.../{yaml-snakeyaml.yml => snakeYaml.yml} | 2 +-
.../dataformats/{soapjaxb.yml => soap.yml} | 2 +-
.../dataformats/{tarfile.yml => tarFile.yml} | 2 +-
.../{univocity-csv.yml => univocityCsv.yml}| 2 +-
.../{univocity-fixed.yml => univocityFixed.yml}| 2 +-
.../{univocity-tsv.yml => univocityTsv.yml}| 2 +-
.../dataformats/{secureXML.yml => xmlSecurity.yml} | 2 +-
.../{zipdeflater.yml => zipDeflater.yml} | 4 +-
.../dataformats/{zipfile.yml => zipFile.yml} | 2 +-
.../pages/reference/extensions/jackson-avro.adoc | 2 +-
.../reference/extensions/jackson-protobuf.adoc | 2 +-
.../pages/reference/extensions/jacksonxml.adoc | 2 +-
.../ROOT/pages/reference/extensions/mail.adoc | 2 +-
.../ROOT/pages/reference/extensions/snakeyaml.adoc | 2 +-
.../ROOT/pages/reference/extensions/soap.adoc | 2 +-
.../ROOT/pages/reference/extensions/tarfile.adoc | 2 +-
.../reference/extensions/univocity-parsers.adoc| 6 +-
.../pages/reference/extensions/xmlsecurity.adoc| 2 +-
.../pages/reference/extensions/zip-deflater.adoc | 4 +-
.../ROOT/pages/reference/extensions/zipfile.adoc | 2 +-
...ver.java => CamelQuarkusBeanPostProcessor.java} | 24 +-
.../camel/quarkus/core/FastCamelContext.java | 4 +-
extensions-jvm/corda/runtime/pom.xml | 4 +
extensions-jvm/hdfs/deployment/pom.xml | 4 +
extensions-jvm/hdfs/runtime/pom.xml| 10 +
extensions-jvm/spark/bom/pom.xml | 12 +
extensions-jvm/spark/runtime/pom.xml | 4 +
.../support/bouncycastle/BouncyCastleRecorder.java | 7 +
.../deployment/MicroProfileHealthProcessor.java| 125 +---
...MicroProfileHealthCamelChecksDisabledTest.java} | 38 ++-
.../deployment/MicroProfileHealthEnabledTest.java | 37 ++-
[camel-quarkus] 01/02: Upgrade to Camel 3.15.0
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch camel-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 92de9f5a6129d0d906c6412314f4797ec9a370a3
Author: Zineb Bendhiba
AuthorDate: Wed Dec 22 16:16:52 2021 +0100
Upgrade to Camel 3.15.0
---
catalog/pom.xml| 13 ---
docs/antora.yml| 6 +-
.../ROOT/examples/components/atomix-map.yml| 2 +-
.../ROOT/examples/components/atomix-messaging.yml | 2 +-
.../ROOT/examples/components/atomix-multimap.yml | 2 +-
.../ROOT/examples/components/atomix-queue.yml | 2 +-
.../ROOT/examples/components/atomix-set.yml| 2 +-
.../ROOT/examples/components/atomix-value.yml | 2 +-
.../ROOT/examples/components/azure-eventhubs.yml | 2 +-
.../examples/components/azure-storage-blob.yml | 2 +-
.../examples/components/azure-storage-datalake.yml | 2 +-
.../examples/components/azure-storage-queue.yml| 2 +-
.../modules/ROOT/examples/components/beanstalk.yml | 2 +-
docs/modules/ROOT/examples/components/elsql.yml| 2 +-
.../modules/ROOT/examples/components/etcd-keys.yml | 2 +-
.../ROOT/examples/components/etcd-stats.yml| 2 +-
.../ROOT/examples/components/etcd-watch.yml| 2 +-
docs/modules/ROOT/examples/components/ganglia.yml | 2 +-
docs/modules/ROOT/examples/components/ipfs.yml | 2 +-
docs/modules/ROOT/examples/components/jing.yml | 2 +-
.../ROOT/examples/components/json-patch.yml| 2 +-
.../ROOT/examples/components/kamelet-reify.yml | 13 ---
.../ROOT/examples/components/milo-browse.yml | 13 +++
docs/modules/ROOT/examples/components/msv.yml | 2 +-
docs/modules/ROOT/examples/components/nagios.yml | 2 +-
docs/modules/ROOT/examples/components/nsq.yml | 2 +-
docs/modules/ROOT/examples/components/sip.yml | 2 +-
docs/modules/ROOT/examples/components/soroush.yml | 2 +-
docs/modules/ROOT/examples/components/yammer.yml | 2 +-
.../{avro-jackson.yml => avroJackson.yml} | 2 +-
docs/modules/ROOT/examples/dataformats/beanio.yml | 2 +-
docs/modules/ROOT/examples/dataformats/bindy.yml | 2 +-
.../{gzipdeflater.yml => gzipDeflater.yml} | 2 +-
.../dataformats/{jacksonxml.yml => jacksonXml.yml} | 4 +-
.../{mime-multipart.yml => mimeMultipart.yml} | 2 +-
.../{protobuf-jackson.yml => protobufJackson.yml} | 2 +-
.../{yaml-snakeyaml.yml => snakeYaml.yml} | 2 +-
.../dataformats/{soapjaxb.yml => soap.yml} | 2 +-
.../dataformats/{tarfile.yml => tarFile.yml} | 2 +-
.../{univocity-csv.yml => univocityCsv.yml}| 2 +-
.../{univocity-fixed.yml => univocityFixed.yml}| 2 +-
.../{univocity-tsv.yml => univocityTsv.yml}| 2 +-
.../dataformats/{secureXML.yml => xmlSecurity.yml} | 2 +-
.../{zipdeflater.yml => zipDeflater.yml} | 4 +-
.../dataformats/{zipfile.yml => zipFile.yml} | 2 +-
docs/modules/ROOT/nav.adoc | 1 -
.../ROOT/pages/reference/extensions/atomix.adoc| 6 +-
.../ROOT/pages/reference/extensions/beanio.adoc| 6 +-
.../ROOT/pages/reference/extensions/beanstalk.adoc | 6 +-
.../ROOT/pages/reference/extensions/elsql.adoc | 6 +-
.../ROOT/pages/reference/extensions/etcd.adoc | 6 +-
.../ROOT/pages/reference/extensions/ganglia.adoc | 6 +-
.../ROOT/pages/reference/extensions/ipfs.adoc | 6 +-
.../pages/reference/extensions/jackson-avro.adoc | 2 +-
.../reference/extensions/jackson-protobuf.adoc | 2 +-
.../pages/reference/extensions/jacksonxml.adoc | 2 +-
.../ROOT/pages/reference/extensions/jing.adoc | 6 +-
.../pages/reference/extensions/kamelet-reify.adoc | 35 ---
.../ROOT/pages/reference/extensions/mail.adoc | 2 +-
.../ROOT/pages/reference/extensions/milo.adoc | 1 +
.../ROOT/pages/reference/extensions/msv.adoc | 6 +-
.../ROOT/pages/reference/extensions/nagios.adoc| 6 +-
.../ROOT/pages/reference/extensions/nsq.adoc | 6 +-
.../ROOT/pages/reference/extensions/sip.adoc | 6 +-
.../ROOT/pages/reference/extensions/snakeyaml.adoc | 2 +-
.../ROOT/pages/reference/extensions/soap.adoc | 2 +-
.../ROOT/pages/reference/extensions/soroush.adoc | 6 +-
.../ROOT/pages/reference/extensions/tarfile.adoc | 2 +-
.../reference/extensions/univocity-parsers.adoc| 6 +-
.../pages/reference/extensions/xmlsecurity.adoc| 2 +-
.../ROOT/pages/reference/extensions/yammer.adoc| 6 +-
.../pages/reference/extensions/zip-deflater.adoc | 4 +-
.../ROOT/pages/reference/extensions/zipfile.adoc | 2 +-
extensions-jvm/kamelet-reify/deployment/pom.xml| 61
.../reify/deployment/KameletReifyProcessor.java| 46 -
extensions-jvm/kamelet-reify/pom.xml | 37
[camel] branch regen_bot updated (f23b5f715 -> 8c64bb7)
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 f23b5f715 camel-google-mail: Ensure google-oauth-client is aligned with the other google-api-client dependencies add 8c64bb7 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(-)
[camel] branch regen_bot updated (dc1c250 -> f23b5f715)
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 dc1c250 [CAMEL-17391] Update elasticsearch-rest documentation
add cc68891 CAMEL-15562: reorganize code to simplify providing
out-of-the-box resume strategies
add 9bdbf7b CAMEL-15562: created a commit manager in camel-kafka
add 2d46024 (chores) camel-kafka: rework the commit management
add d65d574 (chores) camel-kafka: simplify and abstract the creation of
custom commit factories
add 66497dd (chores) camel-kafka: minor documentation fix
add f23b5f715 camel-google-mail: Ensure google-oauth-client is aligned
with the other google-api-client dependencies
No new revisions were added by this update.
Summary of changes:
.../org/apache/camel/catalog/components/kafka.json | 4 +-
components/camel-google/camel-google-mail/pom.xml | 9 ++
.../component/kafka/KafkaComponentConfigurer.java | 4 +-
.../component/kafka/KafkaEndpointConfigurer.java | 4 +-
.../org/apache/camel/component/kafka/kafka.json| 4 +-
.../camel-kafka/src/main/docs/kafka-component.adoc | 2 +-
.../camel/component/kafka/KafkaComponent.java | 3 +
.../camel/component/kafka/KafkaConfiguration.java | 1 +
.../camel/component/kafka/KafkaEndpoint.java | 2 +
.../camel/component/kafka/KafkaFetchRecords.java | 38 ++
.../kafka/consumer/AbstractCommitManager.java | 92 +++
.../kafka/consumer/AsyncCommitManager.java | 88 ++
.../CommitManager.java}| 34 +++---
.../component/kafka/consumer/CommitManagers.java | 53 +
.../kafka/consumer/CommitToOffsetManager.java | 80 +
.../DefaultKafkaManualAsyncCommit.java | 25 ++--
.../DefaultKafkaManualAsyncCommitFactory.java | 19 ++-
.../{ => consumer}/DefaultKafkaManualCommit.java | 63 ++
.../DefaultKafkaManualCommitFactory.java | 18 ++-
.../DefaultKafkaManualSyncCommit.java | 18 ++-
.../{ => consumer}/KafkaAsyncManualCommit.java | 2 +-
.../kafka/{ => consumer}/KafkaManualCommit.java| 2 +-
.../kafka/consumer/KafkaManualCommitFactory.java | 82 +
.../kafka/consumer/NoopCommitManager.java | 52
.../kafka/consumer/SyncCommitManager.java | 71 +++
.../consumer/support/KafkaRecordProcessor.java | 131 ++---
.../support/KafkaRecordProcessorFacade.java| 20 ++--
.../support/PartitionAssignmentListener.java | 12 +-
.../kafka/consumer/support/ProcessingResult.java | 4 +-
.../KafkaConsumerAsyncManualCommitIT.java | 6 +-
.../integration/KafkaConsumerManualCommitIT.java | 2 +-
.../ROOT/pages/camel-3x-upgrade-guide-3_15.adoc| 15 +++
.../dsl/KafkaComponentBuilderFactory.java | 6 +-
.../endpoint/dsl/KafkaEndpointBuilderFactory.java | 6 +-
34 files changed, 710 insertions(+), 262 deletions(-)
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/AbstractCommitManager.java
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/AsyncCommitManager.java
rename
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{KafkaManualCommitFactory.java
=> consumer/CommitManager.java} (57%)
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/CommitManagers.java
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/CommitToOffsetManager.java
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{
=> consumer}/DefaultKafkaManualAsyncCommit.java (69%)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{
=> consumer}/DefaultKafkaManualAsyncCommitFactory.java (64%)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{
=> consumer}/DefaultKafkaManualCommit.java (52%)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{
=> consumer}/DefaultKafkaManualCommitFactory.java (64%)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{
=> consumer}/DefaultKafkaManualSyncCommit.java (71%)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{
=> consumer}/KafkaAsyncManualCommit.java (95%)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{
=> consumer}/KafkaManualCommit.java (95%)
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/KafkaManualCommitFactory.java
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/NoopCommitManager.java
create mode 100644
[camel] branch regen_bot updated (66497dd -> dc1c250)
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 66497dd (chores) camel-kafka: minor documentation fix
omit d65d574 (chores) camel-kafka: simplify and abstract the creation of
custom commit factories
omit 2d46024 (chores) camel-kafka: rework the commit management
omit 9bdbf7b CAMEL-15562: created a commit manager in camel-kafka
omit cc68891 CAMEL-15562: reorganize code to simplify providing
out-of-the-box resume strategies
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 (dc1c250)
\
O -- O -- O (66497dd)
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:
.../org/apache/camel/catalog/components/kafka.json | 4 +-
.../component/kafka/KafkaComponentConfigurer.java | 4 +-
.../component/kafka/KafkaEndpointConfigurer.java | 4 +-
.../org/apache/camel/component/kafka/kafka.json| 4 +-
.../camel-kafka/src/main/docs/kafka-component.adoc | 2 +-
.../DefaultKafkaManualAsyncCommit.java | 25 ++--
.../DefaultKafkaManualAsyncCommitFactory.java | 19 +--
.../{consumer => }/DefaultKafkaManualCommit.java | 63 --
.../DefaultKafkaManualCommitFactory.java | 18 +--
.../DefaultKafkaManualSyncCommit.java | 18 +--
.../{consumer => }/KafkaAsyncManualCommit.java | 2 +-
.../camel/component/kafka/KafkaComponent.java | 3 -
.../camel/component/kafka/KafkaConfiguration.java | 1 -
.../camel/component/kafka/KafkaEndpoint.java | 2 -
.../camel/component/kafka/KafkaFetchRecords.java | 38 --
.../kafka/{consumer => }/KafkaManualCommit.java| 2 +-
...tManager.java => KafkaManualCommitFactory.java} | 34 +++---
.../kafka/consumer/AbstractCommitManager.java | 92 ---
.../kafka/consumer/AsyncCommitManager.java | 88 --
.../component/kafka/consumer/CommitManagers.java | 53 -
.../kafka/consumer/CommitToOffsetManager.java | 80 -
.../kafka/consumer/KafkaManualCommitFactory.java | 82 -
.../kafka/consumer/NoopCommitManager.java | 52
.../kafka/consumer/SyncCommitManager.java | 71 ---
.../consumer/support/KafkaRecordProcessor.java | 131 +++--
.../support/KafkaRecordProcessorFacade.java| 20 ++--
.../support/PartitionAssignmentListener.java | 12 +-
.../kafka/consumer/support/ProcessingResult.java | 4 +-
.../KafkaConsumerAsyncManualCommitIT.java | 6 +-
.../integration/KafkaConsumerManualCommitIT.java | 2 +-
.../ROOT/pages/camel-3x-upgrade-guide-3_15.adoc| 15 ---
.../dsl/KafkaComponentBuilderFactory.java | 6 +-
.../endpoint/dsl/KafkaEndpointBuilderFactory.java | 6 +-
33 files changed, 262 insertions(+), 701 deletions(-)
rename
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{consumer
=> }/DefaultKafkaManualAsyncCommit.java (69%)
rename
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{consumer
=> }/DefaultKafkaManualAsyncCommitFactory.java (64%)
rename
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{consumer
=> }/DefaultKafkaManualCommit.java (52%)
rename
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{consumer
=> }/DefaultKafkaManualCommitFactory.java (64%)
rename
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{consumer
=> }/DefaultKafkaManualSyncCommit.java (71%)
rename
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{consumer
=> }/KafkaAsyncManualCommit.java (95%)
rename
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{consumer
=> }/KafkaManualCommit.java (95%)
rename
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{consumer/CommitManager.java
=> KafkaManualCommitFactory.java} (57%)
delete mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/AbstractCommitManager.java
delete mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/AsyncCommitManager.java
delete mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/CommitManagers.java
delete mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/CommitToOffsetManager.java
delete mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/KafkaManualCommitFactory.java
delete mode 100644
[camel] branch regen_bot updated (ff16877 -> 66497dd)
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 ff16877 CAMEL-17510: camel-yaml-dsl - Generate json schema in
camelCase
add 5cc4c57 [CAMEL-17391] Update elasticsearch-rest documentation (#6759)
add dc1c250 [CAMEL-17391] Update elasticsearch-rest documentation
add cc68891 CAMEL-15562: reorganize code to simplify providing
out-of-the-box resume strategies
add 9bdbf7b CAMEL-15562: created a commit manager in camel-kafka
add 2d46024 (chores) camel-kafka: rework the commit management
add d65d574 (chores) camel-kafka: simplify and abstract the creation of
custom commit factories
add 66497dd (chores) camel-kafka: minor documentation fix
No new revisions were added by this update.
Summary of changes:
.../catalog/components/elasticsearch-rest.json | 4 +-
.../org/apache/camel/catalog/components/kafka.json | 4 +-
.../elasticsearch/elasticsearch-rest.json | 4 +-
.../main/docs/elasticsearch-rest-component.adoc| 10 ++
.../elasticsearch/ElasticsearchComponent.java | 3 +-
.../elasticsearch/ElasticsearchConfiguration.java | 3 +-
.../component/kafka/KafkaComponentConfigurer.java | 4 +-
.../component/kafka/KafkaEndpointConfigurer.java | 4 +-
.../org/apache/camel/component/kafka/kafka.json| 4 +-
.../camel-kafka/src/main/docs/kafka-component.adoc | 2 +-
.../camel/component/kafka/KafkaComponent.java | 3 +
.../camel/component/kafka/KafkaConfiguration.java | 1 +
.../camel/component/kafka/KafkaEndpoint.java | 2 +
.../camel/component/kafka/KafkaFetchRecords.java | 38 ++
.../kafka/consumer/AbstractCommitManager.java | 92 +++
.../kafka/consumer/AsyncCommitManager.java | 88 ++
.../CommitManager.java}| 34 +++---
.../component/kafka/consumer/CommitManagers.java | 53 +
.../kafka/consumer/CommitToOffsetManager.java | 80 +
.../DefaultKafkaManualAsyncCommit.java | 25 ++--
.../DefaultKafkaManualAsyncCommitFactory.java | 19 ++-
.../{ => consumer}/DefaultKafkaManualCommit.java | 63 ++
.../DefaultKafkaManualCommitFactory.java | 18 ++-
.../DefaultKafkaManualSyncCommit.java | 18 ++-
.../{ => consumer}/KafkaAsyncManualCommit.java | 2 +-
.../kafka/{ => consumer}/KafkaManualCommit.java| 2 +-
.../kafka/consumer/KafkaManualCommitFactory.java | 82 +
.../kafka/consumer/NoopCommitManager.java | 52
.../kafka/consumer/SyncCommitManager.java | 71 +++
.../consumer/support/KafkaRecordProcessor.java | 131 ++---
.../support/KafkaRecordProcessorFacade.java| 20 ++--
.../support/PartitionAssignmentListener.java | 12 +-
.../kafka/consumer/support/ProcessingResult.java | 4 +-
.../KafkaConsumerAsyncManualCommitIT.java | 6 +-
.../integration/KafkaConsumerManualCommitIT.java | 2 +-
.../ROOT/pages/camel-3x-upgrade-guide-3_15.adoc| 15 +++
.../ElasticsearchRestComponentBuilderFactory.java | 4 +-
.../dsl/KafkaComponentBuilderFactory.java | 6 +-
.../dsl/ElasticsearchEndpointBuilderFactory.java | 8 +-
.../endpoint/dsl/KafkaEndpointBuilderFactory.java | 6 +-
40 files changed, 728 insertions(+), 271 deletions(-)
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/AbstractCommitManager.java
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/AsyncCommitManager.java
rename
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{KafkaManualCommitFactory.java
=> consumer/CommitManager.java} (57%)
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/CommitManagers.java
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/CommitToOffsetManager.java
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{
=> consumer}/DefaultKafkaManualAsyncCommit.java (69%)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{
=> consumer}/DefaultKafkaManualAsyncCommitFactory.java (64%)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{
=> consumer}/DefaultKafkaManualCommit.java (52%)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{
=> consumer}/DefaultKafkaManualCommitFactory.java (64%)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{
=> consumer}/DefaultKafkaManualSyncCommit.java (71%)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{
=> consumer}/KafkaAsyncManualCommit.java (95%)
rename
[camel] branch regen_bot updated (c88ebc5 -> ff16877)
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 c88ebc5 CAMEL-17510: camel-yaml-dsl - Generate json schema in camelCase add ff16877 CAMEL-17510: camel-yaml-dsl - Generate json schema in camelCase No new revisions were added by this update. Summary of changes: .../maven/dsl/yaml/GenerateYamlSchemaMojo.java | 29 ++-- .../src/generated/resources/camelYamlDsl.json | 168 +++-- 2 files changed, 71 insertions(+), 126 deletions(-)
[camel] branch main 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 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 8c64bb7 CAMEL-17519: Expose MainSupprt.internalBeforeStart so that it
can be overridden
8c64bb7 is described below
commit 8c64bb76d8fecefb8f0b21d568979cb963d07072
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();
[GitHub] [camel] jamesnetherton merged pull request #6794: CAMEL-17519: Expose MainSupprt.internalBeforeStart so that it can be overridden
jamesnetherton merged pull request #6794: URL: https://github.com/apache/camel/pull/6794 -- 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 (66497dd -> f23b5f715)
This is an automated email from the ASF dual-hosted git repository. jamesnetherton pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel.git. from 66497dd (chores) camel-kafka: minor documentation fix add f23b5f715 camel-google-mail: Ensure google-oauth-client is aligned with the other google-api-client dependencies No new revisions were added by this update. Summary of changes: components/camel-google/camel-google-mail/pom.xml | 9 + 1 file changed, 9 insertions(+)
[camel] 04/05: (chores) camel-kafka: simplify and abstract the creation of custom commit factories
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit d65d574a093b64a99c29850d9bafb5abffbf9e6e
Author: Otavio Rodolfo Piske
AuthorDate: Thu Jan 20 09:26:04 2022 +0100
(chores) camel-kafka: simplify and abstract the creation of custom commit
factories
---
.../kafka/consumer/AbstractCommitManager.java | 30 ---
.../kafka/consumer/AsyncCommitManager.java | 8 +--
.../consumer/DefaultKafkaManualAsyncCommit.java| 21 +++-
.../DefaultKafkaManualAsyncCommitFactory.java | 17 +-
.../kafka/consumer/DefaultKafkaManualCommit.java | 61 +-
.../consumer/DefaultKafkaManualCommitFactory.java | 16 +-
.../consumer/DefaultKafkaManualSyncCommit.java | 13 ++---
.../kafka/consumer/KafkaManualCommitFactory.java | 44
.../ROOT/pages/camel-3x-upgrade-guide-3_15.adoc| 2 +
9 files changed, 147 insertions(+), 65 deletions(-)
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/AbstractCommitManager.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/AbstractCommitManager.java
index a982cbf..7923835 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/AbstractCommitManager.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/AbstractCommitManager.java
@@ -18,6 +18,7 @@
package org.apache.camel.component.kafka.consumer;
import java.time.Duration;
+import java.util.Collection;
import java.util.Collections;
import org.apache.camel.Exchange;
@@ -33,14 +34,15 @@ import org.slf4j.LoggerFactory;
public abstract class AbstractCommitManager implements CommitManager {
public static final long START_OFFSET = -1;
-
private static final Logger LOG =
LoggerFactory.getLogger(AbstractCommitManager.class);
-private final Consumer consumer;
+
protected final KafkaConsumer kafkaConsumer;
protected final String threadId;
protected final String printableTopic;
protected final KafkaConfiguration configuration;
+private final Consumer consumer;
+
public AbstractCommitManager(Consumer consumer, KafkaConsumer
kafkaConsumer, String threadId, String printableTopic) {
this.consumer = consumer;
this.kafkaConsumer = kafkaConsumer;
@@ -49,15 +51,29 @@ public abstract class AbstractCommitManager implements
CommitManager {
this.configuration = kafkaConsumer.getEndpoint().getConfiguration();
}
+protected KafkaManualCommit getManualCommit(
+Exchange exchange, TopicPartition partition,
ConsumerRecord record,
+Collection asyncCommits,
+KafkaManualCommitFactory manualCommitFactory) {
+
+StateRepository offsetRepository =
configuration.getOffsetRepository();
+long commitTimeoutMs = configuration.getCommitTimeoutMs();
+
+KafkaManualCommitFactory.CamelExchangePayload camelExchangePayload =
new KafkaManualCommitFactory.CamelExchangePayload(
+exchange, consumer, threadId, offsetRepository, asyncCommits);
+KafkaManualCommitFactory.KafkaRecordPayload kafkaRecordPayload = new
KafkaManualCommitFactory.KafkaRecordPayload(
+partition,
+record.offset(), commitTimeoutMs);
+
+return manualCommitFactory.newInstance(camelExchangePayload,
kafkaRecordPayload);
+}
+
@Override
public KafkaManualCommit getManualCommit(
Exchange exchange, TopicPartition partition,
ConsumerRecord record) {
-KafkaManualCommitFactory manualCommitFactory =
kafkaConsumer.getEndpoint().getKafkaManualCommitFactory();
-StateRepository offsetRepository =
configuration.getOffsetRepository();
-long commitTimeoutMs = configuration.getCommitTimeoutMs();
-return manualCommitFactory.newInstance(exchange, consumer,
partition.topic(), threadId,
-offsetRepository, partition, record.offset(), commitTimeoutMs,
null);
+KafkaManualCommitFactory manualCommitFactory =
kafkaConsumer.getEndpoint().getKafkaManualCommitFactory();
+return getManualCommit(exchange, partition, record, null,
manualCommitFactory);
}
@Override
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/AsyncCommitManager.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/AsyncCommitManager.java
index 26f23ba..20838c0 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/AsyncCommitManager.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/AsyncCommitManager.java
@@ -22,7 +22,6 @@ import java.util.concurrent.ConcurrentLinkedQueue;
import org.apache.camel.Exchange;
import
[camel] 05/05: (chores) camel-kafka: minor documentation fix
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 66497dd61fe100aa40dd0f86958e545862c6344a
Author: Otavio Rodolfo Piske
AuthorDate: Thu Jan 20 09:26:24 2022 +0100
(chores) camel-kafka: minor documentation fix
---
components/camel-kafka/src/main/docs/kafka-component.adoc | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/components/camel-kafka/src/main/docs/kafka-component.adoc
b/components/camel-kafka/src/main/docs/kafka-component.adoc
index 7683bbf..2fc39a6 100644
--- a/components/camel-kafka/src/main/docs/kafka-component.adoc
+++ b/components/camel-kafka/src/main/docs/kafka-component.adoc
@@ -400,7 +400,7 @@ public void process(Exchange exchange) {
This will force a synchronous commit which will block until the commit is
acknowledge on Kafka, or if it fails an exception is thrown.
-You can use an asynchronous commit as well by configuring the
`KafkaManualCommitFactory` with the
`DefaultKafkaManualAsyncCommitFactory`implementation.
+You can use an asynchronous commit as well by configuring the
`KafkaManualCommitFactory` with the `DefaultKafkaManualAsyncCommitFactory`
implementation.
The commit will then be done in the next consumer loop using the kafka
asynchronous commit api.
Be aware that records from a partition must be processed and committed by a
unique thread.
[camel] 02/05: CAMEL-15562: created a commit manager in camel-kafka
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 9bdbf7b6b394561058a7ef7198997244f43929d0
Author: Otavio Rodolfo Piske
AuthorDate: Wed Jan 19 11:40:26 2022 +0100
CAMEL-15562: created a commit manager in camel-kafka
This reorganizes the commit management code so that we can unify managing
different commit strategies.
---
.../component/kafka/KafkaComponentConfigurer.java | 4 +-
.../component/kafka/KafkaEndpointConfigurer.java | 4 +-
.../org/apache/camel/component/kafka/kafka.json| 4 +-
.../camel/component/kafka/KafkaComponent.java | 2 +
.../camel/component/kafka/KafkaConfiguration.java | 1 +
.../camel/component/kafka/KafkaEndpoint.java | 2 +
.../camel/component/kafka/KafkaFetchRecords.java | 39 ++---
...kaAsyncManualCommit.java => CommitManager.java} | 27 ++-
.../kafka/consumer/DefaultCommitManager.java | 195 +
.../consumer/DefaultKafkaManualAsyncCommit.java| 3 +-
.../DefaultKafkaManualAsyncCommitFactory.java | 2 -
.../kafka/consumer/DefaultKafkaManualCommit.java | 1 -
.../consumer/DefaultKafkaManualCommitFactory.java | 2 -
.../consumer/DefaultKafkaManualSyncCommit.java | 4 +-
.../kafka/consumer/KafkaAsyncManualCommit.java | 2 -
.../kafka/{ => consumer}/KafkaManualCommit.java| 2 +-
.../{ => consumer}/KafkaManualCommitFactory.java | 3 +-
.../consumer/support/KafkaRecordProcessor.java | 131 +-
.../support/KafkaRecordProcessorFacade.java| 20 +--
.../support/PartitionAssignmentListener.java | 12 +-
.../kafka/consumer/support/ProcessingResult.java | 4 +-
.../KafkaConsumerAsyncManualCommitIT.java | 6 +-
.../integration/KafkaConsumerManualCommitIT.java | 2 +-
.../ROOT/pages/camel-3x-upgrade-guide-3_15.adoc| 2 +
.../dsl/KafkaComponentBuilderFactory.java | 9 +-
.../endpoint/dsl/KafkaEndpointBuilderFactory.java | 13 +-
26 files changed, 285 insertions(+), 211 deletions(-)
diff --git
a/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaComponentConfigurer.java
b/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaComponentConfigurer.java
index d8f6a58..0d5a1c2 100644
---
a/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaComponentConfigurer.java
+++
b/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaComponentConfigurer.java
@@ -91,7 +91,7 @@ public class KafkaComponentConfigurer extends
PropertyConfigurerSupport implemen
case "kafkaclientfactory":
case "kafkaClientFactory":
target.setKafkaClientFactory(property(camelContext,
org.apache.camel.component.kafka.KafkaClientFactory.class, value)); return true;
case "kafkamanualcommitfactory":
-case "kafkaManualCommitFactory":
target.setKafkaManualCommitFactory(property(camelContext,
org.apache.camel.component.kafka.KafkaManualCommitFactory.class, value));
return true;
+case "kafkaManualCommitFactory":
target.setKafkaManualCommitFactory(property(camelContext,
org.apache.camel.component.kafka.consumer.KafkaManualCommitFactory.class,
value)); return true;
case "kerberosbeforereloginmintime":
case "kerberosBeforeReloginMinTime":
getOrCreateConfiguration(target).setKerberosBeforeReloginMinTime(property(camelContext,
java.lang.Integer.class, value)); return true;
case "kerberosinitcmd":
@@ -305,7 +305,7 @@ public class KafkaComponentConfigurer extends
PropertyConfigurerSupport implemen
case "kafkaclientfactory":
case "kafkaClientFactory": return
org.apache.camel.component.kafka.KafkaClientFactory.class;
case "kafkamanualcommitfactory":
-case "kafkaManualCommitFactory": return
org.apache.camel.component.kafka.KafkaManualCommitFactory.class;
+case "kafkaManualCommitFactory": return
org.apache.camel.component.kafka.consumer.KafkaManualCommitFactory.class;
case "kerberosbeforereloginmintime":
case "kerberosBeforeReloginMinTime": return java.lang.Integer.class;
case "kerberosinitcmd":
diff --git
a/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaEndpointConfigurer.java
b/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaEndpointConfigurer.java
index 7c3ef61..270e758 100644
---
a/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaEndpointConfigurer.java
+++
b/components/camel-kafka/src/generated/java/org/apache/camel/component/kafka/KafkaEndpointConfigurer.java
@@ -85,7 +85,7 @@ public class KafkaEndpointConfigurer extends
PropertyConfigurerSupport implement
case "kafkaclientfactory":
case "kafkaClientFactory":
target.setKafkaClientFactory(property(camelContext,
[camel] 01/05: CAMEL-15562: reorganize code to simplify providing out-of-the-box resume strategies
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit cc688915bef20707e9e1be3fe72fb056058ffc0d
Author: Otavio Rodolfo Piske
AuthorDate: Tue Jan 18 15:31:11 2022 +0100
CAMEL-15562: reorganize code to simplify providing out-of-the-box resume
strategies
---
.../java/org/apache/camel/component/kafka/KafkaComponent.java | 1 +
.../org/apache/camel/component/kafka/KafkaFetchRecords.java | 1 +
.../camel/component/kafka/KafkaManualCommitFactory.java | 1 +
.../kafka/{ => consumer}/DefaultKafkaManualAsyncCommit.java | 2 +-
.../{ => consumer}/DefaultKafkaManualAsyncCommitFactory.java | 4 +++-
.../kafka/{ => consumer}/DefaultKafkaManualCommit.java| 3 ++-
.../kafka/{ => consumer}/DefaultKafkaManualCommitFactory.java | 4 +++-
.../kafka/{ => consumer}/DefaultKafkaManualSyncCommit.java| 3 ++-
.../kafka/{ => consumer}/KafkaAsyncManualCommit.java | 4 +++-
.../kafka/consumer/support/KafkaRecordProcessor.java | 2 +-
.../kafka/consumer/support/KafkaRecordProcessorFacade.java| 2 +-
.../kafka/integration/KafkaConsumerAsyncManualCommitIT.java | 2 +-
.../modules/ROOT/pages/camel-3x-upgrade-guide-3_15.adoc | 11 +++
13 files changed, 31 insertions(+), 9 deletions(-)
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaComponent.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaComponent.java
index 75e0034..abe2a0c 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaComponent.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaComponent.java
@@ -20,6 +20,7 @@ import java.util.Map;
import org.apache.camel.CamelContext;
import org.apache.camel.SSLContextParametersAware;
+import
org.apache.camel.component.kafka.consumer.DefaultKafkaManualCommitFactory;
import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.annotations.Component;
import org.apache.camel.support.DefaultComponent;
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
index 4fd454f..5b529df 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
@@ -27,6 +27,7 @@ import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.ReentrantLock;
import java.util.regex.Pattern;
+import org.apache.camel.component.kafka.consumer.KafkaAsyncManualCommit;
import
org.apache.camel.component.kafka.consumer.support.KafkaRecordProcessorFacade;
import
org.apache.camel.component.kafka.consumer.support.PartitionAssignmentListener;
import org.apache.camel.component.kafka.consumer.support.ProcessingResult;
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaManualCommitFactory.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaManualCommitFactory.java
index b0f6144..daa1213 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaManualCommitFactory.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaManualCommitFactory.java
@@ -19,6 +19,7 @@ package org.apache.camel.component.kafka;
import java.util.Collection;
import org.apache.camel.Exchange;
+import org.apache.camel.component.kafka.consumer.KafkaAsyncManualCommit;
import org.apache.camel.spi.StateRepository;
import org.apache.kafka.clients.consumer.Consumer;
import org.apache.kafka.common.TopicPartition;
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/DefaultKafkaManualAsyncCommit.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/DefaultKafkaManualAsyncCommit.java
similarity index 98%
rename from
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/DefaultKafkaManualAsyncCommit.java
rename to
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/DefaultKafkaManualAsyncCommit.java
index e9765fe..af33b0f 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/DefaultKafkaManualAsyncCommit.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/DefaultKafkaManualAsyncCommit.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.kafka;
+package org.apache.camel.component.kafka.consumer;
import java.util.Collection;
import java.util.Collections;
diff --git
[camel] 03/05: (chores) camel-kafka: rework the commit management
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 2d46024a7836e7b24dce7257a17d4f9499c48f7b
Author: Otavio Rodolfo Piske
AuthorDate: Wed Jan 19 17:14:45 2022 +0100
(chores) camel-kafka: rework the commit management
Breaks the commit management for noop, sync and async strategies and
streamline the equivalent manual commit classes so that responsibilities
boundaries are clearer
---
.../org/apache/camel/catalog/components/kafka.json | 4 +-
.../camel/component/kafka/KafkaFetchRecords.java | 6 +-
.../kafka/consumer/AbstractCommitManager.java | 76
.../kafka/consumer/AsyncCommitManager.java | 92 ++
.../component/kafka/consumer/CommitManager.java| 4 +-
.../component/kafka/consumer/CommitManagers.java | 53 ++
.../kafka/consumer/CommitToOffsetManager.java | 80 +
.../kafka/consumer/DefaultCommitManager.java | 195 -
.../consumer/DefaultKafkaManualAsyncCommit.java| 5 +-
.../consumer/DefaultKafkaManualSyncCommit.java | 2 +-
.../kafka/consumer/NoopCommitManager.java | 52 ++
.../kafka/consumer/SyncCommitManager.java | 71
.../kafka/consumer/support/ProcessingResult.java | 4 +-
.../dsl/KafkaComponentBuilderFactory.java | 7 +-
.../endpoint/dsl/KafkaEndpointBuilderFactory.java | 9 +-
15 files changed, 446 insertions(+), 214 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
[camel] branch main updated (dc1c250 -> 66497dd)
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git.
from dc1c250 [CAMEL-17391] Update elasticsearch-rest documentation
new cc68891 CAMEL-15562: reorganize code to simplify providing
out-of-the-box resume strategies
new 9bdbf7b CAMEL-15562: created a commit manager in camel-kafka
new 2d46024 (chores) camel-kafka: rework the commit management
new d65d574 (chores) camel-kafka: simplify and abstract the creation of
custom commit factories
new 66497dd (chores) camel-kafka: minor documentation fix
The 5 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 +-
.../component/kafka/KafkaComponentConfigurer.java | 4 +-
.../component/kafka/KafkaEndpointConfigurer.java | 4 +-
.../org/apache/camel/component/kafka/kafka.json| 4 +-
.../camel-kafka/src/main/docs/kafka-component.adoc | 2 +-
.../camel/component/kafka/KafkaComponent.java | 3 +
.../camel/component/kafka/KafkaConfiguration.java | 1 +
.../camel/component/kafka/KafkaEndpoint.java | 2 +
.../camel/component/kafka/KafkaFetchRecords.java | 38 ++
.../kafka/consumer/AbstractCommitManager.java | 92 +++
.../kafka/consumer/AsyncCommitManager.java | 88 ++
.../CommitManager.java}| 34 +++---
.../component/kafka/consumer/CommitManagers.java | 53 +
.../kafka/consumer/CommitToOffsetManager.java | 80 +
.../DefaultKafkaManualAsyncCommit.java | 25 ++--
.../DefaultKafkaManualAsyncCommitFactory.java | 19 ++-
.../{ => consumer}/DefaultKafkaManualCommit.java | 63 ++
.../DefaultKafkaManualCommitFactory.java | 18 ++-
.../DefaultKafkaManualSyncCommit.java | 18 ++-
.../{ => consumer}/KafkaAsyncManualCommit.java | 2 +-
.../kafka/{ => consumer}/KafkaManualCommit.java| 2 +-
.../kafka/consumer/KafkaManualCommitFactory.java | 82 +
.../kafka/consumer/NoopCommitManager.java | 52
.../kafka/consumer/SyncCommitManager.java | 71 +++
.../consumer/support/KafkaRecordProcessor.java | 131 ++---
.../support/KafkaRecordProcessorFacade.java| 20 ++--
.../support/PartitionAssignmentListener.java | 12 +-
.../kafka/consumer/support/ProcessingResult.java | 4 +-
.../KafkaConsumerAsyncManualCommitIT.java | 6 +-
.../integration/KafkaConsumerManualCommitIT.java | 2 +-
.../ROOT/pages/camel-3x-upgrade-guide-3_15.adoc| 15 +++
.../dsl/KafkaComponentBuilderFactory.java | 6 +-
.../endpoint/dsl/KafkaEndpointBuilderFactory.java | 6 +-
33 files changed, 701 insertions(+), 262 deletions(-)
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/AbstractCommitManager.java
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/AsyncCommitManager.java
rename
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{KafkaManualCommitFactory.java
=> consumer/CommitManager.java} (57%)
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/CommitManagers.java
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/CommitToOffsetManager.java
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{
=> consumer}/DefaultKafkaManualAsyncCommit.java (69%)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{
=> consumer}/DefaultKafkaManualAsyncCommitFactory.java (64%)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{
=> consumer}/DefaultKafkaManualCommit.java (52%)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{
=> consumer}/DefaultKafkaManualCommitFactory.java (64%)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{
=> consumer}/DefaultKafkaManualSyncCommit.java (71%)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{
=> consumer}/KafkaAsyncManualCommit.java (95%)
rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{
=> consumer}/KafkaManualCommit.java (95%)
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/KafkaManualCommitFactory.java
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/NoopCommitManager.java
create mode 100644
[camel] branch main updated: [CAMEL-17391] Update elasticsearch-rest documentation
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 dc1c250 [CAMEL-17391] Update elasticsearch-rest documentation
dc1c250 is described below
commit dc1c250a546caae3ad3b5595ee6e6c2f017db8e9
Author: Claus Ibsen
AuthorDate: Thu Jan 20 12:30:10 2022 +0100
[CAMEL-17391] Update elasticsearch-rest documentation
---
.../org/apache/camel/catalog/components/elasticsearch-rest.json | 4 ++--
.../apache/camel/component/elasticsearch/elasticsearch-rest.json | 4 ++--
.../camel/component/elasticsearch/ElasticsearchComponent.java | 3 ++-
.../camel/component/elasticsearch/ElasticsearchConfiguration.java | 3 ++-
.../component/dsl/ElasticsearchRestComponentBuilderFactory.java | 4 +++-
.../builder/endpoint/dsl/ElasticsearchEndpointBuilderFactory.java | 8 ++--
6 files changed, 17 insertions(+), 9 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/elasticsearch-rest.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/elasticsearch-rest.json
index 35415b6..abad0e3 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/elasticsearch-rest.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/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": "producer", "label": "", "required": false, "type": "integer",
"javaType": "int",
[GitHub] [camel] orpiske merged pull request #6793: CAMEL-15562 pre-work
orpiske merged pull request #6793: URL: https://github.com/apache/camel/pull/6793 -- 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 #6759: [CAMEL-17391] Update elasticsearch-rest documentation
davsclaus merged pull request #6759: URL: https://github.com/apache/camel/pull/6759 -- 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: CAMEL-17510: camel-yaml-dsl - Generate json schema in camelCase
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 ff16877 CAMEL-17510: camel-yaml-dsl - Generate json schema in
camelCase
ff16877 is described below
commit ff168778ef9d45071a2c3e72aa4cf81a959724e8
Author: Claus Ibsen
AuthorDate: Thu Jan 20 11:51:29 2022 +0100
CAMEL-17510: camel-yaml-dsl - Generate json schema in camelCase
---
.../maven/dsl/yaml/GenerateYamlSchemaMojo.java | 29 ++--
.../src/generated/resources/camelYamlDsl.json | 168 +++--
2 files changed, 71 insertions(+), 126 deletions(-)
diff --git
a/dsl/camel-yaml-dsl/camel-yaml-dsl-maven-plugin/src/main/java/org/apache/camel/maven/dsl/yaml/GenerateYamlSchemaMojo.java
b/dsl/camel-yaml-dsl/camel-yaml-dsl-maven-plugin/src/main/java/org/apache/camel/maven/dsl/yaml/GenerateYamlSchemaMojo.java
index 4fd34cb..af3ffad 100644
---
a/dsl/camel-yaml-dsl/camel-yaml-dsl-maven-plugin/src/main/java/org/apache/camel/maven/dsl/yaml/GenerateYamlSchemaMojo.java
+++
b/dsl/camel-yaml-dsl/camel-yaml-dsl-maven-plugin/src/main/java/org/apache/camel/maven/dsl/yaml/GenerateYamlSchemaMojo.java
@@ -126,9 +126,11 @@ public class GenerateYamlSchemaMojo extends
GenerateYamlSupportMojo {
// filter out unwanted cases when in camelCase mode
if (!kebabCase) {
-definitions.forEach(this::filterCase);
-filterCase(step);
-filterCase(root.with("items"));
+for (JsonNode definition : definitions) {
+kebabToCamelCase(definition);
+}
+kebabToCamelCase(step);
+kebabToCamelCase(root.with("items"));
}
try {
@@ -203,28 +205,27 @@ public class GenerateYamlSchemaMojo extends
GenerateYamlSupportMojo {
}
}
-private void filterCase(JsonNode node) {
+private void kebabToCamelCase(JsonNode node) {
if (node instanceof ObjectNode) {
ObjectNode on = (ObjectNode) node;
-JsonNode jn = on.with("properties");
-if (jn.isEmpty()) {
+JsonNode jn = on.get("properties");
+if (jn == null || jn.isEmpty()) {
jn = on.findPath("properties");
}
-if (jn instanceof ObjectNode) {
+if (jn != null && !jn.isEmpty() && jn instanceof ObjectNode) {
ObjectNode p = (ObjectNode) jn;
-Map keep = new LinkedHashMap<>();
-
+Map rebuild = new LinkedHashMap<>();
// the properties are in mixed kebab-case and camelCase
for (Iterator it = p.fieldNames(); it.hasNext(); ) {
String n = it.next();
String t = StringHelper.dashToCamelCase(n);
JsonNode prop = p.get(n);
-keep.put(t, prop);
+rebuild.put(t, prop);
+}
+if (!rebuild.isEmpty()) {
+p.removeAll();
+rebuild.forEach(p::set);
}
-
-// rebuild
-p.removeAll();
-keep.forEach(p::set);
}
}
}
diff --git
a/dsl/camel-yaml-dsl/camel-yaml-dsl/src/generated/resources/camelYamlDsl.json
b/dsl/camel-yaml-dsl/camel-yaml-dsl/src/generated/resources/camelYamlDsl.json
index 39d3843..02eb843 100644
---
a/dsl/camel-yaml-dsl/camel-yaml-dsl/src/generated/resources/camelYamlDsl.json
+++
b/dsl/camel-yaml-dsl/camel-yaml-dsl/src/generated/resources/camelYamlDsl.json
@@ -224,8 +224,7 @@
"type" : "boolean"
}
}
-} ],
-"properties" : { }
+} ]
},
"org.apache.camel.builder.DefaultErrorHandlerBuilder" : {
"type" : "object",
@@ -262,15 +261,13 @@
}
},
"org.apache.camel.builder.NoErrorHandlerBuilder" : {
-"type" : "object",
-"properties" : { }
+"type" : "object"
},
"org.apache.camel.dsl.yaml.deserializers.BeansDeserializer" : {
"type" : "array",
"items" : {
"$ref" :
"#/items/definitions/org.apache.camel.dsl.yaml.deserializers.NamedBeanDefinition"
-},
-"properties" : { }
+}
},
"org.apache.camel.dsl.yaml.deserializers.NamedBeanDefinition" : {
"type" : "object",
@@ -446,8 +443,7 @@
"type" : "string"
}
}
-} ],
-"properties" : { }
+} ]
},
"org.apache.camel.model.CatchDefinition" : {
"type" : "object",
@@ -588,8 +584,7 @@
}
}
} ],
-"required" : [ "type" ],
-"properties" : { }
+"required" : [ "type" ]
},
"org.apache.camel.model.DataFormatDefinition" : {
"type" : "object",
@@ -635,8
[GitHub] [camel-k] bouskaJ opened a new pull request #2895: [TEST] - check IntegrationPlatform namespace with global operator
bouskaJ opened a new pull request #2895: URL: https://github.com/apache/camel-k/pull/2895 **Release Note** ```release-note NONE ``` -- 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: CAMEL-17510: camel-yaml-dsl - Generate json schema in camelCase
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 c88ebc5 CAMEL-17510: camel-yaml-dsl - Generate json schema in
camelCase
c88ebc5 is described below
commit c88ebc5149d245b8b9b84a8fcc4e46e8debb63cd
Author: Claus Ibsen
AuthorDate: Thu Jan 20 11:33:07 2022 +0100
CAMEL-17510: camel-yaml-dsl - Generate json schema in camelCase
---
.../maven/dsl/yaml/GenerateYamlSchemaMojo.java | 47 ++-
.../src/generated/resources/camelYamlDsl.json | 96 ++
2 files changed, 119 insertions(+), 24 deletions(-)
diff --git
a/dsl/camel-yaml-dsl/camel-yaml-dsl-maven-plugin/src/main/java/org/apache/camel/maven/dsl/yaml/GenerateYamlSchemaMojo.java
b/dsl/camel-yaml-dsl/camel-yaml-dsl-maven-plugin/src/main/java/org/apache/camel/maven/dsl/yaml/GenerateYamlSchemaMojo.java
index 11c253a..4fd34cb 100644
---
a/dsl/camel-yaml-dsl/camel-yaml-dsl-maven-plugin/src/main/java/org/apache/camel/maven/dsl/yaml/GenerateYamlSchemaMojo.java
+++
b/dsl/camel-yaml-dsl/camel-yaml-dsl-maven-plugin/src/main/java/org/apache/camel/maven/dsl/yaml/GenerateYamlSchemaMojo.java
@@ -21,8 +21,8 @@ import java.io.IOException;
import java.io.StringWriter;
import java.util.ArrayList;
import java.util.Comparator;
-import java.util.HashSet;
import java.util.Iterator;
+import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
@@ -163,7 +163,7 @@ public class GenerateYamlSchemaMojo extends
GenerateYamlSupportMojo {
Comparator.comparing(property -> annotationValue(property,
"name").map(AnnotationValue::asString).orElse("")));
for (AnnotationInstance property : properties) {
-final String propertyName = valueCase(annotationValue(property,
"name").map(AnnotationValue::asString).orElse(""));
+final String propertyName = annotationValue(property,
"name").map(AnnotationValue::asString).orElse("");
final String propertyType = annotationValue(property,
"type").map(AnnotationValue::asString).orElse("");
final boolean propertyRequired
= annotationValue(property,
"required").map(AnnotationValue::asBoolean).orElse(false);
@@ -197,7 +197,8 @@ public class GenerateYamlSchemaMojo extends
GenerateYamlSupportMojo {
setProperty(objectDefinition, propertyName, propertyType);
if (propertyRequired) {
-definition.withArray("required").add(propertyName);
+String name = kebabCase ? propertyName :
StringHelper.dashToCamelCase(propertyName);
+definition.withArray("required").add(name);
}
}
}
@@ -205,29 +206,27 @@ public class GenerateYamlSchemaMojo extends
GenerateYamlSupportMojo {
private void filterCase(JsonNode node) {
if (node instanceof ObjectNode) {
ObjectNode on = (ObjectNode) node;
-ObjectNode p = on.with("properties");
-Set keep = new HashSet<>();
-for (Iterator it = p.fieldNames(); it.hasNext(); ) {
-String n = it.next();
-String t = valueCase(n);
-if (t.equals(n)) {
-keep.add(n);
-}
-}
-if (!keep.isEmpty()) {
-p.retain(keep);
+JsonNode jn = on.with("properties");
+if (jn.isEmpty()) {
+jn = on.findPath("properties");
}
-}
-}
+if (jn instanceof ObjectNode) {
+ObjectNode p = (ObjectNode) jn;
+Map keep = new LinkedHashMap<>();
+
+// the properties are in mixed kebab-case and camelCase
+for (Iterator it = p.fieldNames(); it.hasNext(); ) {
+String n = it.next();
+String t = StringHelper.dashToCamelCase(n);
+JsonNode prop = p.get(n);
+keep.put(t, prop);
+}
-private String valueCase(String value) {
-if (kebabCase) {
-// kebab was the original case for yaml-dsl
-return value;
-} else {
-value = StringHelper.dashToCamelCase(value);
+// rebuild
+p.removeAll();
+keep.forEach(p::set);
+}
}
-return value;
}
private void setProperty(
@@ -287,7 +286,7 @@ public class GenerateYamlSchemaMojo extends
GenerateYamlSupportMojo {
.map(AnnotationValue::asNestedArray)
.ifPresent(properties -> {
for (AnnotationInstance property : properties) {
-final String propertyName =
valueCase(annotationValue(property,
"name").map(AnnotationValue::asString).orElse(""));
+
[GitHub] [camel-k] squakez commented on pull request #2894: Update stale.yaml
squakez commented on pull request #2894: URL: https://github.com/apache/camel-k/pull/2894#issuecomment-1017323206 The changes don't affect the code, the failures are probably due because we're in the middle of a new release cut. -- 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] squakez closed issue #2893: Stale bot is setting issue `stale` where marked as `never-stale`
squakez closed issue #2893: URL: https://github.com/apache/camel-k/issues/2893 -- 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] squakez merged pull request #2894: Update stale.yaml
squakez merged pull request #2894: URL: https://github.com/apache/camel-k/pull/2894 -- 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] branch main updated: Update stale.yaml
This is an automated email from the ASF dual-hosted git repository. pcongiusti 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 03c8b21 Update stale.yaml 03c8b21 is described below commit 03c8b2125fc19aee8edc23156aac88aa483c069a Author: Pasquale Congiusti AuthorDate: Thu Jan 20 09:11:40 2022 +0100 Update stale.yaml Closes #2893 --- .github/workflows/stale.yaml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/.github/workflows/stale.yaml b/.github/workflows/stale.yaml index c860951..1239284 100644 --- a/.github/workflows/stale.yaml +++ b/.github/workflows/stale.yaml @@ -32,14 +32,14 @@ jobs: days-before-close: 15 operations-per-run: 10 stale-issue-label: status/stale -exempt-issue-label: status/never-stale +exempt-issue-labels: status/never-stale stale-issue-message: | 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! stale-pr-label: status/stale -exempt-pr-label: status/never-stale +exempt-pr-labels: status/never-stale stale-pr-message: | This PR has been automatically marked as stale due to 90 days of inactivity. It will be closed if no further activity occurs within 15 days.
[GitHub] [camel-quarkus] freedev edited a comment on issue #3474: java.lang.IllegalStateException: The stream has no active subscriptions smallrye-reactive-messaging-camel
freedev edited a comment on issue #3474: URL: https://github.com/apache/camel-quarkus/issues/3474#issuecomment-1017310498 I just had a look at #3386 but it's not clear what's missing part, well, apart the title. Anyway, I've just updated https://github.com/freedev/code-with-quarkus-camel adding a proper README that explain how to do it. -- 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] freedev commented on issue #3474: java.lang.IllegalStateException: The stream has no active subscriptions smallrye-reactive-messaging-camel
freedev commented on issue #3474: URL: https://github.com/apache/camel-quarkus/issues/3474#issuecomment-1017310498 I just had a look at #3386 but it's not clear what's missing part, well, a part the title. Anyway, I've just updated https://github.com/freedev/code-with-quarkus-camel adding a proper README that explain how to do it. -- 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] 01/01: 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-17519
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 08ea8ff0d0203aeec546a2d256c3bb0a2529b74e
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-17519 created (now 08ea8ff)
This is an automated email from the ASF dual-hosted git repository. jamesnetherton pushed a change to branch CAMEL-17519 in repository https://gitbox.apache.org/repos/asf/camel.git. at 08ea8ff CAMEL-17519: Expose MainSupprt.internalBeforeStart so that it can be overridden This branch includes the following new commits: new 08ea8ff CAMEL-17519: Expose MainSupprt.internalBeforeStart so that it can be overridden The 1 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.
[GitHub] [camel-quarkus] aldettinger commented on issue #3394: camel.main.durationMaxSeconds is not honoured
aldettinger commented on issue #3394: URL: https://github.com/apache/camel-quarkus/issues/3394#issuecomment-1017290488 Sure @jamesnetherton , you are welcome to move this ahead. -- 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] 01/01: Upgrade to Quarkus 2.8.0.CR1
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch quarkus-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 197bfbb47a55e168425429178a9004a8bf7c68ba
Author: James Netherton
AuthorDate: Thu Jan 20 07:52:37 2022 +
Upgrade to Quarkus 2.8.0.CR1
---
docs/antora.yml | 2 +-
pom.xml | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/docs/antora.yml b/docs/antora.yml
index 168241c..7974faf 100644
--- a/docs/antora.yml
+++ b/docs/antora.yml
@@ -31,7 +31,7 @@ asciidoc:
target-maven-version: 3.8.4 # replace ${target-maven-version}
camel-version: 3.14.0 # replace ${camel.version}
camel-docs-version: 3.14.x # replace ${camel.docs.components.version}
-quarkus-version: 2.7.0.CR1 # replace ${quarkus.version}
+quarkus-version: 999-SNAPSHOT # replace ${quarkus.version}
# attributes used in xrefs to other Antora components
cq-camel-components: 3.14.x@components # replace
${camel.docs.components.xref}
quarkus-examples-version: latest
diff --git a/pom.xml b/pom.xml
index 30fa249..9d915f2 100644
--- a/pom.xml
+++ b/pom.xml
@@ -55,7 +55,7 @@
1.0.0
2.3.0
1.0.3
-2.7.0.CR1
+999-SNAPSHOT
2.0.0
0.30.0
[camel-quarkus] branch quarkus-main updated (c43a90b -> 197bfbb)
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a change to branch quarkus-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git.
discard c43a90b Adapt to Quarkus CDI proxy class changes
discard b340d4a Sync latest property versions
discard f1917c8 Modify checks for TransactionManager class name in line with
Quarkus CDI proxy class changes
discard 8676ab3 java.lang.UnsatisfiedLinkError: no awt in java.library.path
in native tests
discard be004ff Exclude geronimo-jms from corda
discard ba0431e ⬆️ Upgrade Quarkus to 2.7.0.CR1
add 193d8d3 Updated CHANGELOG.md
add a2017c8 aws2-quarkus-client Verify that no client except quarkus one
is used during test #3447
add 6cad4cc Ban netty-all #3464
add ca8ad1c Refactor aws2-quarkus-client-ddb(s3) by copying files (not
duplicating) #3236
add 3f0f0c7 Update Salesforce Integration tests to Salesforce API upgrade
add 080bded Improve documentation on setting up the Salesforce
developer account
add ce20ec1 Updated CHANGELOG.md
add c060ee3 Upgrade Quarkus to 2.7.0.CR1
add 0d0f0f1 java.lang.UnsatisfiedLinkError: no awt in java.library.path
in native tests
add fc97c4b Updated CHANGELOG.md
add 73ffc7e Avoid creating CamelBeanBuildItem for health checks if they
are disabled
new 197bfbb Upgrade to Quarkus 2.8.0.CR1
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 (c43a90b)
\
N -- N -- N refs/heads/quarkus-main (197bfbb)
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.
The 1 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:
CHANGELOG.md | 14 +
extensions-jvm/hdfs/deployment/pom.xml | 4 +
extensions-jvm/hdfs/runtime/pom.xml| 10 +
extensions-jvm/spark/runtime/pom.xml | 4 +
.../support/bouncycastle/BouncyCastleRecorder.java | 7 +
.../deployment/MicroProfileHealthProcessor.java| 82 +-
...MicroProfileHealthCamelChecksDisabledTest.java} | 38 ++-
.../deployment/MicroProfileHealthEnabledTest.java | 24 +-
extensions/nsq/deployment/pom.xml | 4 +
extensions/nsq/runtime/pom.xml | 8 +
.../aws2-quarkus-client/aws2-ddb/pom.xml | 56
.../aws2/ddb/it/Aws2DdbQuarkusClientResource.java} | 57 ++--
.../component/aws2/ddb/it/Aws2DdbResource.java | 321 -
.../aws2/ddb/it/Aws2DdbQuarkusClientTest.java | 266 +
... => Aws2DdbQuarkusClientTestEnvCustomizer.java} | 5 +-
...quarkus.test.support.aws2.Aws2TestEnvCustomizer | 2 +-
.../aws2-quarkus-client/aws2-s3/pom.xml| 56
.../aws2/s3/it/Aws2S3QuarkusClientInvoker.java}| 12 +-
.../src/main/resources/application.properties | 6 -
.../aws2/s3/it/Aws2S3QuarkusClientTest.java| 315
...a => Aws2S3QuarkusClientTestEnvCustomizer.java} | 27 +-
...quarkus.test.support.aws2.Aws2TestEnvCustomizer | 2 +-
.../it/Aws2SesQuarkusClientTestEnvCustomizer.java | 3 +
.../it/Aws2SnsQuarkusClientTestEnvCustomizer.java | 3 +
integration-test-groups/aws2/aws2-s3/pom.xml | 56
.../quarkus/component/aws2/Aws2S3Resource.java | 288 --
.../component/aws2/s3/it/Aws2S3Resource.java | 6 +-
.../component/aws2/{ => s3/it}/Aws2S3IT.java | 2 +-
.../component/aws2/{ => s3/it}/Aws2S3Test.java | 2 +-
.../aws2/{ => s3/it}/Aws2S3TestEnvCustomizer.java | 3 +-
...quarkus.test.support.aws2.Aws2TestEnvCustomizer | 2 +-
.../test/support/aws2/Aws2TestEnvContext.java | 14 +
.../aws2-quarkus-client-grouped/pom.xml| 30 ++
integration-tests/salesforce/README.adoc | 17 +-
.../salesforce/SalesforceIntegrationTest.java | 4 +-
pom.xml| 9 +-
36 files changed, 457 insertions(+), 1302 deletions(-)
copy
extensions/microprofile-health/deployment/src/test/java/org/apache/camel/quarkus/component/microprofile/health/deployment/{MicroProfileHealthDisabledViaCamelMainTest.java
=> MicroProfileHealthCamelChecksDisabledTest.java} (59%)
copy
[camel-quarkus] branch main updated: Avoid creating CamelBeanBuildItem for health checks if they are disabled
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton 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 73ffc7e Avoid creating CamelBeanBuildItem for health checks if they
are disabled
73ffc7e is described below
commit 73ffc7ef7f8882f0ba49bb89d8f7bfbe233a5f82
Author: James Netherton
AuthorDate: Thu Jan 20 07:18:02 2022 +
Avoid creating CamelBeanBuildItem for health checks if they are disabled
Fixes #3470
---
.../deployment/MicroProfileHealthProcessor.java| 82 +++---
.../MicroProfileHealthCamelChecksDisabledTest.java | 96 ++
.../deployment/MicroProfileHealthEnabledTest.java | 24 +-
3 files changed, 188 insertions(+), 14 deletions(-)
diff --git
a/extensions/microprofile-health/deployment/src/main/java/org/apache/camel/quarkus/component/microprofile/health/deployment/MicroProfileHealthProcessor.java
b/extensions/microprofile-health/deployment/src/main/java/org/apache/camel/quarkus/component/microprofile/health/deployment/MicroProfileHealthProcessor.java
index e1261c0..351c9eb 100644
---
a/extensions/microprofile-health/deployment/src/main/java/org/apache/camel/quarkus/component/microprofile/health/deployment/MicroProfileHealthProcessor.java
+++
b/extensions/microprofile-health/deployment/src/main/java/org/apache/camel/quarkus/component/microprofile/health/deployment/MicroProfileHealthProcessor.java
@@ -20,6 +20,7 @@ import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.function.BooleanSupplier;
+import java.util.function.Predicate;
import javax.enterprise.inject.Vetoed;
@@ -34,12 +35,17 @@ import
io.quarkus.smallrye.health.deployment.HealthBuildTimeConfig;
import org.apache.camel.health.HealthCheck;
import org.apache.camel.health.HealthCheckRegistry;
import org.apache.camel.health.HealthCheckRepository;
-import org.apache.camel.impl.health.DefaultHealthCheckRegistry;
+import org.apache.camel.impl.health.ConsumersHealthCheckRepository;
+import org.apache.camel.impl.health.ContextHealthCheck;
+import org.apache.camel.impl.health.HealthCheckRegistryRepository;
+import org.apache.camel.impl.health.RoutesHealthCheckRepository;
import
org.apache.camel.microprofile.health.AbstractCamelMicroProfileHealthCheck;
import
org.apache.camel.quarkus.component.microprofile.health.runtime.CamelMicroProfileHealthConfig;
import
org.apache.camel.quarkus.component.microprofile.health.runtime.CamelMicroProfileHealthRecorder;
import org.apache.camel.quarkus.core.deployment.spi.CamelBeanBuildItem;
import org.apache.camel.quarkus.core.deployment.util.CamelSupport;
+import org.apache.camel.util.ObjectHelper;
+import org.eclipse.microprofile.config.Config;
import org.eclipse.microprofile.config.ConfigProvider;
import org.eclipse.microprofile.health.Liveness;
import org.eclipse.microprofile.health.Readiness;
@@ -79,14 +85,23 @@ class MicroProfileHealthProcessor {
}
}
+static final class HealthRegistryEnabled implements BooleanSupplier {
+@Override
+public boolean getAsBoolean() {
+return ConfigProvider.getConfig()
+.getOptionalValue("camel.health.registryEnabled",
boolean.class)
+.orElse(true);
+}
+}
+
@BuildStep
FeatureBuildItem feature() {
return new FeatureBuildItem(FEATURE);
}
@Record(ExecutionTime.STATIC_INIT)
-@BuildStep(onlyIf = HealthEnabled.class)
-CamelBeanBuildItem metricRegistry(CamelMicroProfileHealthRecorder
recorder, CamelMicroProfileHealthConfig config) {
+@BuildStep(onlyIf = { HealthEnabled.class, HealthRegistryEnabled.class })
+CamelBeanBuildItem healthCheckRegistry(CamelMicroProfileHealthRecorder
recorder, CamelMicroProfileHealthConfig config) {
return new CamelBeanBuildItem(
"HealthCheckRegistry",
HealthCheckRegistry.class.getName(),
@@ -94,22 +109,43 @@ class MicroProfileHealthProcessor {
}
@BuildStep(onlyIf = HealthEnabled.class)
-List camelHealthDiscovery(
-CombinedIndexBuildItem combinedIndex,
-CamelMicroProfileHealthConfig config) {
-
+List camelHealthDiscovery(CombinedIndexBuildItem
combinedIndex) {
IndexView index = combinedIndex.getIndex();
List buildItems = new ArrayList<>();
Collection healthChecks =
index.getAllKnownImplementors(CAMEL_HEALTH_CHECK_DOTNAME);
Collection healthCheckRepositories = index
.getAllKnownImplementors(CAMEL_HEALTH_CHECK_REPOSITORY_DOTNAME);
+Config config = ConfigProvider.getConfig();
+Predicate healthCheckFilter = classInfo -> {
+String className = classInfo.name().toString();
+if
(className.equals(HealthCheckRegistryRepository.class.getName())) {
+
[GitHub] [camel-quarkus] jamesnetherton closed issue #3470: Health check `CamelBeanBuildItem` should use the check id as the name
jamesnetherton closed issue #3470: URL: https://github.com/apache/camel-quarkus/issues/3470 -- 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] jamesnetherton merged pull request #3475: Avoid creating `CamelBeanBuildItem` for health checks if they are disabled
jamesnetherton merged pull request #3475: URL: https://github.com/apache/camel-quarkus/pull/3475 -- 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] jamesnetherton commented on issue #3474: java.lang.IllegalStateException: The stream has no active subscriptions smallrye-reactive-messaging-camel
jamesnetherton commented on issue #3474: URL: https://github.com/apache/camel-quarkus/issues/3474#issuecomment-1017272954 I'd wait for #3386 to be fixed before contributing an example based on `camel-azure-servicebus`. -- 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] freedev closed issue #3474: java.lang.IllegalStateException: The stream has no active subscriptions smallrye-reactive-messaging-camel
freedev closed issue #3474: URL: https://github.com/apache/camel-quarkus/issues/3474 -- 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] freedev commented on issue #3474: java.lang.IllegalStateException: The stream has no active subscriptions smallrye-reactive-messaging-camel
freedev commented on issue #3474: URL: https://github.com/apache/camel-quarkus/issues/3474#issuecomment-1017269601 Hi thanks for helping, your pull request did the job. What about add a azure service bus integration sample in https://github.com/smallrye/smallrye-reactive-messaging/tree/main/examples or even in https://github.com/apache/camel-quarkus-examples Can I try a pull request? -- 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] orpiske opened a new pull request #6793: CAMEL-15562 pre-work
orpiske opened a new pull request #6793: URL: https://github.com/apache/camel/pull/6793 Additional refactoring to the Kafka component code to simplify implementing builtin resume strategies for CAMEL-15562 -- 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] jamesnetherton commented on issue #3474: java.lang.IllegalStateException: The stream has no active subscriptions smallrye-reactive-messaging-camel
jamesnetherton commented on issue #3474: URL: https://github.com/apache/camel-quarkus/issues/3474#issuecomment-1017258773 I opened a pull request on your project fix up the dependencies https://github.com/freedev/code-with-quarkus-camel/pull/1. That should allow the app to launch at least. Note that there is no Camel Quarkus extension for `camel-azure-servicebus` yet. So its not guaranteed to work 100% correctly if you just refer to the plain Camel component dependency, especially if you expect native mode support for it. See also https://github.com/apache/camel-quarkus/issues/3386. -- 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] freedev commented on issue #3474: java.lang.IllegalStateException: The stream has no active subscriptions smallrye-reactive-messaging-camel
freedev commented on issue #3474: URL: https://github.com/apache/camel-quarkus/issues/3474#issuecomment-1017243152 Hi James, thanks for coming back to me! :)In the first instance I've tried `CamelContextProducer` without but failed to start quarkus. [1] Unsatisfied dependency for type org.apache.camel.CamelContext and qualifiers [@Default] This is the log: ``` ~/git/personal/quarkus/code-with-quarkus-camel master !2 ?1 mvn clean quarkus:dev ok [INFO] Scanning for projects... [INFO] [INFO] < t.lux.quarkus.azure:code-with-quarkus-camel >- [INFO] Building code-with-quarkus-camel 1.0.0-SNAPSHOT [INFO] [ jar ]- [INFO] [INFO] --- maven-clean-plugin:2.5:clean (default-clean) @ code-with-quarkus-camel --- [INFO] Deleting /Users/freedev/git/personal/quarkus/code-with-quarkus-camel/target [INFO] [INFO] --- quarkus-maven-plugin:2.6.2.Final:dev (default-cli) @ code-with-quarkus-camel --- [INFO] Invoking org.apache.maven.plugins:maven-resources-plugin:2.6:resources) @ code-with-quarkus-camel [INFO] Using 'UTF-8' encoding to copy filtered resources. [INFO] Copying 1 resource [INFO] Invoking io.quarkus.platform:quarkus-maven-plugin:2.6.2.Final:generate-code) @ code-with-quarkus-camel [INFO] Invoking org.apache.maven.plugins:maven-compiler-plugin:3.8.1:compile) @ code-with-quarkus-camel [INFO] Changes detected - recompiling the module! [INFO] Compiling 1 source file to /Users/freedev/git/personal/quarkus/code-with-quarkus-camel/target/classes [INFO] Invoking org.apache.maven.plugins:maven-resources-plugin:2.6:testResources) @ code-with-quarkus-camel [INFO] Using 'UTF-8' encoding to copy filtered resources. [INFO] skip non existing resourceDirectory /Users/freedev/git/personal/quarkus/code-with-quarkus-camel/src/test/resources [INFO] Invoking io.quarkus.platform:quarkus-maven-plugin:2.6.2.Final:generate-code-tests) @ code-with-quarkus-camel [INFO] Invoking org.apache.maven.plugins:maven-compiler-plugin:3.8.1:testCompile) @ code-with-quarkus-camel [INFO] Changes detected - recompiling the module! Listening for transport dt_socket at address: 5005 2022-01-20 09:46:36,533 INFO [io.qua.dep.dev.IsolatedDevModeMain] (main) Attempting to start live reload endpoint to recover from previous Quarkus startup failure 2022-01-20 09:46:36,588 ERROR [io.qua.dep.dev.IsolatedDevModeMain] (main) Failed to start quarkus: java.lang.RuntimeException: io.quarkus.builder.BuildException: Build failure: Build failed due to errors [error]: Build step io.quarkus.arc.deployment.ArcProcessor#validate threw an exception: javax.enterprise.inject.spi.DeploymentException: Found 2 deployment problems: [1] Unsatisfied dependency for type org.apache.camel.CamelContext and qualifiers [@Default] - java member: t.lux.quarkus.azure.MyReactiveMessagingApplication#camelContext - declared on CLASS bean [types=[t.lux.quarkus.azure.MyReactiveMessagingApplication, java.lang.Object], qualifiers=[@Default, @Any], target=t.lux.quarkus.azure.MyReactiveMessagingApplication] [2] Unsatisfied dependency for type org.apache.camel.CamelContext and qualifiers [@Default] - java member: io.smallrye.reactive.messaging.camel.CamelConnector#camel - declared on CLASS bean [types=[org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory, org.eclipse.microprofile.reactive.messaging.spi.OutgoingConnectorFactory, io.smallrye.reactive.messaging.camel.CamelConnector, org.eclipse.microprofile.reactive.messaging.spi.IncomingConnectorFactory, java.lang.Object], qualifiers=[@Connector(value = "smallrye-camel"), @Any], target=io.smallrye.reactive.messaging.camel.CamelConnector] at io.quarkus.arc.processor.BeanDeployment.processErrors(BeanDeployment.java:1204) at io.quarkus.arc.processor.BeanDeployment.init(BeanDeployment.java:269) at io.quarkus.arc.processor.BeanProcessor.initialize(BeanProcessor.java:134) at io.quarkus.arc.deployment.ArcProcessor.validate(ArcProcessor.java:454) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at io.quarkus.deployment.ExtensionLoader$2.execute(ExtensionLoader.java:887) at io.quarkus.builder.BuildContext.run(BuildContext.java:277) at org.jboss.threads.ContextHandler$1.runWith(ContextHandler.java:18) at
[GitHub] [camel-quarkus] jamesnetherton commented on issue #3394: camel.main.durationMaxSeconds is not honoured
jamesnetherton commented on issue #3394: URL: https://github.com/apache/camel-quarkus/issues/3394#issuecomment-1017237001 It'd be nice to fix this for the 2.7.0 release. I can take a look into it. Until we have a Camel version with the `protected` `internalBeforeStart()`, I guess we can work around it on our side by setting the relevant main config like `mainConfigurationProperties.setDurationMaxSeconds(someValue)`. -- 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] divyansh42 commented on issue #2892: camel-k-client binary is missing in the latest release assets
divyansh42 commented on issue #2892: URL: https://github.com/apache/camel-k/issues/2892#issuecomment-1017224801 Great, Thanks for the quick response! -- 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] oscerd commented on issue #2892: camel-k-client binary is missing in the latest release assets
oscerd commented on issue #2892: URL: https://github.com/apache/camel-k/issues/2892#issuecomment-1017222607 I deleted the release to avoid confusion, once the vote will be completed I'll create it, sorry for the confusion @divyansh42 -- 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] oscerd commented on issue #2848: Release 1.8.0
oscerd commented on issue #2848: URL: https://github.com/apache/camel-k/issues/2848#issuecomment-1017221912 ## Changes by Kind ### Feature - Added support for KEDA autoscalers with automatic configuration when using Kamelets (#2838, @nicolaferraro) - Feat(maven): Configurable Maven CLI options (#2879, @astefanutti) - Feat: Faster operator startup (#2814, @astefanutti) - Feat: Global HTTP proxy support (#2858, @astefanutti) - Feat: Report runtime health checks into Integration readiness condition (#2719, @astefanutti) - Feat: Set GOMAXPROCS based on CPU quota (#2837, @astefanutti) ### Bug or Regression - Fix(OLM): Remove aggregated cluster roles from OLM bundle (#2809, @astefanutti) - Fix(build): Fix OLM bundle generation on Mac OS (#2797, @astefanutti) - Fix(cli): Skip version compatibility check for builder command (#2796, @astefanutti) - Fix(doc): Update Prometheus Operator setup documentation (#2795, @astefanutti) - Fix(log): Structure keytool logs (#2878, @astefanutti) - Fix(yaml): Take to-d into account while parsing YAML DSL steps (#2822, @astefanutti) - Fix: Install Kamelets as unstructured resources (#2881, @astefanutti) ### Uncategorized - Chore(RBAC): Remove wildcards from Knative role (#2807, @astefanutti) - Chore(build): Upgrade Maven to version 3.8.4 (#2767, @astefanutti) - Chore(build): Upgrade base image to ubi-quarkus-mandrel:21.3.0.0 (#2798, @astefanutti) - Chore(kamelet): polish error handler (#2843, @squakez) - Chore: Upgrade Knative to version 1.1.0 (#2846, @astefanutti) - Chore: Upgrade Spectrum and go-containerregistry (#2779, @astefanutti) - Doc(install): suggested resource configuration (#2774, @squakez) - Doc(jitpack): detailed info and link to example (#2857, @squakez) - Doc(kamelets): custom repository (#2849, @squakez) - Feat(cmd): OLM default discovery (#2735, @squakez) - Feat(cmd): operator additional info (#2730, @squakez) - Feat(cmd/run): autogenerated configmap for resource/config local files (#2771, @squakez) - Fix(build): default jitpack to main (#2775, @squakez) - Fix(doc): filter nolint comments in documentation trait (#2851, @squakez) - Fix(e2e): Avoid nested Gomega fields matcher (#2833, @astefanutti) - Fix: filter lint comment in traits (#2873, @squakez) ## Dependencies ### Added - github.com/bits-and-blooms/bitset: [v1.2.0](https://github.com/bits-and-blooms/bitset/tree/v1.2.0) - github.com/cenkalti/backoff/v4: [v4.1.1](https://github.com/cenkalti/backoff/v4/tree/v4.1.1) - github.com/checkpoint-restore/go-criu/v5: [v5.0.0](https://github.com/checkpoint-restore/go-criu/v5/tree/v5.0.0) - github.com/container-tools/go-containerregistry: [40ccc94](https://github.com/container-tools/go-containerregistry/tree/40ccc94) - github.com/containerd/stargz-snapshotter/estargz: [v0.10.1](https://github.com/containerd/stargz-snapshotter/estargz/tree/v0.10.1) - github.com/danieljoos/wincred: [v1.1.0](https://github.com/danieljoos/wincred/tree/v1.1.0) - github.com/kr/fs: [v0.1.0](https://github.com/kr/fs/tree/v0.1.0) - github.com/miekg/pkcs11: [v1.0.3](https://github.com/miekg/pkcs11/tree/v1.0.3) - github.com/moby/locker: [v1.0.1](https://github.com/moby/locker/tree/v1.0.1) - github.com/pkg/sftp: [v1.10.1](https://github.com/pkg/sftp/tree/v1.10.1) - github.com/stefanberger/go-pkcs11uri: [78d3cae](https://github.com/stefanberger/go-pkcs11uri/tree/78d3cae) - github.com/vbatts/tar-split: [v0.11.2](https://github.com/vbatts/tar-split/tree/v0.11.2) - go.etcd.io/etcd/api/v3: v3.5.0 - go.etcd.io/etcd/client/pkg/v3: v3.5.0 - go.etcd.io/etcd/client/v2: v2.305.0 - go.mozilla.org/pkcs7: 432b235 ### Changed - cloud.google.com/go: v0.97.0 → v0.98.0 - github.com/Azure/azure-sdk-for-go: [v50.2.0+incompatible → v43.0.0+incompatible](https://github.com/Azure/azure-sdk-for-go/compare/v50.2.0...v43.0.0) - github.com/Azure/go-autorest/autorest/adal: [v0.9.10 → v0.9.5](https://github.com/Azure/go-autorest/autorest/adal/compare/v0.9.10...v0.9.5) - github.com/Azure/go-autorest/autorest/to: [v0.4.0 → v0.3.0](https://github.com/Azure/go-autorest/autorest/to/compare/v0.4.0...v0.3.0) - github.com/Azure/go-autorest/autorest/validation: [v0.3.1 → v0.1.0](https://github.com/Azure/go-autorest/autorest/validation/compare/v0.3.1...v0.1.0) - github.com/Azure/go-autorest/autorest: [v0.11.17 → v0.11.12](https://github.com/Azure/go-autorest/autorest/compare/v0.11.17...v0.11.12) - github.com/Microsoft/go-winio: [6eac466 → v0.5.1](https://github.com/Microsoft/go-winio/compare/6eac466...v0.5.1) - github.com/Microsoft/hcsshim/test: [d3e5deb → 43a75bb](https://github.com/Microsoft/hcsshim/test/compare/d3e5deb...43a75bb) - github.com/Microsoft/hcsshim: [v0.8.15 → v0.8.23](https://github.com/Microsoft/hcsshim/compare/v0.8.15...v0.8.23) - github.com/aws/aws-sdk-go: [v1.37.1 →
[GitHub] [camel-k] squakez opened a new pull request #2894: Update stale.yaml
squakez opened a new pull request #2894: URL: https://github.com/apache/camel-k/pull/2894 Closes #2893 **Release Note** ```release-note NONE ``` -- 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] branch squakez-patch-1 created (now c0142be)
This is an automated email from the ASF dual-hosted git repository. pcongiusti pushed a change to branch squakez-patch-1 in repository https://gitbox.apache.org/repos/asf/camel-k.git. at c0142be Update stale.yaml This branch includes the following new commits: new c0142be Update stale.yaml The 1 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-k] 01/01: Update stale.yaml
This is an automated email from the ASF dual-hosted git repository. pcongiusti pushed a commit to branch squakez-patch-1 in repository https://gitbox.apache.org/repos/asf/camel-k.git commit c0142be771c253f644bbb542108ebd094f4b153c Author: Pasquale Congiusti AuthorDate: Thu Jan 20 09:11:40 2022 +0100 Update stale.yaml Closes #2893 --- .github/workflows/stale.yaml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/.github/workflows/stale.yaml b/.github/workflows/stale.yaml index c860951..1239284 100644 --- a/.github/workflows/stale.yaml +++ b/.github/workflows/stale.yaml @@ -32,14 +32,14 @@ jobs: days-before-close: 15 operations-per-run: 10 stale-issue-label: status/stale -exempt-issue-label: status/never-stale +exempt-issue-labels: status/never-stale stale-issue-message: | 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! stale-pr-label: status/stale -exempt-pr-label: status/never-stale +exempt-pr-labels: status/never-stale stale-pr-message: | This PR has been automatically marked as stale due to 90 days of inactivity. It will be closed if no further activity occurs within 15 days.
[GitHub] [camel-k] squakez opened a new issue #2893: Stale bot is setting issue `stale` where marked as `never-stale`
squakez opened a new issue #2893: URL: https://github.com/apache/camel-k/issues/2893 See #2289 or #2318, those issues were marked as `never-stale` but the bot ignores it. -- 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/03: Kafka to Azure Storage Blob: 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 a5381d98bb9b8a288830d858c4cd255cb1f0 Author: Andrea Cosentino AuthorDate: Thu Jan 20 08:37:35 2022 +0100 Kafka to Azure Storage Blob: Added a camel-jbang section to the README --- profiling/kafka/kafka-azure-storage-blob/README.md | 12 1 file changed, 12 insertions(+) diff --git a/profiling/kafka/kafka-azure-storage-blob/README.md b/profiling/kafka/kafka-azure-storage-blob/README.md index 967a60d..d95dedf 100644 --- a/profiling/kafka/kafka-azure-storage-blob/README.md +++ b/profiling/kafka/kafka-azure-storage-blob/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. + ## 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] branch jbang-profiling created (now cc32d41)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch jbang-profiling in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git. at cc32d41 Kafka to Azure Storage Blob: Added a camel-jbang section to the README No new revisions were added by this update.
[camel-performance-tests] 02/03: Kafka to Azure Storage Blob: 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 af7db414c52a62e9430f08bdc8ea18e6cb0cb328 Author: Andrea Cosentino AuthorDate: Thu Jan 20 08:40:00 2022 +0100 Kafka to Azure Storage Blob: Added a camel-jbang section to the README --- profiling/kafka/kafka-azure-storage-blob/README.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/profiling/kafka/kafka-azure-storage-blob/README.md b/profiling/kafka/kafka-azure-storage-blob/README.md index d95dedf..d3dfba8 100644 --- a/profiling/kafka/kafka-azure-storage-blob/README.md +++ b/profiling/kafka/kafka-azure-storage-blob/README.md @@ -123,7 +123,7 @@ What you need to do is simply running this commands: 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. +You'll get at jfr recording file once the application will be stopped in your working directory. ## Send messages to Kafka
[camel-performance-tests] branch main updated (901bfcb -> d34de70)
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 901bfcb Next is 3.15.0-SNAPSHOT
new a5381d9 Kafka to Azure Storage Blob: Added a camel-jbang section to
the README
new af7db41 Kafka to Azure Storage Blob: Added a camel-jbang section to
the README
new d34de70 Kafka to Azure Storage Blob: Added a camel-jbang section to
the README
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
profiling/kafka/kafka-azure-storage-blob/README.md | 12
.../data/sources/{routes.yaml => camel-jbang-route.yaml} | 6 +++---
2 files changed, 15 insertions(+), 3 deletions(-)
copy profiling/kafka/kafka-azure-storage-blob/data/sources/{routes.yaml =>
camel-jbang-route.yaml} (91%)
[camel-performance-tests] 03/03: Kafka to Azure Storage Blob: 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 d34de70d55e1fc76cc7346970260f2315bae5dd7 Author: Andrea Cosentino AuthorDate: Thu Jan 20 08:56:33 2022 +0100 Kafka to Azure Storage Blob: Added a camel-jbang section to the README --- .../data/sources/camel-jbang-route.yaml| 24 ++ 1 file changed, 24 insertions(+) diff --git a/profiling/kafka/kafka-azure-storage-blob/data/sources/camel-jbang-route.yaml b/profiling/kafka/kafka-azure-storage-blob/data/sources/camel-jbang-route.yaml new file mode 100644 index 000..cc557f3 --- /dev/null +++ b/profiling/kafka/kafka-azure-storage-blob/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" +
[GitHub] [camel-quarkus] jamesnetherton commented on issue #3402: [quarkus-main]crypto test failure in native mode
jamesnetherton commented on issue #3402: URL: https://github.com/apache/camel-quarkus/issues/3402#issuecomment-1017208502 Issues seem to be resolved now. -- 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] jamesnetherton closed issue #3402: [quarkus-main]crypto test failure in native mode
jamesnetherton closed issue #3402: URL: https://github.com/apache/camel-quarkus/issues/3402 -- 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
