[camel] branch master updated: Update camel-3-migration-guide.adoc

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
 new aa7376e  Update camel-3-migration-guide.adoc
aa7376e is described below

commit aa7376eac87434bb6b51262015ce708cd2e52938
Author: Matej Melko <6814482+mme...@users.noreply.github.com>
AuthorDate: Wed May 20 16:12:35 2020 +0200

Update camel-3-migration-guide.adoc

add formatting for renamed terser component.
---
 docs/user-manual/modules/ROOT/pages/camel-3-migration-guide.adoc | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/docs/user-manual/modules/ROOT/pages/camel-3-migration-guide.adoc 
b/docs/user-manual/modules/ROOT/pages/camel-3-migration-guide.adoc
index d22cefe..0a554c2 100644
--- a/docs/user-manual/modules/ROOT/pages/camel-3-migration-guide.adoc
+++ b/docs/user-manual/modules/ROOT/pages/camel-3-migration-guide.adoc
@@ -603,7 +603,7 @@ The class `ThreadPoolRejectedPolicy` has been moved from 
`org.apache.camel.Threa
 
 The simple language `property` function was deprecated in Camel 2.x and has 
been removed. Use `exchangeProperty` as function name.
 
-The terser language has been renamed from terser to hl7terser.
+The terser language has been renamed from `terser` to `hl7terser`.
 
 === JSSE
 

[GitHub] [camel] oscerd merged pull request #3846: Update camel-3-migration-guide.adoc

[GitBox]

oscerd merged pull request #3846:
URL: https://github.com/apache/camel/pull/3846


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-spring-boot] oscerd merged pull request #74: [Github Actions] Periodic Sync Camel Spring Boot Master Branch

[GitBox]

oscerd merged pull request #74:
URL: https://github.com/apache/camel-spring-boot/pull/74


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel-spring-boot] branch master updated: [create-pull-request] automated change

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git


The following commit(s) were added to refs/heads/master by this push:
 new 02fc68e  [create-pull-request] automated change
02fc68e is described below

commit 02fc68e1387a4cddf9775ee479f4fdedde0a84e5
Author: github-actions[bot] 
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu May 21 00:52:43 2020 +

[create-pull-request] automated change
---
 components-starter/camel-corda-starter/pom.xml | 12 
 1 file changed, 12 deletions(-)

diff --git a/components-starter/camel-corda-starter/pom.xml 
b/components-starter/camel-corda-starter/pom.xml
index 9ae10f6..8559a29 100644
--- a/components-starter/camel-corda-starter/pom.xml
+++ b/components-starter/camel-corda-starter/pom.xml
@@ -38,18 +38,6 @@
   org.apache.camel
   camel-corda
   ${camel-version}
-  
-  
-
-  ch.qos.logback
-  logback-classic
-
-
-  ch.qos.logback
-  logback-core
-
-  
-  
 
 
 

[GitHub] [camel-quarkus] github-actions[bot] opened a new issue #1251: [CI] - Quarkus Master Branch Build Failure

[GitBox]

github-actions[bot] opened a new issue #1251:
URL: https://github.com/apache/camel-quarkus/issues/1251


   The 
[quarkus-master](https://github.com/apache/camel-quarkus/tree/quarkus-master) 
branch build is failing:
   
   * Build ID: 111025955-28-a8bfe50a-d74f-4275-afc8-ef3844c0e73b
   * Camel Quarkus Commit: 18e246e8a1ec2595911bb0aa22a9119ad2357e9b
   
   * Quarkus Master Commit: 
   * Link to build: 
https://github.com/apache/camel-quarkus/actions/runs/111025955
   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel-spring-boot] branch automatic-periodic-sync updated (0cd3855 -> 118e36d)

[github-bot]

This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a change to branch automatic-periodic-sync
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git.


omit 0cd3855  [create-pull-request] automated change
 add c1c2bfe  The regen game: I love the regen's smell in the morning
 add 84a7eb1  Regen
 add 118e36d  [create-pull-request] automated change

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   (0cd3855)
\
 N -- N -- N   refs/heads/automatic-periodic-sync (118e36d)

You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.

Any revisions marked "omit" are not gone; other references still
refer to them.  Any revisions marked "discard" are gone forever.

No new revisions were added by this update.

Summary of changes:
 .../org/apache/camel/springboot/catalog/components/atmos.json   | 2 +-
 .../org/apache/camel/springboot/catalog/components/avro.json| 2 +-
 .../org/apache/camel/springboot/catalog/components/aws-kms.json | 2 +-
 .../org/apache/camel/springboot/catalog/components/aws-mq.json  | 2 +-
 .../org/apache/camel/springboot/catalog/components/aws-msk.json | 2 +-
 .../org/apache/camel/springboot/catalog/components/aws-sns.json | 2 +-
 .../org/apache/camel/springboot/catalog/components/aws2-mq.json | 2 +-
 .../org/apache/camel/springboot/catalog/components/aws2-sns.json| 2 +-
 .../org/apache/camel/springboot/catalog/components/azure-blob.json  | 2 +-
 .../org/apache/camel/springboot/catalog/components/azure-queue.json | 2 +-
 .../org/apache/camel/springboot/catalog/components/box.json | 2 +-
 .../org/apache/camel/springboot/catalog/components/braintree.json   | 2 +-
 .../org/apache/camel/springboot/catalog/components/chatscript.json  | 2 +-
 .../org/apache/camel/springboot/catalog/components/consul.json  | 2 +-
 .../org/apache/camel/springboot/catalog/components/corda.json   | 2 +-
 .../camel/springboot/catalog/components/debezium-mongodb.json   | 2 +-
 .../apache/camel/springboot/catalog/components/debezium-mysql.json  | 2 +-
 .../camel/springboot/catalog/components/debezium-postgres.json  | 2 +-
 .../camel/springboot/catalog/components/debezium-sqlserver.json | 2 +-
 .../org/apache/camel/springboot/catalog/components/docker.json  | 2 +-
 .../org/apache/camel/springboot/catalog/components/dropbox.json | 2 +-
 .../camel/springboot/catalog/components/elasticsearch-rest.json | 2 +-
 .../org/apache/camel/springboot/catalog/components/fhir.json| 2 +-
 .../org/apache/camel/springboot/catalog/components/file.json| 2 +-
 .../org/apache/camel/springboot/catalog/components/flink.json   | 2 +-
 .../org/apache/camel/springboot/catalog/components/fop.json | 2 +-
 .../org/apache/camel/springboot/catalog/components/github.json  | 2 +-
 .../apache/camel/springboot/catalog/components/google-bigquery.json | 2 +-
 .../apache/camel/springboot/catalog/components/google-drive.json| 2 +-
 .../org/apache/camel/springboot/catalog/components/google-mail.json | 2 +-
 .../apache/camel/springboot/catalog/components/google-pubsub.json   | 2 +-
 .../org/apache/camel/springboot/catalog/components/gora.json| 2 +-
 .../apache/camel/springboot/catalog/components/hazelcast-queue.json | 2 +-
 .../org/apache/camel/springboot/catalog/components/hbase.json   | 2 +-
 .../org/apache/camel/springboot/catalog/components/hdfs.json| 2 +-
 .../org/apache/camel/springboot/catalog/components/hipchat.json | 2 +-
 .../apache/camel/springboot/catalog/components/ignite-cache.json| 2 +-
 .../apache/camel/springboot/catalog/components/ignite-compute.json  | 2 +-
 .../apache/camel/springboot/catalog/components/ignite-events.json   | 2 +-
 .../apache/camel/springboot/catalog/components/ignite-idgen.json| 2 +-
 .../camel/springboot/catalog/components/ignite-messaging.json   | 2 +-
 .../apache/camel/springboot/catalog/components/ignite-queue.json| 2 +-
 .../org/apache/camel/springboot/catalog/components/ignite-set.json  | 2 +-
 .../org/apache/camel/springboot/catalog/components/iota.json| 2 +-
 .../org/apache/camel/springboot/catalog/components/jbpm.json| 2 +-
 .../org/apache/camel/springboot/catalog/components/jclouds.json | 2 +-
 .../org/apache/camel/springboot/catalog/components/jcr.json | 2 +-
 .../org/apache/camel/springboot/catalog/components/jooq.json| 2 +-
 .../org/apache/camel/springboot/catalog/components/kudu.json| 2 +-
 .../org/apache/camel/springboot/catalog/components/ldap.json| 2 +-
 

[GitHub] [camel-kafka-connector] valdar opened a new pull request #234: [DO NOT MERGE] Mirror registry test.

[GitBox]

valdar opened a new pull request #234:
URL: https://github.com/apache/camel-kafka-connector/pull/234


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel-examples] branch master updated: Polished

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-examples.git


The following commit(s) were added to refs/heads/master by this push:
 new 75bac5b  Polished
75bac5b is described below

commit 75bac5b0ee96edc7620f77439a03f9d51d4a8c03
Author: Claus Ibsen 
AuthorDate: Wed May 20 22:59:10 2020 +0200

Polished
---
 .../src/main/java/org/apache/camel/example/artemis/ArtemisMain.java | 2 +-
 .../java/org/apache/camel/example/artemis/CreateOrderRoute.java | 2 +-
 .../java/org/apache/camel/example/artemis/WidgetGadgetRoute.java| 6 +++---
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/examples/camel-example-artemis/src/main/java/org/apache/camel/example/artemis/ArtemisMain.java
 
b/examples/camel-example-artemis/src/main/java/org/apache/camel/example/artemis/ArtemisMain.java
index f32d9bd..ca8ef4f 100644
--- 
a/examples/camel-example-artemis/src/main/java/org/apache/camel/example/artemis/ArtemisMain.java
+++ 
b/examples/camel-example-artemis/src/main/java/org/apache/camel/example/artemis/ArtemisMain.java
@@ -35,7 +35,7 @@ public final class ArtemisMain {
 
 public static void main(String[] args) throws Exception {
 // create the ActiveMQ Artemis component
-main.bind("artemis", createArtemisComponent());
+main.bind("jms", createArtemisComponent());
 
 // add the widget/gadget route
 main.configure().addRoutesBuilder(new WidgetGadgetRoute());
diff --git 
a/examples/camel-example-artemis/src/main/java/org/apache/camel/example/artemis/CreateOrderRoute.java
 
b/examples/camel-example-artemis/src/main/java/org/apache/camel/example/artemis/CreateOrderRoute.java
index ee7f9b8..db533f5 100644
--- 
a/examples/camel-example-artemis/src/main/java/org/apache/camel/example/artemis/CreateOrderRoute.java
+++ 
b/examples/camel-example-artemis/src/main/java/org/apache/camel/example/artemis/CreateOrderRoute.java
@@ -28,6 +28,6 @@ public class CreateOrderRoute extends RouteBuilder {
 // route files form src/data (noop = keep the file as-is after done, 
and do not pickup the same file again)
 from("file:src/data?noop=true")
 // route to the newOrder queue on the Artemis broker
-.to("artemis:queue:newOrder?jmsMessageType=Text");
+.to("jms:queue:newOrder?jmsMessageType=Text");
 }
 }
diff --git 
a/examples/camel-example-artemis/src/main/java/org/apache/camel/example/artemis/WidgetGadgetRoute.java
 
b/examples/camel-example-artemis/src/main/java/org/apache/camel/example/artemis/WidgetGadgetRoute.java
index e04c7b4..74ba8e9 100644
--- 
a/examples/camel-example-artemis/src/main/java/org/apache/camel/example/artemis/WidgetGadgetRoute.java
+++ 
b/examples/camel-example-artemis/src/main/java/org/apache/camel/example/artemis/WidgetGadgetRoute.java
@@ -32,10 +32,10 @@ public class WidgetGadgetRoute extends RouteBuilder {
 // it is more common to inline the endpoints and predicates in the 
route
 // as shown in the CreateOrderRoute
 
-Endpoint newOrder = endpoint("artemis:queue:newOrder");
+Endpoint newOrder = endpoint("jms:queue:newOrder");
 Predicate isWidget = xpath("/order/product = 'widget'");
-Endpoint widget = endpoint("artemis:queue:widget");
-Endpoint gadget = endpoint("artemis:queue:gadget");
+Endpoint widget = endpoint("jms:queue:widget");
+Endpoint gadget = endpoint("jms:queue:gadget");
 
 from(newOrder)
 .choice()

[camel-examples] branch master updated: Remove license header for sample data

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-examples.git


The following commit(s) were added to refs/heads/master by this push:
 new 7d2c2e8  Remove license header for sample data
7d2c2e8 is described below

commit 7d2c2e8c52de0dfed4a772fc341d02e6ba85dfc4
Author: Claus Ibsen 
AuthorDate: Wed May 20 22:53:20 2020 +0200

Remove license header for sample data
---
 examples/camel-example-artemis/src/data/order1.xml | 18 --
 examples/camel-example-artemis/src/data/order2.xml | 18 --
 2 files changed, 36 deletions(-)

diff --git a/examples/camel-example-artemis/src/data/order1.xml 
b/examples/camel-example-artemis/src/data/order1.xml
index ec715e4..bfa69dd 100644
--- a/examples/camel-example-artemis/src/data/order1.xml
+++ b/examples/camel-example-artemis/src/data/order1.xml
@@ -1,22 +1,4 @@
 
-
 
   123
   widget
diff --git a/examples/camel-example-artemis/src/data/order2.xml 
b/examples/camel-example-artemis/src/data/order2.xml
index f2ca195..fee24ea 100644
--- a/examples/camel-example-artemis/src/data/order2.xml
+++ b/examples/camel-example-artemis/src/data/order2.xml
@@ -1,22 +1,4 @@
 
-
 
   456
   gadget

[GitHub] [camel-kafka-connector] valdar opened a new issue #233: Explore the possibilty of autogenerating some tests for each conenctor

[GitBox]

valdar opened a new issue #233:
URL: https://github.com/apache/camel-kafka-connector/issues/233


   I am not sure they will add much test coverage but it could be feasible to 
automatically generate some tests for each connector.
   
   The generated test would not actually start the endpoints but just 
instantiate the connector in a Kafka connect embed environment to check that at 
least dependencies and basic properties are fine.



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-kafka-connector] valdar commented on issue #97: S3 source connector delete files from source bucket

[GitBox]

valdar commented on issue #97:
URL: 
https://github.com/apache/camel-kafka-connector/issues/97#issuecomment-631712812


   In `master` this has been fixed by #231. @ruchirvaninasdaq feel free to 
reopen if it will not be solved once 0.3.0 is released.



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-kafka-connector] valdar closed issue #97: S3 source connector delete files from source bucket

[GitBox]

valdar closed issue #97:
URL: https://github.com/apache/camel-kafka-connector/issues/97


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-kafka-connector] valdar commented on pull request #193: Add contentLogLevel task property

[GitBox]

valdar commented on pull request #193:
URL: 
https://github.com/apache/camel-kafka-connector/pull/193#issuecomment-631710273


   Thanks for the contribution @fvaleri !



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-kafka-connector] valdar merged pull request #193: Add contentLogLevel task property

[GitBox]

valdar merged pull request #193:
URL: https://github.com/apache/camel-kafka-connector/pull/193


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel-kafka-connector] branch master updated: Add contentLogLevel task property

[valdar]

This is an automated email from the ASF dual-hosted git repository.

valdar pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git


The following commit(s) were added to refs/heads/master by this push:
 new 5527e2f  Add contentLogLevel task property
 new 569cc3e  Merge pull request #193 from fvaleri/log-payload
5527e2f is described below

commit 5527e2fd9d46c1293cf531e233ca9cf43385704b
Author: Federico Valeri 
AuthorDate: Wed May 6 09:59:37 2020 +0200

Add contentLogLevel task property
---
 core/pom.xml   |   5 +
 .../kafkaconnector/CamelSinkConnectorConfig.java   |   8 +-
 .../apache/camel/kafkaconnector/CamelSinkTask.java |   4 +-
 .../kafkaconnector/CamelSourceConnectorConfig.java |  10 +-
 .../camel/kafkaconnector/CamelSourceTask.java  |  38 ++--
 .../camel/kafkaconnector/utils/TaskHelper.java |  42 +
 .../camel/kafkaconnector/CamelSinkTaskTest.java|   3 +
 .../camel/kafkaconnector/CamelSourceTaskTest.java  |   3 +
 .../camel/kafkaconnector/utils/TaskHelperTest.java | 200 +
 parent/pom.xml |   7 +
 10 files changed, 267 insertions(+), 53 deletions(-)

diff --git a/core/pom.xml b/core/pom.xml
index 91f8ec0..f082a9c 100644
--- a/core/pom.xml
+++ b/core/pom.xml
@@ -89,6 +89,11 @@
 test
 
 
+org.slf4j
+slf4j-ext
+test
+
+
 org.apache.logging.log4j
 log4j-api
 test
diff --git 
a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkConnectorConfig.java
 
b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkConnectorConfig.java
index c353c58..61b 100644
--- 
a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkConnectorConfig.java
+++ 
b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkConnectorConfig.java
@@ -18,6 +18,7 @@ package org.apache.camel.kafkaconnector;
 
 import java.util.Map;
 
+import org.apache.camel.LoggingLevel;
 import org.apache.kafka.common.config.AbstractConfig;
 import org.apache.kafka.common.config.ConfigDef;
 import org.apache.kafka.common.config.ConfigDef.Importance;
@@ -42,10 +43,15 @@ public class CamelSinkConnectorConfig extends 
AbstractConfig {
 public static final String TOPIC_CONF = "topics";
 public static final String TOPIC_DOC = "A list of topics to use as input 
for this connector";
 
+public static final String CAMEL_SINK_CONTENT_LOG_LEVEL_DEFAULT = 
LoggingLevel.OFF.toString();
+public static final String CAMEL_SINK_CONTENT_LOG_LEVEL_CONF = 
"camel.sink.contentLogLevel";
+public static final String CAMEL_SINK_CONTENT_LOG_LEVEL_DOC = "Log level 
for the record's content (default: " + CAMEL_SINK_CONTENT_LOG_LEVEL_DEFAULT + 
"). Valid values: TRACE, DEBUG, INFO, WARN, ERROR, OFF.";
+
 private static final ConfigDef CONFIG_DEF = new ConfigDef()
 .define(CAMEL_SINK_URL_CONF, Type.STRING, CAMEL_SINK_URL_DEFAULT, 
Importance.HIGH, CAMEL_SINK_URL_DOC)
 .define(CAMEL_SINK_MARSHAL_CONF, Type.STRING, 
CAMEL_SINK_MARSHAL_DEFAULT, Importance.HIGH, CAMEL_SINK_MARSHAL_DOC)
-.define(CAMEL_SINK_COMPONENT_CONF, Type.STRING, 
CAMEL_SINK_COMPONENT_DEFAULT, Importance.HIGH, CAMEL_SINK_COMPONENT_DOC);
+.define(CAMEL_SINK_COMPONENT_CONF, Type.STRING, 
CAMEL_SINK_COMPONENT_DEFAULT, Importance.HIGH, CAMEL_SINK_COMPONENT_DOC)
+.define(CAMEL_SINK_CONTENT_LOG_LEVEL_CONF, Type.STRING, 
CAMEL_SINK_CONTENT_LOG_LEVEL_DEFAULT, Importance.HIGH, 
CAMEL_SINK_CONTENT_LOG_LEVEL_DOC);
 
 public CamelSinkConnectorConfig(ConfigDef config, Map 
parsedConfig) {
 super(config, parsedConfig);
diff --git 
a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java 
b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
index bd0870b..15ccd2b 100644
--- a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
+++ b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
@@ -110,6 +110,7 @@ public class CamelSinkTask extends SinkTask {
 @Override
 public void put(Collection sinkRecords) {
 for (SinkRecord record : sinkRecords) {
+TaskHelper.logRecordContent(LOG, record, config);
 Map headers = new HashMap();
 Exchange exchange = new 
DefaultExchange(producer.getCamelContext());
 headers.put(KAFKA_RECORD_KEY_HEADER, record.key());
@@ -123,7 +124,8 @@ public class CamelSinkTask extends SinkTask {
 }
 exchange.getMessage().setHeaders(headers);
 exchange.getMessage().setBody(record.value());
-LOG.debug("Sending {} to {}", exchange, LOCAL_URL);
+
+LOG.debug("Sending exchange {} to {}", exchange.getExchangeId(), 
LOCAL_URL);
 producer.send(LOCAL_URL, exchange);
 }
 }
diff --git 

[GitHub] [camel-kafka-connector] valdar commented on a change in pull request #193: Add contentLogLevel task property

[GitBox]

valdar commented on a change in pull request #193:
URL: 
https://github.com/apache/camel-kafka-connector/pull/193#discussion_r428289918



##
File path: 
core/src/main/java/org/apache/camel/kafkaconnector/utils/TaskHelper.java
##
@@ -93,4 +101,40 @@ private static Boolean stringStartWithOneOfPrefixes(String 
s, Set prefix
 }
 return false;
 }
+
+public static  void logRecordContent(Logger 
logger, ConnectRecord record, CFG config) {
+if (logger != null && record != null && config != null) {
+// do not log record's content by default, as it may contain 
sensitive information
+LoggingLevel level = LoggingLevel.OFF;
+try {
+final String key = (record instanceof SourceRecord)
+? 
CamelSourceConnectorConfig.CAMEL_SOURCE_CONTENT_LOG_LEVEL_CONF
+: 
CamelSinkConnectorConfig.CAMEL_SINK_CONTENT_LOG_LEVEL_CONF;
+level = 
LoggingLevel.valueOf(config.getString(key).trim().toUpperCase());
+} catch (Throwable e) {
+}
+if (level != LoggingLevel.OFF && 
Arrays.asList(LoggingLevel.values()).contains(level)) {

Review comment:
   +1 it was my impression as well.





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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-quarkus] ppalaga opened a new pull request #1250: Enable update-extension-doc-page mojo in newly scaffolded extensions

[GitBox]

ppalaga opened a new pull request #1250:
URL: https://github.com/apache/camel-quarkus/pull/1250


   Fixup #1232
   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-kafka-connector] fvaleri commented on a change in pull request #193: Add contentLogLevel task property

[GitBox]

fvaleri commented on a change in pull request #193:
URL: 
https://github.com/apache/camel-kafka-connector/pull/193#discussion_r428256345



##
File path: 
core/src/main/java/org/apache/camel/kafkaconnector/utils/TaskHelper.java
##
@@ -93,4 +101,40 @@ private static Boolean stringStartWithOneOfPrefixes(String 
s, Set prefix
 }
 return false;
 }
+
+public static  void logRecordContent(Logger 
logger, ConnectRecord record, CFG config) {
+if (logger != null && record != null && config != null) {
+// do not log record's content by default, as it may contain 
sensitive information
+LoggingLevel level = LoggingLevel.OFF;
+try {
+final String key = (record instanceof SourceRecord)
+? 
CamelSourceConnectorConfig.CAMEL_SOURCE_CONTENT_LOG_LEVEL_CONF
+: 
CamelSinkConnectorConfig.CAMEL_SINK_CONTENT_LOG_LEVEL_CONF;
+level = 
LoggingLevel.valueOf(config.getString(key).trim().toUpperCase());
+} catch (Throwable e) {
+}
+if (level != LoggingLevel.OFF && 
Arrays.asList(LoggingLevel.values()).contains(level)) {

Review comment:
   Conflicts fixed.
   
   > is this `Arrays.asList(LoggingLevel.values()).contains(level)` check 
needed? or you can just log a warning in the `default` clasue of the `switch 
case`?
   
   Added a warning message in case of invalid level, thanks.
   
   > In the end have you decided to not use `CamelLogger`? I am not implying is 
wrong, I am just asking.
   
   We can use it, but, unless I'm missing something, it seems that it does not 
support string substitution, so we would be back to unnecessary object creation.





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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-quarkus] ppalaga closed issue #1232: Per-extension documentation pages

[GitBox]

ppalaga closed issue #1232:
URL: https://github.com/apache/camel-quarkus/issues/1232


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel-quarkus] branch master updated: Fix #1232 Per-extension documentation pages

[ppalaga]

This is an automated email from the ASF dual-hosted git repository.

ppalaga pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git


The following commit(s) were added to refs/heads/master by this push:
 new 786c86b  Fix #1232 Per-extension documentation pages
786c86b is described below

commit 786c86b18ab5ab9a3b053578b883e639253537e5
Author: Peter Palaga 
AuthorDate: Wed May 20 16:01:40 2020 +0200

Fix #1232 Per-extension documentation pages
---
 docs/modules/ROOT/pages/extensions/activemq.adoc   |  27 
 docs/modules/ROOT/pages/extensions/ahc.adoc|  25 ++--
 .../pages/list-of-camel-quarkus-extensions.adoc|   2 +-
 extensions-core/xml-io/deployment/pom.xml  |   2 +-
 extensions-core/xml-io/pom.xml |   2 +-
 extensions-core/xml-io/runtime/pom.xml |   2 +-
 extensions-core/xml-jaxb/deployment/pom.xml|   2 +-
 extensions-core/xml-jaxb/pom.xml   |   2 +-
 extensions-core/xml-jaxb/runtime/pom.xml   |   2 +-
 extensions-core/xml-jaxp/deployment/pom.xml|   2 +-
 extensions-core/xml-jaxp/pom.xml   |   2 +-
 extensions-core/xml-jaxp/runtime/pom.xml   |   2 +-
 extensions/activemq/runtime/pom.xml|  18 +++
 extensions/ahc/runtime/pom.xml |  18 +++
 .../ahc/runtime/src/main/doc/configuration.adoc|   2 +
 .../quarkus/maven/AbstractDocGeneratorMojo.java|  73 ++
 .../camel/quarkus/maven/CamelQuarkusExtension.java | 153 +
 .../org/apache/camel/quarkus/maven/CqCatalog.java  |  16 ++-
 .../org/apache/camel/quarkus/maven/CqUtils.java|  63 -
 .../quarkus/maven/PrepareCatalogQuarkusMojo.java   | 139 +--
 .../quarkus/maven/UpdateDocExtensionsListMojo.java |  45 +-
 .../quarkus/maven/UpdateExtensionDocPageMojo.java  | 113 +++
 .../doc-templates/extension-doc-page.adoc  |  38 +
 .../readme-components.ftl  |   0
 .../readme-dataformats.ftl |   0
 .../readme-languages.ftl   |   0
 .../readme-others.ftl  |   0
 27 files changed, 550 insertions(+), 200 deletions(-)

diff --git a/docs/modules/ROOT/pages/extensions/activemq.adoc 
b/docs/modules/ROOT/pages/extensions/activemq.adoc
new file mode 100644
index 000..927405c
--- /dev/null
+++ b/docs/modules/ROOT/pages/extensions/activemq.adoc
@@ -0,0 +1,27 @@
+// Do not edit directly!
+// This file was generated by 
camel-quarkus-package-maven-plugin:update-extension-doc-page
+
+[[activemq]]
+= ActiveMQ
+
+*Since Camel Quarkus 1.0.0-M5, JVM and native*
+
+Send messages to (or consume from) Apache ActiveMQ. This component extends the 
Camel JMS component.
+
+== What's inside
+
+* https://camel.apache.org/components/latest/activemq-component.html[ActiveMQ 
component]
+
+Please refer to the above links for usage details.
+
+== Maven coordinates
+
+[source,xml]
+
+
+org.apache.camel.quarkus
+camel-quarkus-activemq
+
+
+
+Check the xref:user-guide.adoc[User guide] for more information about writing 
Camel Quarkus applications.
diff --git a/docs/modules/ROOT/pages/extensions/ahc.adoc 
b/docs/modules/ROOT/pages/extensions/ahc.adoc
index 45fc877..711d196 100644
--- a/docs/modules/ROOT/pages/extensions/ahc.adoc
+++ b/docs/modules/ROOT/pages/extensions/ahc.adoc
@@ -1,13 +1,20 @@
+// Do not edit directly!
+// This file was generated by 
camel-quarkus-package-maven-plugin:update-extension-doc-page
+
 [[ahc]]
-= Async HTTP Client (AHC) Extension
+= AHC (Async Http Client)
+
+*Since Camel Quarkus 1.0.0-M3, JVM and native*
+
+Call external HTTP services using Async Http Client.
+
+== What's inside
 
-*Since Camel Quarkus 1.0.0-M3*
+* https://camel.apache.org/components/latest/ahc-component.html[AHC component]
 
-The AHC component provides HTTP based endpoints for consuming external HTTP 
resources (as a client to call external
-servers using HTTP). It is using the 
https://github.com/AsyncHttpClient/async-http-client[Async Http Client library]
-under the hood.
+Please refer to the above links for usage details.
 
-Maven users will need to add the following dependency to their `pom.xml` for 
this extension.
+== Maven coordinates
 
 [source,xml]
 
@@ -17,12 +24,10 @@ Maven users will need to add the following dependency to 
their `pom.xml` for thi
 
 
 
-== Usage
-
-Please refer to the 
https://camel.apache.org/components/latest/ahc-component.html[AHC] component 
page.
-
+Check the xref:user-guide.adoc[User guide] for more information about writing 
Camel Quarkus applications.
 
 == Configuration
 
 * Check the xref:native-mode.adoc#charsets[Character encodings section] of the 
Native mode guide if you expect
   your application to send or receive requests using non-default encodings.
+
diff --git a/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc 

[GitHub] [camel-quarkus] ppalaga merged pull request #1249: Fix #1232 Per-extension documentation pages

[GitBox]

ppalaga merged pull request #1249:
URL: https://github.com/apache/camel-quarkus/pull/1249


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel-kafka-connector] branch master updated: Sink test refactoring

[valdar]

This is an automated email from the ASF dual-hosted git repository.

valdar pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git


The following commit(s) were added to refs/heads/master by this push:
 new 1de9ad6  Sink test refactoring
 new 9bcd681  Merge pull request #216 from fvaleri/sink-test-ref
1de9ad6 is described below

commit 1de9ad69644b5c46ebee471bf02e23f2930df8e7
Author: Federico Valeri 
AuthorDate: Sat May 16 19:29:22 2020 +0200

Sink test refactoring
---
 .../kafkaconnector/CamelSinkConnectorConfig.java   |   4 +
 .../kafkaconnector/CamelSourceConnectorConfig.java |   2 +-
 .../camel/kafkaconnector/CamelSinkTaskTest.java| 232 ++---
 3 files changed, 116 insertions(+), 122 deletions(-)

diff --git 
a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkConnectorConfig.java
 
b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkConnectorConfig.java
index e11e84d..c353c58 100644
--- 
a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkConnectorConfig.java
+++ 
b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkConnectorConfig.java
@@ -38,6 +38,10 @@ public class CamelSinkConnectorConfig extends AbstractConfig 
{
 public static final String CAMEL_SINK_URL_DOC = "The camel url to 
configure the destination. If this is set " + CAMEL_SINK_COMPONENT_CONF
 + " and all the properties starting with " + 
CamelSinkTask.getCamelSinkEndpointConfigPrefix() + ".<" + 
CAMEL_SINK_COMPONENT_CONF + " value> are ignored.";
 
+public static final String TOPIC_DEFAULT = "test";
+public static final String TOPIC_CONF = "topics";
+public static final String TOPIC_DOC = "A list of topics to use as input 
for this connector";
+
 private static final ConfigDef CONFIG_DEF = new ConfigDef()
 .define(CAMEL_SINK_URL_CONF, Type.STRING, CAMEL_SINK_URL_DEFAULT, 
Importance.HIGH, CAMEL_SINK_URL_DOC)
 .define(CAMEL_SINK_MARSHAL_CONF, Type.STRING, 
CAMEL_SINK_MARSHAL_DEFAULT, Importance.HIGH, CAMEL_SINK_MARSHAL_DOC)
diff --git 
a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceConnectorConfig.java
 
b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceConnectorConfig.java
index 01a55b8..34e2495 100644
--- 
a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceConnectorConfig.java
+++ 
b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceConnectorConfig.java
@@ -40,7 +40,7 @@ public class CamelSourceConnectorConfig extends 
AbstractConfig {
 
 public static final String TOPIC_DEFAULT = "test";
 public static final String TOPIC_CONF = "topics";
-public static final String TOPIC_DOC = "The topic to publish data to";
+public static final String TOPIC_DOC = "A list of topics to use as output 
for this connector";
 
 public static final Long CAMEL_SOURCE_MAX_BATCH_POLL_SIZE_DEFAULT = 1000L;
 public static final String CAMEL_SOURCE_MAX_BATCH_POLL_SIZE_CONF = 
"camel.source.maxBatchPollSize";
diff --git 
a/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java 
b/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java
index ba147b8..24cd03c 100644
--- a/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java
+++ b/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java
@@ -34,40 +34,41 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
 
 public class CamelSinkTaskTest {
 
+private static final String SEDA_URI = "seda:test";
+private static final String TOPIC_NAME = "my-topic";
+private static final long RECEIVE_TIMEOUT = 1_000;
+
 @Test
 public void testOnlyBody() {
 Map props = new HashMap<>();
-props.put("camel.sink.url", "seda:test");
-props.put("topics", "mytopic");
-
-CamelSinkTask camelSinkTask = new CamelSinkTask();
-camelSinkTask.start(props);
+props.put(CamelSinkConnectorConfig.TOPIC_CONF, TOPIC_NAME);
+props.put(CamelSinkConnectorConfig.CAMEL_SINK_URL_CONF, SEDA_URI);
 
-String topic = "mytopic";
+CamelSinkTask sinkTask = new CamelSinkTask();
+sinkTask.start(props);
 
 List records = new ArrayList();
-SinkRecord record = new SinkRecord(topic, 1, null, "test", null, 
"camel", 42);
+SinkRecord record = new SinkRecord(TOPIC_NAME, 1, null, "test", null, 
"camel", 42);
 records.add(record);
-camelSinkTask.put(records);
+sinkTask.put(records);
 
-ConsumerTemplate c = camelSinkTask.getCms().createConsumerTemplate();
-Exchange exchange = c.receive("seda:test", 1000L);
+ConsumerTemplate consumer = sinkTask.getCms().createConsumerTemplate();
+Exchange exchange = consumer.receive(SEDA_URI, RECEIVE_TIMEOUT);
 assertEquals("camel", exchange.getMessage().getBody());
 assertEquals("test", 

[GitHub] [camel-kafka-connector] valdar commented on pull request #216: Sink test refactoring

[GitBox]

valdar commented on pull request #216:
URL: 
https://github.com/apache/camel-kafka-connector/pull/216#issuecomment-631634454


   Thanks for the contribution @fvaleri 



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-kafka-connector] valdar merged pull request #216: Sink test refactoring

[GitBox]

valdar merged pull request #216:
URL: https://github.com/apache/camel-kafka-connector/pull/216


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel] fvaleri commented on pull request #3837: [CAMEL-7810] Fix JdbcAggregationRepository optimistic locking feature (2.25.x)

[GitBox]

fvaleri commented on pull request #3837:
URL: https://github.com/apache/camel/pull/3837#issuecomment-631609162


   Added `JdbcAggregationRepositoryNew` as separate class to avoid breaking 
applications using the old repository layout and a note about it in the 
component page. Will add an example on how to use it with another PR later.



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel] branch camel-2.25.x updated: Updating Tomcat to 9.0.35

[coheigea]

This is an automated email from the ASF dual-hosted git repository.

coheigea pushed a commit to branch camel-2.25.x
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/camel-2.25.x by this push:
 new 25ce710  Updating Tomcat to 9.0.35
25ce710 is described below

commit 25ce7103bb0d93c75761cff0c5efcf9865e81899
Author: Colm O hEigeartaigh 
AuthorDate: Wed May 20 17:54:06 2020 +0100

Updating Tomcat to 9.0.35
---
 components/camel-websocket-jsr356/pom.xml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/components/camel-websocket-jsr356/pom.xml 
b/components/camel-websocket-jsr356/pom.xml
index 55188c5..914ac44 100644
--- a/components/camel-websocket-jsr356/pom.xml
+++ b/components/camel-websocket-jsr356/pom.xml
@@ -30,7 +30,7 @@
   Camel WebSocket using JSR356 (javax)
 
   
-9.0.34
+9.0.35
 
 
   org.apache.camel.component.websocket.jsr356.*;${camel.osgi.version}

[camel] branch master updated: Updating Tomcat to 9.0.35

[coheigea]

This is an automated email from the ASF dual-hosted git repository.

coheigea pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
 new ff7514e  Updating Tomcat to 9.0.35
ff7514e is described below

commit ff7514e765411b502fad97a6112da7b429ebd93e
Author: Colm O hEigeartaigh 
AuthorDate: Wed May 20 17:52:17 2020 +0100

Updating Tomcat to 9.0.35
---
 components/camel-servlet/pom.xml  | 2 +-
 components/camel-websocket-jsr356/pom.xml | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/components/camel-servlet/pom.xml b/components/camel-servlet/pom.xml
index 01577a1..212eae2 100644
--- a/components/camel-servlet/pom.xml
+++ b/components/camel-servlet/pom.xml
@@ -39,7 +39,7 @@
 
 
 
-9.0.34
+9.0.35
 
 
 
diff --git a/components/camel-websocket-jsr356/pom.xml 
b/components/camel-websocket-jsr356/pom.xml
index 1179495..e324bfa 100644
--- a/components/camel-websocket-jsr356/pom.xml
+++ b/components/camel-websocket-jsr356/pom.xml
@@ -30,7 +30,7 @@
 Camel WebSocket using JSR356 (javax)
 
 
-9.0.34
+9.0.35
 
 
 !org.apache.camel.component.websocket.jsr356.*,

[GitHub] [camel-kafka-connector] valdar commented on pull request #216: Sink test refactoring

[GitBox]

valdar commented on pull request #216:
URL: 
https://github.com/apache/camel-kafka-connector/pull/216#issuecomment-631591700


   Can you solve conflicts with `master`?



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-kafka-connector] valdar commented on a change in pull request #193: Add contentLogLevel task property

[GitBox]

valdar commented on a change in pull request #193:
URL: 
https://github.com/apache/camel-kafka-connector/pull/193#discussion_r428156744



##
File path: 
core/src/main/java/org/apache/camel/kafkaconnector/utils/TaskHelper.java
##
@@ -93,4 +101,40 @@ private static Boolean stringStartWithOneOfPrefixes(String 
s, Set prefix
 }
 return false;
 }
+
+public static  void logRecordContent(Logger 
logger, ConnectRecord record, CFG config) {
+if (logger != null && record != null && config != null) {
+// do not log record's content by default, as it may contain 
sensitive information
+LoggingLevel level = LoggingLevel.OFF;
+try {
+final String key = (record instanceof SourceRecord)
+? 
CamelSourceConnectorConfig.CAMEL_SOURCE_CONTENT_LOG_LEVEL_CONF
+: 
CamelSinkConnectorConfig.CAMEL_SINK_CONTENT_LOG_LEVEL_CONF;
+level = 
LoggingLevel.valueOf(config.getString(key).trim().toUpperCase());
+} catch (Throwable e) {
+}
+if (level != LoggingLevel.OFF && 
Arrays.asList(LoggingLevel.values()).contains(level)) {

Review comment:
   Can you also fix conflict with `master`?





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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-kafka-connector] valdar commented on a change in pull request #193: Add contentLogLevel task property

[GitBox]

valdar commented on a change in pull request #193:
URL: 
https://github.com/apache/camel-kafka-connector/pull/193#discussion_r428154795



##
File path: 
core/src/main/java/org/apache/camel/kafkaconnector/utils/TaskHelper.java
##
@@ -93,4 +101,40 @@ private static Boolean stringStartWithOneOfPrefixes(String 
s, Set prefix
 }
 return false;
 }
+
+public static  void logRecordContent(Logger 
logger, ConnectRecord record, CFG config) {
+if (logger != null && record != null && config != null) {
+// do not log record's content by default, as it may contain 
sensitive information
+LoggingLevel level = LoggingLevel.OFF;
+try {
+final String key = (record instanceof SourceRecord)
+? 
CamelSourceConnectorConfig.CAMEL_SOURCE_CONTENT_LOG_LEVEL_CONF
+: 
CamelSinkConnectorConfig.CAMEL_SINK_CONTENT_LOG_LEVEL_CONF;
+level = 
LoggingLevel.valueOf(config.getString(key).trim().toUpperCase());
+} catch (Throwable e) {
+}
+if (level != LoggingLevel.OFF && 
Arrays.asList(LoggingLevel.values()).contains(level)) {

Review comment:
   is this `Arrays.asList(LoggingLevel.values()).contains(level)` check 
needed? or you can just log a warning in the `default` clasue of the `switch 
case`?





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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-kafka-connector] valdar commented on a change in pull request #193: Add contentLogLevel task property

[GitBox]

valdar commented on a change in pull request #193:
URL: 
https://github.com/apache/camel-kafka-connector/pull/193#discussion_r428154795



##
File path: 
core/src/main/java/org/apache/camel/kafkaconnector/utils/TaskHelper.java
##
@@ -93,4 +101,40 @@ private static Boolean stringStartWithOneOfPrefixes(String 
s, Set prefix
 }
 return false;
 }
+
+public static  void logRecordContent(Logger 
logger, ConnectRecord record, CFG config) {
+if (logger != null && record != null && config != null) {
+// do not log record's content by default, as it may contain 
sensitive information
+LoggingLevel level = LoggingLevel.OFF;
+try {
+final String key = (record instanceof SourceRecord)
+? 
CamelSourceConnectorConfig.CAMEL_SOURCE_CONTENT_LOG_LEVEL_CONF
+: 
CamelSinkConnectorConfig.CAMEL_SINK_CONTENT_LOG_LEVEL_CONF;
+level = 
LoggingLevel.valueOf(config.getString(key).trim().toUpperCase());
+} catch (Throwable e) {
+}
+if (level != LoggingLevel.OFF && 
Arrays.asList(LoggingLevel.values()).contains(level)) {

Review comment:
   is this `Arrays.asList(LoggingLevel.values()).contains(level)` check 
needed? or you can just log a warning in the default clasue of the switch case?





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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel] branch camel-2.25.x updated (df2dc9c -> d955977)

[coheigea]

This is an automated email from the ASF dual-hosted git repository.

coheigea pushed a change to branch camel-2.25.x
in repository https://gitbox.apache.org/repos/asf/camel.git.


from df2dc9c  Updating htmlunit due to CVE-2020-5529
 add d955977  Updating Tomcat to 9.0.34

No new revisions were added by this update.

Summary of changes:
 components/camel-websocket-jsr356/pom.xml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

[GitHub] [camel-kafka-connector] oscerd closed issue #223: CamelSinkTask headers must be cleaned before sending them ahead

[GitBox]

oscerd closed issue #223:
URL: https://github.com/apache/camel-kafka-connector/issues/223


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel-kafka-connector] branch master updated (97575f2 -> 7d2e0af)

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.


from 97575f2  Merge pull request #231 from apache/camel-3.3.0
 add fbed92f  CamelSinkTask headers must be cleaned before sending them 
ahead
 add 6b878cf  Fixed CS
 new 7d2e0af  Merge pull request #232 from apache/sink-headers

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:
 .../apache/camel/kafkaconnector/CamelSinkTask.java |  24 ++---
 .../camel/kafkaconnector/CamelSinkTaskTest.java| 104 ++---
 2 files changed, 65 insertions(+), 63 deletions(-)

[GitHub] [camel-kafka-connector] oscerd merged pull request #232: CamelSinkTask headers must be cleaned before sending them ahead

[GitBox]

oscerd merged pull request #232:
URL: https://github.com/apache/camel-kafka-connector/pull/232


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel-kafka-connector] 01/01: Merge pull request #232 from apache/sink-headers

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit 7d2e0af8da080b5dedd55928f92830c7a4a84c74
Merge: 97575f2 6b878cf
Author: Andrea Cosentino 
AuthorDate: Wed May 20 18:27:34 2020 +0200

Merge pull request #232 from apache/sink-headers

CamelSinkTask headers must be cleaned before sending them ahead

 .../apache/camel/kafkaconnector/CamelSinkTask.java |  24 ++---
 .../camel/kafkaconnector/CamelSinkTaskTest.java| 104 ++---
 2 files changed, 65 insertions(+), 63 deletions(-)

[GitHub] [camel] gnodet commented on pull request #3843: Camel 14878

[GitBox]

gnodet commented on pull request #3843:
URL: https://github.com/apache/camel/pull/3843#issuecomment-631578014


   > Yeah, I'd prefer the syntax like "5s" instead of "5 s" too.
   
   I've changed the defaults to have no spaces.  However, I've kept the 
optional spaces in the syntax.



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-quarkus] ppalaga commented on pull request #1249: Fix #1232 Per-extension documentation pages

[GitBox]

ppalaga commented on pull request #1249:
URL: https://github.com/apache/camel-quarkus/pull/1249#issuecomment-631565712


   af20fa5 fixed license headers and 'for usage details' instead of 'for the 
usage'



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-quarkus] ppalaga commented on a change in pull request #1249: Fix #1232 Per-extension documentation pages

[GitBox]

ppalaga commented on a change in pull request #1249:
URL: https://github.com/apache/camel-quarkus/pull/1249#discussion_r428125458



##
File path: docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc
##
@@ -799,11 +805,5 @@ Number of miscellaneous extensions: 12 in 12 JAR artifacts 
(0 deprecated)
 
 | (camel-quarkus-reactive-executor) | Native +
  Stable | 0.3.0 | Reactive Executor for camel-core using Vert.x
-
-| (camel-quarkus-xml-io) | Native +
- Stable | 1.0.0-M5 | An XML stack for parsing XML route definitions. A fast an 
light weight alternative to camel-quarkus-xml-jaxp
-
-| (camel-quarkus-xml-jaxb) | Native +
- Stable | 1.0.0-M5 | An XML stack for parsing XML route definitions. A legacy 
alternative to the fast an light weight camel-quarkus-xml-io

Review comment:
   Fixed in af20fa5





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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel] branch master updated: Updating Tomcat to 9.0.34

[coheigea]

This is an automated email from the ASF dual-hosted git repository.

coheigea pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
 new ce609bf  Updating Tomcat to 9.0.34
ce609bf is described below

commit ce609bf79b611154783612c2c2a63b7a852ea0cc
Author: Colm O hEigeartaigh 
AuthorDate: Wed May 20 16:53:38 2020 +0100

Updating Tomcat to 9.0.34
---
 components/camel-servlet/pom.xml  | 2 +-
 components/camel-websocket-jsr356/pom.xml | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/components/camel-servlet/pom.xml b/components/camel-servlet/pom.xml
index 816e290..01577a1 100644
--- a/components/camel-servlet/pom.xml
+++ b/components/camel-servlet/pom.xml
@@ -39,7 +39,7 @@
 
 
 
-9.0.31
+9.0.34
 
 
 
diff --git a/components/camel-websocket-jsr356/pom.xml 
b/components/camel-websocket-jsr356/pom.xml
index b08884d..1179495 100644
--- a/components/camel-websocket-jsr356/pom.xml
+++ b/components/camel-websocket-jsr356/pom.xml
@@ -30,7 +30,7 @@
 Camel WebSocket using JSR356 (javax)
 
 
-9.0.31
+9.0.34
 
 
 !org.apache.camel.component.websocket.jsr356.*,

[camel-kafka-connector] branch sink-headers updated (fbed92f -> 6b878cf)

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a change to branch sink-headers
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.


from fbed92f  CamelSinkTask headers must be cleaned before sending them 
ahead
 add 6b878cf  Fixed CS

No new revisions were added by this update.

Summary of changes:
 core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

[GitHub] [camel-kafka-connector] oscerd opened a new pull request #232: CamelSinkTask headers must be cleaned before sending them ahead

[GitBox]

oscerd opened a new pull request #232:
URL: https://github.com/apache/camel-kafka-connector/pull/232


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel-kafka-connector] 01/01: CamelSinkTask headers must be cleaned before sending them ahead

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch sink-headers
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit fbed92f4d8c71658118ec9450b7d938045dfcfd1
Author: Andrea Cosentino 
AuthorDate: Wed May 20 17:46:02 2020 +0200

CamelSinkTask headers must be cleaned before sending them ahead
---
 .../apache/camel/kafkaconnector/CamelSinkTask.java |  24 ++---
 .../camel/kafkaconnector/CamelSinkTaskTest.java| 104 ++---
 2 files changed, 65 insertions(+), 63 deletions(-)

diff --git 
a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java 
b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
index 521c0ad..c32a330 100644
--- a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
+++ b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
@@ -31,6 +31,7 @@ import org.apache.camel.impl.DefaultCamelContext;
 import org.apache.camel.kafkaconnector.utils.CamelMainSupport;
 import org.apache.camel.kafkaconnector.utils.TaskHelper;
 import org.apache.camel.support.DefaultExchange;
+import org.apache.commons.lang3.StringUtils;
 import org.apache.kafka.connect.data.Schema;
 import org.apache.kafka.connect.data.SchemaBuilder;
 import org.apache.kafka.connect.errors.ConnectException;
@@ -140,29 +141,30 @@ public class CamelSinkTask extends SinkTask {
 }
 
 private void addHeader(Map map, Header singleHeader) {
+   String camelHeaderKey = StringUtils.removeStart(singleHeader.key(), 
HEADER_CAMEL_PREFIX);
 Schema schema = singleHeader.schema();
 if 
(schema.type().getName().equals(Schema.STRING_SCHEMA.type().getName())) {
-map.put(singleHeader.key(), (String)singleHeader.value());
+map.put(camelHeaderKey, (String)singleHeader.value());
 } else if 
(schema.type().getName().equalsIgnoreCase(Schema.BOOLEAN_SCHEMA.type().getName()))
 {
-map.put(singleHeader.key(), (Boolean)singleHeader.value());
+map.put(camelHeaderKey, (Boolean)singleHeader.value());
 } else if 
(schema.type().getName().equalsIgnoreCase(Schema.INT32_SCHEMA.type().getName()))
 {
-map.put(singleHeader.key(), singleHeader.value());
+map.put(camelHeaderKey, singleHeader.value());
 } else if 
(schema.type().getName().equalsIgnoreCase(Schema.BYTES_SCHEMA.type().getName()))
 {
-map.put(singleHeader.key(), (byte[])singleHeader.value());
+map.put(camelHeaderKey, (byte[])singleHeader.value());
 } else if 
(schema.type().getName().equalsIgnoreCase(Schema.FLOAT32_SCHEMA.type().getName()))
 {
-map.put(singleHeader.key(), (float)singleHeader.value());
+map.put(camelHeaderKey, (float)singleHeader.value());
 } else if 
(schema.type().getName().equalsIgnoreCase(Schema.FLOAT64_SCHEMA.type().getName()))
 {
-map.put(singleHeader.key(), (double)singleHeader.value());
+map.put(camelHeaderKey, (double)singleHeader.value());
 } else if 
(schema.type().getName().equalsIgnoreCase(Schema.INT16_SCHEMA.type().getName()))
 {
-map.put(singleHeader.key(), (short)singleHeader.value());
+map.put(camelHeaderKey, (short)singleHeader.value());
 } else if 
(schema.type().getName().equalsIgnoreCase(Schema.INT64_SCHEMA.type().getName()))
 {
-map.put(singleHeader.key(), (long)singleHeader.value());
+map.put(camelHeaderKey, (long)singleHeader.value());
 } else if 
(schema.type().getName().equalsIgnoreCase(Schema.INT8_SCHEMA.type().getName())) 
{
-map.put(singleHeader.key(), (byte)singleHeader.value());
+map.put(camelHeaderKey, (byte)singleHeader.value());
 } else if 
(schema.type().getName().equalsIgnoreCase(SchemaBuilder.map(Schema.STRING_SCHEMA,
 Schema.STRING_SCHEMA).type().getName())) {
-map.put(singleHeader.key(), (Map)singleHeader.value());
+map.put(camelHeaderKey, (Map)singleHeader.value());
 } else if 
(schema.type().getName().equalsIgnoreCase(SchemaBuilder.array(Schema.STRING_SCHEMA).type().getName()))
 {
-map.put(singleHeader.key(), (List)singleHeader.value());
+map.put(camelHeaderKey, (List)singleHeader.value());
 }
 }
 
diff --git 
a/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java 
b/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java
index 32e3bc6..ba147b8 100644
--- a/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java
+++ b/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java
@@ -91,13 +91,13 @@ public class CamelSinkTaskTest {
 Exchange exchange = c.receive("seda:test", 1000L);
 assertEquals("camel", exchange.getMessage().getBody());
 assertEquals("test", 

[camel-kafka-connector] branch sink-headers created (now fbed92f)

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a change to branch sink-headers
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.


  at fbed92f  CamelSinkTask headers must be cleaned before sending them 
ahead

This branch includes the following new commits:

 new fbed92f  CamelSinkTask headers must be cleaned before sending them 
ahead

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] branch master updated: Fix checkstyle issue

[gnodet]

This is an automated email from the ASF dual-hosted git repository.

gnodet pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
 new 2b8fffe  Fix checkstyle issue
2b8fffe is described below

commit 2b8fffe3b0a2fc28ddb87ad097729e75fbd6bb90
Author: Guillaume Nodet 
AuthorDate: Wed May 20 16:01:54 2020 +0200

Fix checkstyle issue
---
 .../camel/component/activemq/ActiveMQEndpoint.java  |  2 +-
 .../org/apache/camel/component/atom/AtomEndpoint.java   |  2 +-
 .../camel/component/debezium/DebeziumMySqlEndpoint.java |  2 +-
 .../component/debezium/DebeziumPostgresEndpoint.java|  2 +-
 .../component/debezium/DebeziumSqlserverEndpoint.java   |  2 +-
 .../apache/camel/component/file/remote/FtpEndpoint.java |  2 +-
 .../hazelcast/HazelcastAggregationRepository.java   | 10 ++
 .../ReplicatedHazelcastAggregationRepository.java   | 17 +++--
 .../apache/camel/component/jclouds/JcloudsEndpoint.java |  2 +-
 .../org/apache/camel/component/jt400/Jt400Endpoint.java |  2 +-
 .../KubernetesPersistentVolumesEndpoint.java|  3 ++-
 .../KubernetesPersistentVolumesClaimsEndpoint.java  |  6 --
 .../org/apache/camel/component/mail/MailEndpoint.java   |  1 -
 .../apache/camel/component/metrics/MetricsEndpoint.java |  1 -
 .../camel/component/micrometer/MicrometerEndpoint.java  |  1 -
 .../camel/component/mongodb/gridfs/GridFsEndpoint.java  |  1 -
 .../apache/camel/component/mongodb/MongoDbEndpoint.java |  1 -
 .../camel/component/mustache/MustacheEndpoint.java  |  1 -
 .../apache/camel/component/nagios/NagiosEndpoint.java   |  1 -
 .../org/apache/camel/component/nats/NatsEndpoint.java   |  1 -
 .../apache/camel/component/pgevent/PgEventEndpoint.java |  1 -
 .../apache/camel/component/pubnub/PubNubEndpoint.java   |  1 -
 .../org/apache/camel/component/rss/RssEndpoint.java |  1 -
 .../apache/camel/component/xquery/XQueryEndpoint.java   |  1 -
 .../apache/camel/component/splunk/SplunkEndpoint.java   |  1 -
 .../org/apache/camel/component/event/EventEndpoint.java |  3 +--
 .../org/apache/camel/component/stax/StAXEndpoint.java   |  1 +
 .../apache/camel/component/twilio/TwilioEndpoint.java   |  1 -
 .../camel/component/validator/ValidatorEndpoint.java|  1 +
 29 files changed, 30 insertions(+), 41 deletions(-)

diff --git 
a/components/camel-activemq/src/main/java/org/apache/camel/component/activemq/ActiveMQEndpoint.java
 
b/components/camel-activemq/src/main/java/org/apache/camel/component/activemq/ActiveMQEndpoint.java
index 6c4cb55..4469472 100644
--- 
a/components/camel-activemq/src/main/java/org/apache/camel/component/activemq/ActiveMQEndpoint.java
+++ 
b/components/camel-activemq/src/main/java/org/apache/camel/component/activemq/ActiveMQEndpoint.java
@@ -16,9 +16,9 @@
  */
 package org.apache.camel.component.activemq;
 
+import org.apache.camel.Category;
 import org.apache.camel.component.jms.JmsEndpoint;
 import org.apache.camel.spi.UriEndpoint;
-import org.apache.camel.Category;
 
 /**
  * Send messages to (or consume from) Apache ActiveMQ. This component extends 
the Camel JMS component.
diff --git 
a/components/camel-atom/src/main/java/org/apache/camel/component/atom/AtomEndpoint.java
 
b/components/camel-atom/src/main/java/org/apache/camel/component/atom/AtomEndpoint.java
index 35a7a4a..cdb1206 100644
--- 
a/components/camel-atom/src/main/java/org/apache/camel/component/atom/AtomEndpoint.java
+++ 
b/components/camel-atom/src/main/java/org/apache/camel/component/atom/AtomEndpoint.java
@@ -19,9 +19,9 @@ package org.apache.camel.component.atom;
 import java.util.Date;
 
 import org.apache.abdera.model.Feed;
+import org.apache.camel.Category;
 import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
-import org.apache.camel.Category;
 import org.apache.camel.component.feed.FeedComponent;
 import org.apache.camel.component.feed.FeedEndpoint;
 import org.apache.camel.component.feed.FeedPollingConsumer;
diff --git 
a/components/camel-debezium-mysql/src/main/java/org/apache/camel/component/debezium/DebeziumMySqlEndpoint.java
 
b/components/camel-debezium-mysql/src/main/java/org/apache/camel/component/debezium/DebeziumMySqlEndpoint.java
index ebce332..3152065 100644
--- 
a/components/camel-debezium-mysql/src/main/java/org/apache/camel/component/debezium/DebeziumMySqlEndpoint.java
+++ 
b/components/camel-debezium-mysql/src/main/java/org/apache/camel/component/debezium/DebeziumMySqlEndpoint.java
@@ -16,8 +16,8 @@
  */
 package org.apache.camel.component.debezium;
 
-import 
org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration;
 import org.apache.camel.Category;
+import 
org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration;
 import org.apache.camel.spi.UriEndpoint;
 import org.apache.camel.spi.UriParam;
 
diff --git 

[GitHub] [camel-kafka-connector] oscerd merged pull request #231: Bump to Camel 3.3.0

[GitBox]

oscerd merged pull request #231:
URL: https://github.com/apache/camel-kafka-connector/pull/231


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel-kafka-connector] 01/01: Merge pull request #231 from apache/camel-3.3.0

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit 97575f27aa5890f2f45bd35578aef4186016982e
Merge: dd00d3b 8a5a644
Author: Andrea Cosentino 
AuthorDate: Wed May 20 17:15:28 2020 +0200

Merge pull request #231 from apache/camel-3.3.0

Bump to Camel 3.3.0

 .../docs/camel-activemq-kafka-sink-connector.adoc  |   8 +-
 .../camel-activemq-kafka-source-connector.adoc |  11 +-
 .../activemq/CamelActivemqSinkConnectorConfig.java |  20 +-
 .../CamelActivemqSourceConnectorConfig.java|  24 +--
 .../main/docs/camel-amqp-kafka-sink-connector.adoc |   2 +-
 .../docs/camel-amqp-kafka-source-connector.adoc|   5 +-
 .../amqp/CamelAmqpSinkConnectorConfig.java |   2 +-
 .../amqp/CamelAmqpSourceConnectorConfig.java   |   6 +-
 .../docs/camel-atom-kafka-source-connector.adoc|   2 +-
 .../atom/CamelAtomSourceConnectorConfig.java   |   2 +-
 .../docs/camel-aws-s3-kafka-sink-connector.adoc|   4 +-
 .../docs/camel-aws-s3-kafka-source-connector.adoc  |   4 +-
 .../awss3/CamelAwss3SinkConnectorConfig.java   |   4 +-
 .../awss3/CamelAwss3SourceConnectorConfig.java |   4 +-
 .../docs/camel-aws2-ec2-kafka-sink-connector.adoc  |   8 +-
 .../aws2ec2/CamelAws2ec2SinkConnectorConfig.java   |  12 +-
 .../docs/camel-aws2-ecs-kafka-sink-connector.adoc  |   4 +-
 .../aws2ecs/CamelAws2ecsSinkConnectorConfig.java   |   8 +
 .../docs/camel-aws2-eks-kafka-sink-connector.adoc  |   4 +-
 .../aws2eks/CamelAws2eksSinkConnectorConfig.java   |   8 +
 .../docs/camel-aws2-iam-kafka-sink-connector.adoc  |   4 +-
 .../aws2iam/CamelAws2iamSinkConnectorConfig.java   |   8 +
 .../docs/camel-aws2-kms-kafka-sink-connector.adoc  |   4 +-
 .../aws2kms/CamelAws2kmsSinkConnectorConfig.java   |   8 +
 .../camel-aws2-lambda-kafka-sink-connector.adoc|   6 +-
 .../CamelAws2lambdaSinkConnectorConfig.java|   8 +
 .../docs/camel-aws2-mq-kafka-sink-connector.adoc   |   4 +-
 .../aws2mq/CamelAws2mqSinkConnectorConfig.java |   8 +
 .../docs/camel-aws2-msk-kafka-sink-connector.adoc  |   4 +-
 .../aws2msk/CamelAws2mskSinkConnectorConfig.java   |   8 +
 .../docs/camel-aws2-s3-kafka-sink-connector.adoc   |  14 +-
 .../docs/camel-aws2-s3-kafka-source-connector.adoc |  12 +-
 .../aws2s3/CamelAws2s3SinkConnectorConfig.java |  40 
 .../aws2s3/CamelAws2s3SourceConnectorConfig.java   |  32 
 .../docs/camel-aws2-sqs-kafka-sink-connector.adoc  |   4 +-
 .../camel-aws2-sqs-kafka-source-connector.adoc |   4 +-
 .../aws2sqs/CamelAws2sqsSinkConnectorConfig.java   |   4 +-
 .../aws2sqs/CamelAws2sqsSourceConnectorConfig.java |   4 +-
 .../camel-aws2-translate-kafka-sink-connector.adoc |   4 +-
 .../CamelAws2translateSinkConnectorConfig.java |   8 +
 .../camel-azure-blob-kafka-sink-connector.adoc |   4 +-
 .../camel-azure-blob-kafka-source-connector.adoc   |   4 +-
 .../CamelAzureblobSinkConnectorConfig.java |   8 +
 .../CamelAzureblobSourceConnectorConfig.java   |   8 +
 .../camel-azure-queue-kafka-sink-connector.adoc|   4 +-
 .../camel-azure-queue-kafka-source-connector.adoc  |   4 +-
 .../CamelAzurequeueSinkConnectorConfig.java|   8 +
 .../CamelAzurequeueSourceConnectorConfig.java  |   8 +
 .../pom.xml| 135 ++
 .../src/main/assembly/package.xml  |  57 ++
 ...el-azure-storage-blob-kafka-sink-connector.adoc |  61 +++
 ...-azure-storage-blob-kafka-source-connector.adoc |  59 ++
 .../CamelAzurestorageblobSinkConnector.java|  35 
 .../CamelAzurestorageblobSinkConnectorConfig.java  | 177 ++
 .../CamelAzurestorageblobSinkTask.java |  39 
 .../CamelAzurestorageblobSourceConnector.java  |  37 
 ...CamelAzurestorageblobSourceConnectorConfig.java | 169 +
 .../CamelAzurestorageblobSourceTask.java   |  39 
 .../src/main/resources/META-INF/LICENSE.txt| 203 +
 .../src/main/resources/META-INF/NOTICE.txt |  11 ++
 .../pom.xml| 135 ++
 .../src/main/assembly/package.xml  |  57 ++
 ...l-azure-storage-queue-kafka-sink-connector.adoc |  52 ++
 ...azure-storage-queue-kafka-source-connector.adoc |  52 ++
 .../CamelAzurestoragequeueSinkConnector.java   |  35 
 .../CamelAzurestoragequeueSinkConnectorConfig.java | 141 ++
 .../CamelAzurestoragequeueSinkTask.java|  39 
 .../CamelAzurestoragequeueSourceConnector.java |  37 
 ...amelAzurestoragequeueSourceConnectorConfig.java | 141 ++
 .../CamelAzurestoragequeueSourceTask.java  |  39 
 .../src/main/resources/META-INF/LICENSE.txt| 203 +
 .../src/main/resources/META-INF/NOTICE.txt |  11 ++
 

[camel-kafka-connector] branch master updated (dd00d3b -> 97575f2)

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.


from dd00d3b  Merge pull request #230 from orpiske/camel-3.3-upgrade
 add 8a5a644  Bump to Camel 3.3.0
 new 97575f2  Merge pull request #231 from apache/camel-3.3.0

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:
 .../docs/camel-activemq-kafka-sink-connector.adoc  |   8 +-
 .../camel-activemq-kafka-source-connector.adoc |  11 +-
 .../activemq/CamelActivemqSinkConnectorConfig.java |  20 +--
 .../CamelActivemqSourceConnectorConfig.java|  24 ++-
 .../main/docs/camel-amqp-kafka-sink-connector.adoc |   2 +-
 .../docs/camel-amqp-kafka-source-connector.adoc|   5 +-
 .../amqp/CamelAmqpSinkConnectorConfig.java |   2 +-
 .../amqp/CamelAmqpSourceConnectorConfig.java   |   6 +-
 .../docs/camel-atom-kafka-source-connector.adoc|   2 +-
 .../atom/CamelAtomSourceConnectorConfig.java   |   2 +-
 .../docs/camel-aws-s3-kafka-sink-connector.adoc|   4 +-
 .../docs/camel-aws-s3-kafka-source-connector.adoc  |   4 +-
 .../awss3/CamelAwss3SinkConnectorConfig.java   |   4 +-
 .../awss3/CamelAwss3SourceConnectorConfig.java |   4 +-
 .../docs/camel-aws2-ec2-kafka-sink-connector.adoc  |   8 +-
 .../aws2ec2/CamelAws2ec2SinkConnectorConfig.java   |  12 +-
 .../docs/camel-aws2-ecs-kafka-sink-connector.adoc  |   4 +-
 .../aws2ecs/CamelAws2ecsSinkConnectorConfig.java   |   8 +
 .../docs/camel-aws2-eks-kafka-sink-connector.adoc  |   4 +-
 .../aws2eks/CamelAws2eksSinkConnectorConfig.java   |   8 +
 .../docs/camel-aws2-iam-kafka-sink-connector.adoc  |   4 +-
 .../aws2iam/CamelAws2iamSinkConnectorConfig.java   |   8 +
 .../docs/camel-aws2-kms-kafka-sink-connector.adoc  |   4 +-
 .../aws2kms/CamelAws2kmsSinkConnectorConfig.java   |   8 +
 .../camel-aws2-lambda-kafka-sink-connector.adoc|   6 +-
 .../CamelAws2lambdaSinkConnectorConfig.java|   8 +
 .../docs/camel-aws2-mq-kafka-sink-connector.adoc   |   4 +-
 .../aws2mq/CamelAws2mqSinkConnectorConfig.java |   8 +
 .../docs/camel-aws2-msk-kafka-sink-connector.adoc  |   4 +-
 .../aws2msk/CamelAws2mskSinkConnectorConfig.java   |   8 +
 .../docs/camel-aws2-s3-kafka-sink-connector.adoc   |  14 +-
 .../docs/camel-aws2-s3-kafka-source-connector.adoc |  12 +-
 .../aws2s3/CamelAws2s3SinkConnectorConfig.java |  40 +
 .../aws2s3/CamelAws2s3SourceConnectorConfig.java   |  32 
 .../docs/camel-aws2-sqs-kafka-sink-connector.adoc  |   4 +-
 .../camel-aws2-sqs-kafka-source-connector.adoc |   4 +-
 .../aws2sqs/CamelAws2sqsSinkConnectorConfig.java   |   4 +-
 .../aws2sqs/CamelAws2sqsSourceConnectorConfig.java |   4 +-
 .../camel-aws2-translate-kafka-sink-connector.adoc |   4 +-
 .../CamelAws2translateSinkConnectorConfig.java |   8 +
 .../camel-azure-blob-kafka-sink-connector.adoc |   4 +-
 .../camel-azure-blob-kafka-source-connector.adoc   |   4 +-
 .../CamelAzureblobSinkConnectorConfig.java |   8 +
 .../CamelAzureblobSourceConnectorConfig.java   |   8 +
 .../camel-azure-queue-kafka-sink-connector.adoc|   4 +-
 .../camel-azure-queue-kafka-source-connector.adoc  |   4 +-
 .../CamelAzurequeueSinkConnectorConfig.java|   8 +
 .../CamelAzurequeueSourceConnectorConfig.java  |   8 +
 .../pom.xml|   8 +-
 .../src/main/assembly/package.xml  |   0
 ...el-azure-storage-blob-kafka-sink-connector.adoc |  61 +++
 ...-azure-storage-blob-kafka-source-connector.adoc |  59 +++
 .../CamelAzurestorageblobSinkConnector.java}   |   8 +-
 .../CamelAzurestorageblobSinkConnectorConfig.java  | 177 +
 .../CamelAzurestorageblobSinkTask.java}|   8 +-
 .../CamelAzurestorageblobSourceConnector.java} |   8 +-
 ...CamelAzurestorageblobSourceConnectorConfig.java | 169 
 .../CamelAzurestorageblobSourceTask.java}  |   8 +-
 .../src/main/resources/META-INF/LICENSE.txt|   0
 .../src/main/resources/META-INF/NOTICE.txt |   0
 .../pom.xml|   8 +-
 .../src/main/assembly/package.xml  |   0
 ...l-azure-storage-queue-kafka-sink-connector.adoc |  52 ++
 ...azure-storage-queue-kafka-source-connector.adoc |  52 ++
 .../CamelAzurestoragequeueSinkConnector.java}  |   8 +-
 .../CamelAzurestoragequeueSinkConnectorConfig.java | 141 
 .../CamelAzurestoragequeueSinkTask.java}   |   8 +-
 .../CamelAzurestoragequeueSourceConnector.java}|   8 +-
 ...amelAzurestoragequeueSourceConnectorConfig.java | 141 
 .../CamelAzurestoragequeueSourceTask.java} |   8 +-
 

[GitHub] [camel-kafka-connector] oscerd closed issue #217: Bump to Camel 3.3.0

[GitBox]

oscerd closed issue #217:
URL: https://github.com/apache/camel-kafka-connector/issues/217


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-quarkus] ppalaga commented on a change in pull request #1249: Fix #1232 Per-extension documentation pages

[GitBox]

ppalaga commented on a change in pull request #1249:
URL: https://github.com/apache/camel-quarkus/pull/1249#discussion_r428082977



##
File path: docs/modules/ROOT/pages/extensions/activemq.adoc
##
@@ -0,0 +1,27 @@
+// Do not edit directly!
+// This file was generated by 
camel-quarkus-package-maven-plugin:update-extension-doc-page
+
+[[activemq]]
+= ActiveMQ
+
+*Since Camel Quarkus 1.0.0-M5, JVM and native*

Review comment:
   Yes, I am not 100% satisfied with this part too. I'd personally prefer 
some sort of badges visually similar to these 
   
![image](https://user-images.githubusercontent.com/1826249/82461803-1891ed80-9abb-11ea-8089-cdc57d3f08b2.png)
   I'd try to find some antora/css expert once the first iteration is online.





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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-quarkus] jamesnetherton commented on a change in pull request #1249: Fix #1232 Per-extension documentation pages

[GitBox]

jamesnetherton commented on a change in pull request #1249:
URL: https://github.com/apache/camel-quarkus/pull/1249#discussion_r428076903



##
File path: docs/modules/ROOT/pages/extensions/activemq.adoc
##
@@ -0,0 +1,27 @@
+// Do not edit directly!
+// This file was generated by 
camel-quarkus-package-maven-plugin:update-extension-doc-page
+
+[[activemq]]
+= ActiveMQ
+
+*Since Camel Quarkus 1.0.0-M5, JVM and native*
+
+Send messages to (or consume from) Apache ActiveMQ. This component extends the 
Camel JMS component.
+
+== What's inside

Review comment:
   Yes, true I'm happy to leave it as-is for 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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-quarkus] ppalaga commented on a change in pull request #1249: Fix #1232 Per-extension documentation pages

[GitBox]

ppalaga commented on a change in pull request #1249:
URL: https://github.com/apache/camel-quarkus/pull/1249#discussion_r428071529



##
File path: docs/modules/ROOT/pages/extensions/activemq.adoc
##
@@ -0,0 +1,27 @@
+// Do not edit directly!
+// This file was generated by 
camel-quarkus-package-maven-plugin:update-extension-doc-page
+
+[[activemq]]
+= ActiveMQ
+
+*Since Camel Quarkus 1.0.0-M5, JVM and native*
+
+Send messages to (or consume from) Apache ActiveMQ. This component extends the 
Camel JMS component.
+
+== What's inside

Review comment:
   The problem with "components" on this level is that technically not only 
components can be listed here: there can also be languages, data formats and 
"others". How about `Included Camel bits`?





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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-quarkus] ppalaga commented on a change in pull request #1249: Fix #1232 Per-extension documentation pages

[GitBox]

ppalaga commented on a change in pull request #1249:
URL: https://github.com/apache/camel-quarkus/pull/1249#discussion_r428054049



##
File path: docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc
##
@@ -799,11 +805,5 @@ Number of miscellaneous extensions: 12 in 12 JAR artifacts 
(0 deprecated)
 
 | (camel-quarkus-reactive-executor) | Native +
  Stable | 0.3.0 | Reactive Executor for camel-core using Vert.x
-
-| (camel-quarkus-xml-io) | Native +
- Stable | 1.0.0-M5 | An XML stack for parsing XML route definitions. A fast an 
light weight alternative to camel-quarkus-xml-jaxp
-
-| (camel-quarkus-xml-jaxb) | Native +
- Stable | 1.0.0-M5 | An XML stack for parsing XML route definitions. A legacy 
alternative to the fast an light weight camel-quarkus-xml-io

Review comment:
   The change of ordering does not look right. Let me check.





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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-kafka-connector] oscerd opened a new pull request #231: Bump to Camel 3.3.0

[GitBox]

oscerd opened a new pull request #231:
URL: https://github.com/apache/camel-kafka-connector/pull/231


   Fixed #217 



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel-kafka-connector] branch camel-3.3.0 created (now 8a5a644)

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a change to branch camel-3.3.0
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.


  at 8a5a644  Bump to Camel 3.3.0

This branch includes the following new commits:

 new 8a5a644  Bump to Camel 3.3.0

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] jamesnetherton edited a comment on pull request #1248: Add support for MicroProfile Fault Tolerance

[GitBox]

jamesnetherton edited a comment on pull request #1248:
URL: https://github.com/apache/camel-quarkus/pull/1248#issuecomment-631510485


   Merging as Kudu test failure is not related.



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel-spring-boot] branch master updated: Regen

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git


The following commit(s) were added to refs/heads/master by this push:
 new 84a7eb1  Regen
84a7eb1 is described below

commit 84a7eb1d76f543fa28b529b3a5122171742c00d3
Author: Andrea Cosentino 
AuthorDate: Wed May 20 16:31:57 2020 +0200

Regen
---
 .../org/apache/camel/springboot/catalog/components/kudu.json| 2 +-
 .../org/apache/camel/springboot/catalog/components/ldap.json| 2 +-
 .../org/apache/camel/springboot/catalog/components/mllp.json| 2 +-
 .../org/apache/camel/springboot/catalog/components/netty-http.json  | 2 +-
 .../apache/camel/springboot/catalog/components/rest-openapi.json| 2 +-
 .../org/apache/camel/springboot/catalog/components/salesforce.json  | 2 +-
 .../apache/camel/springboot/catalog/components/sap-netweaver.json   | 2 +-
 .../org/apache/camel/springboot/catalog/components/splunk.json  | 2 +-
 .../apache/camel/springboot/catalog/components/string-template.json | 2 +-
 .../org/apache/camel/springboot/catalog/components/telegram.json| 2 +-
 .../org/apache/camel/springboot/catalog/components/thrift.json  | 2 +-
 .../camel/springboot/catalog/components/twitter-directmessage.json  | 2 +-
 .../apache/camel/springboot/catalog/components/twitter-search.json  | 2 +-
 .../camel/springboot/catalog/components/twitter-timeline.json   | 2 +-
 .../org/apache/camel/springboot/catalog/components/web3j.json   | 2 +-
 .../org/apache/camel/springboot/catalog/components/weka.json| 2 +-
 .../org/apache/camel/springboot/catalog/components/wordpress.json   | 2 +-
 .../org/apache/camel/springboot/catalog/components/workday.json | 2 +-
 .../org/apache/camel/springboot/catalog/components/yammer.json  | 2 +-
 .../org/apache/camel/springboot/catalog/components/zendesk.json | 2 +-
 .../camel/springboot/catalog/components/zookeeper-master.json   | 2 +-
 .../org/apache/camel/springboot/catalog/components/zookeeper.json   | 2 +-
 tooling/camel-spring-boot-dependencies/pom.xml  | 6 +++---
 23 files changed, 25 insertions(+), 25 deletions(-)

diff --git 
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kudu.json
 
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kudu.json
index d75a08e..05ba606 100644
--- 
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kudu.json
+++ 
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/kudu.json
@@ -6,7 +6,7 @@
 "description": "Interact with Apache Kudu, a free and open source 
column-oriented data store of the Apache Hadoop ecosystem.",
 "deprecated": false,
 "firstVersion": "3.0",
-"label": "cloud,database,iot",
+"label": "database,iot,cloud",
 "javaType": "org.apache.camel.component.kudu.KuduComponent",
 "supportLevel": "Stable",
 "groupId": "org.apache.camel.springboot",
diff --git 
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/ldap.json
 
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/ldap.json
index bb0afe7..f0a8b7d 100644
--- 
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/ldap.json
+++ 
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/ldap.json
@@ -6,7 +6,7 @@
 "description": "Perform searches on LDAP servers.",
 "deprecated": false,
 "firstVersion": "1.5.0",
-"label": "ldap",
+"label": "search,ldap",
 "javaType": "org.apache.camel.component.ldap.LdapComponent",
 "supportLevel": "Stable",
 "groupId": "org.apache.camel.springboot",
diff --git 
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/mllp.json
 
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/mllp.json
index a31fc35..423d21a 100644
--- 
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/mllp.json
+++ 
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/mllp.json
@@ -6,7 +6,7 @@
 "description": "Communicate with external systems using the MLLP 
protocol.",
 "deprecated": false,
 "firstVersion": "2.17.0",
-"label": "mllp",
+"label": "networking,rpc,mllp",
 "javaType": "org.apache.camel.component.mllp.MllpComponent",
 "supportLevel": "Stable",
 "groupId": "org.apache.camel.springboot",
diff --git 

[GitHub] [camel-quarkus] jamesnetherton commented on a change in pull request #1249: Fix #1232 Per-extension documentation pages

[GitBox]

jamesnetherton commented on a change in pull request #1249:
URL: https://github.com/apache/camel-quarkus/pull/1249#discussion_r428056131



##
File path: docs/modules/ROOT/pages/extensions/activemq.adoc
##
@@ -0,0 +1,27 @@
+// Do not edit directly!
+// This file was generated by 
camel-quarkus-package-maven-plugin:update-extension-doc-page
+
+[[activemq]]
+= ActiveMQ
+
+*Since Camel Quarkus 1.0.0-M5, JVM and native*
+
+Send messages to (or consume from) Apache ActiveMQ. This component extends the 
Camel JMS component.
+
+== What's inside

Review comment:
   Maybe 'Included components'? I don't want to get too hung up on wording 
so if you disagree, that's ok.

##
File path: docs/modules/ROOT/pages/extensions/activemq.adoc
##
@@ -0,0 +1,27 @@
+// Do not edit directly!
+// This file was generated by 
camel-quarkus-package-maven-plugin:update-extension-doc-page
+
+[[activemq]]
+= ActiveMQ
+
+*Since Camel Quarkus 1.0.0-M5, JVM and native*

Review comment:
   Might be better to separate the support level (JVM and native) out into 
it's own heading. WDYT?

##
File path: docs/modules/ROOT/pages/extensions/activemq.adoc
##
@@ -0,0 +1,27 @@
+// Do not edit directly!
+// This file was generated by 
camel-quarkus-package-maven-plugin:update-extension-doc-page
+
+[[activemq]]
+= ActiveMQ
+
+*Since Camel Quarkus 1.0.0-M5, JVM and native*
+
+Send messages to (or consume from) Apache ActiveMQ. This component extends the 
Camel JMS component.
+
+== What's inside
+
+* https://camel.apache.org/components/latest/activemq-component.html[ActiveMQ 
component]
+
+Please refer to the above links for the usage.

Review comment:
   'for usage details' instead of 'for the usage'





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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-quarkus] jamesnetherton closed issue #1234: Add support for MicroProfile Fault Tolerance

[GitBox]

jamesnetherton closed issue #1234:
URL: https://github.com/apache/camel-quarkus/issues/1234


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel-quarkus] 01/02: Add support for MicroProfile Fault Tolerance

[jamesnetherton]

This is an automated email from the ASF dual-hosted git repository.

jamesnetherton pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git

commit 6b01c12514571fa3fbb221f6599149430d73f4db
Author: James Netherton 
AuthorDate: Wed May 20 07:04:55 2020 +0100

Add support for MicroProfile Fault Tolerance

Fixes #1234
---
 .../pages/list-of-camel-quarkus-extensions.adoc|  5 +-
 .../deployment/pom.xml | 79 
 .../MicroprofileFaultToleranceProcessor.java   | 30 
 extensions/microprofile-fault-tolerance/pom.xml| 39 ++
 .../microprofile-fault-tolerance/runtime/pom.xml   | 87 ++
 .../main/resources/META-INF/quarkus-extension.yaml | 29 
 extensions/pom.xml |  1 +
 integration-tests/microprofile/pom.xml |  6 +-
 .../MicroProfileFaultToleranceRoutes.java  | 43 +++
 .../MicroprofileFaultToleranceResource.java| 38 ++
 .../metrics/MicroProfileMetricsRouteBuilder.java   |  1 +
 .../MicroprofileFaultToleranceIT.java  | 24 ++
 .../MicroprofileFaultToleranceTest.java| 42 +++
 .../it/metrics/MicroProfileMetricsTest.java|  2 +-
 poms/bom-deployment/pom.xml|  5 ++
 poms/bom/pom.xml   | 10 +++
 16 files changed, 438 insertions(+), 3 deletions(-)

diff --git a/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc 
b/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc
index 125de90..6ca7f5a 100644
--- a/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc
+++ b/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc
@@ -764,7 +764,7 @@ Level | Since | Description
 == Miscellaneous Extensions
 
 // others: START
-Number of miscellaneous extensions: 12 in 12 JAR artifacts (0 deprecated)
+Number of miscellaneous extensions: 13 in 13 JAR artifacts (0 deprecated)
 
 [width="100%",cols="4,1,1,5",options="header"]
 |===
@@ -788,6 +788,9 @@ Number of miscellaneous extensions: 12 in 12 JAR artifacts 
(0 deprecated)
 | (camel-quarkus-kotlin) | Native +
  Stable | 1.0.0-M3 | Write Camel integration routes in Kotlin
 
+| (camel-quarkus-microprofile-fault-tolerance) | Native +
+ Stable | 1.0.0-M8 | Circuit Breaker EIP using Microprofile Fault Tolerance
+
 | xref:extensions/microprofile-health.adoc[camel-quarkus-microprofile-health]  
| Native +
  Stable | 0.3.0 | Bridging Eclipse MicroProfile Health with Camel health checks
 
diff --git a/extensions/microprofile-fault-tolerance/deployment/pom.xml 
b/extensions/microprofile-fault-tolerance/deployment/pom.xml
new file mode 100644
index 000..24508e4
--- /dev/null
+++ b/extensions/microprofile-fault-tolerance/deployment/pom.xml
@@ -0,0 +1,79 @@
+
+
+http://maven.apache.org/POM/4.0.0;
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
http://maven.apache.org/xsd/maven-4.0.0.xsd;>
+4.0.0
+
+org.apache.camel.quarkus
+
camel-quarkus-microprofile-fault-tolerance-parent
+1.1.0-SNAPSHOT
+../pom.xml
+
+
+
camel-quarkus-microprofile-fault-tolerance-deployment
+Camel Quarkus :: Microprofile Fault Tolerance :: Deployment
+
+
+
+
+org.apache.camel.quarkus
+camel-quarkus-bom-deployment
+${project.version}
+pom
+import
+
+
+
+
+
+
+io.quarkus
+
quarkus-smallrye-fault-tolerance-deployment
+
+
+org.apache.camel.quarkus
+camel-quarkus-core-deployment
+
+
+org.apache.camel.quarkus
+camel-quarkus-microprofile-fault-tolerance
+
+
+
+
+
+
+org.apache.maven.plugins
+maven-compiler-plugin
+
+
+
+io.quarkus
+
quarkus-extension-processor
+${quarkus.version}
+
+
+
+
+
+
+
+
diff --git 
a/extensions/microprofile-fault-tolerance/deployment/src/main/java/org/apache/camel/quarkus/component/microprofile/fault/tolerance/deployment/MicroprofileFaultToleranceProcessor.java
 
b/extensions/microprofile-fault-tolerance/deployment/src/main/java/org/apache/camel/quarkus/component/microprofile/fault/tolerance/deployment/MicroprofileFaultToleranceProcessor.java
new file mode 100644
index 000..d5b8b14
--- /dev/null
+++ 
b/extensions/microprofile-fault-tolerance/deployment/src/main/java/org/apache/camel/quarkus/component/microprofile/fault/tolerance/deployment/MicroprofileFaultToleranceProcessor.java
@@ -0,0 

[GitHub] [camel-quarkus] jamesnetherton commented on pull request #1248: Add support for MicroProfile Fault Tolerance

[GitBox]

jamesnetherton commented on pull request #1248:
URL: https://github.com/apache/camel-quarkus/pull/1248#issuecomment-631510485


   Merging as Kudu test failure is not unrelated.



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel-quarkus] branch master updated (34298be -> 17c9d0d)

[jamesnetherton]

This is an automated email from the ASF dual-hosted git repository.

jamesnetherton pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git.


from 34298be  Debezium PostgresSQL Connector native support #1191
 new 6b01c12  Add support for MicroProfile Fault Tolerance
 new 17c9d0d  Use random port for quarkus.http.test-ssl-port

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:
 .../pages/list-of-camel-quarkus-extensions.adoc|  5 -
 .../deployment/pom.xml | 16 +++
 .../MicroprofileFaultToleranceProcessor.java   |  7 ---
 .../pom.xml|  4 ++--
 .../microprofile-fault-tolerance}/runtime/pom.xml  | 15 +-
 .../main/resources/META-INF/quarkus-extension.yaml |  6 +++---
 extensions/pom.xml |  1 +
 integration-tests/microprofile/pom.xml |  6 +-
 .../MicroProfileFaultToleranceRoutes.java} | 24 ++
 .../MicroprofileFaultToleranceResource.java}   | 14 +
 .../metrics/MicroProfileMetricsRouteBuilder.java   |  1 +
 .../MicroprofileFaultToleranceIT.java} |  4 ++--
 .../MicroprofileFaultToleranceTest.java}   | 22 
 .../it/metrics/MicroProfileMetricsTest.java|  2 +-
 poms/bom-deployment/pom.xml|  5 +
 poms/bom/pom.xml   | 10 +
 poms/build-parent-it/pom.xml   |  4 
 17 files changed, 95 insertions(+), 51 deletions(-)
 copy extensions/{debezium-postgres => 
microprofile-fault-tolerance}/deployment/pom.xml (87%)
 copy 
extensions-support/jetty/deployment/src/main/java/org/apache/camel/quarkus/support/jetty/deployment/JettySupportFeature.java
 => 
extensions/microprofile-fault-tolerance/deployment/src/main/java/org/apache/camel/quarkus/component/microprofile/fault/tolerance/deployment/MicroprofileFaultToleranceProcessor.java
 (83%)
 copy extensions/{aws2-s3 => microprofile-fault-tolerance}/pom.xml (91%)
 copy {extensions-jvm/avro-rpc => 
extensions/microprofile-fault-tolerance}/runtime/pom.xml (82%)
 copy {extensions-core/caffeine-lrucache => 
extensions/microprofile-fault-tolerance}/runtime/src/main/resources/META-INF/quarkus-extension.yaml
 (82%)
 copy 
integration-tests/{scheduler/src/main/java/org/apache/camel/quarkus/component/scheduler/it/SchedulerRoute.java
 => 
microprofile/src/main/java/org/apache/camel/quarkus/component/microprofile/it/faulttolerance/MicroProfileFaultToleranceRoutes.java}
 (53%)
 copy 
integration-tests/{exec/src/main/java/org/apache/camel/quarkus/component/exec/it/ExecResource.java
 => 
microprofile/src/main/java/org/apache/camel/quarkus/component/microprofile/it/faulttolerance/MicroprofileFaultToleranceResource.java}
 (76%)
 copy 
integration-tests/{activemq/src/test/java/org/apache/camel/quarkus/component/activemq/it/ActiveMQIT.java
 => 
microprofile/src/test/java/org/apache/camel/quarkus/component/microprofile/it/faulttolerance/MicroprofileFaultToleranceIT.java}
 (85%)
 copy 
integration-tests/{github/src/test/java/org/apache/camel/quarkus/component/github/it/GithubTest.java
 => 
microprofile/src/test/java/org/apache/camel/quarkus/component/microprofile/it/faulttolerance/MicroprofileFaultToleranceTest.java}
 (60%)

[GitHub] [camel-quarkus] jamesnetherton merged pull request #1248: Add support for MicroProfile Fault Tolerance

[GitBox]

jamesnetherton merged pull request #1248:
URL: https://github.com/apache/camel-quarkus/pull/1248


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel-quarkus] 02/02: Use random port for quarkus.http.test-ssl-port

[jamesnetherton]

This is an automated email from the ASF dual-hosted git repository.

jamesnetherton pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git

commit 17c9d0d39d9a76bc796ca6dd7ce9734fc7d250af
Author: James Netherton 
AuthorDate: Wed May 20 13:13:08 2020 +0100

Use random port for quarkus.http.test-ssl-port
---
 poms/build-parent-it/pom.xml | 4 
 1 file changed, 4 insertions(+)

diff --git a/poms/build-parent-it/pom.xml b/poms/build-parent-it/pom.xml
index d3fdf4f..b57be92 100644
--- a/poms/build-parent-it/pom.xml
+++ b/poms/build-parent-it/pom.xml
@@ -59,6 +59,7 @@
 
 
 
${test.http.port.jvm}
+
${test.https.port.jvm}
 
 
 
@@ -70,6 +71,7 @@
 
 
 
${test.http.port.native}
+
${test.https.port.native}
 
 
 
@@ -92,7 +94,9 @@
 
 
 test.http.port.jvm
+test.https.port.jvm
 test.http.port.native
+test.https.port.native
 
 
 

[GitHub] [camel-quarkus] ppalaga commented on pull request #1215: Debezium PostgresSQL Connector native support #1191

[GitBox]

ppalaga commented on pull request #1215:
URL: https://github.com/apache/camel-quarkus/pull/1215#issuecomment-631500401


   Thanks, @JiriOndrusek !



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-quarkus] ppalaga merged pull request #1215: Debezium PostgresSQL Connector native support #1191

[GitBox]

ppalaga merged pull request #1215:
URL: https://github.com/apache/camel-quarkus/pull/1215


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel-quarkus] branch master updated (a97b3d1 -> 34298be)

[ppalaga]

This is an automated email from the ASF dual-hosted git repository.

ppalaga pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git.


from a97b3d1  Disabled Kudu itests on JRE 8 as not supported
 add 34298be  Debezium PostgresSQL Connector native support #1191

No new revisions were added by this update.

Summary of changes:
 .github/test-categories.yaml   |   1 +
 .../ROOT/pages/extensions/debezium-postgres.adoc   |  30 +
 .../pages/list-of-camel-quarkus-extensions.adoc|   4 +-
 .../deployment/DebeziumPostgresProcessor.java  |  47 ---
 .../debezium-postgres/integration-test/pom.xml |  81 ---
 .../debezium/postgres/it/DebeziumPostgresTest.java |  34 -
 extensions-jvm/debezium-postgres/pom.xml   |  38 --
 extensions-jvm/pom.xml |   1 -
 .../debezium-postgres/deployment/pom.xml   |  10 +-
 .../deployment/DebeziumPostgresProcessor.java} |  43 +++---
 extensions/{aws2-s3 => debezium-postgres}/pom.xml  |   4 +-
 .../debezium-postgres/runtime/pom.xml  |  22 ++-
 .../postgres/graal/SubstituteMetrics.java} |  22 +--
 .../main/resources/META-INF/quarkus-extension.yaml |   4 +-
 extensions/pom.xml |   1 +
 .../{influxdb => debezium-postgres}/pom.xml|  29 ++--
 .../postgres/it/DebeziumPostgresResource.java  |  34 +++--
 .../debezium/postgres/it/DebeziumPostgresIT.java}  |   4 +-
 .../debezium/postgres/it/DebeziumPostgresTest.java | 148 +
 .../postgres/it/DebeziumPostgresTestResource.java  |  98 ++
 .../src/test/resources/init.sql}   |   5 +-
 integration-tests/pom.xml  |   1 +
 22 files changed, 379 insertions(+), 282 deletions(-)
 create mode 100644 docs/modules/ROOT/pages/extensions/debezium-postgres.adoc
 delete mode 100644 
extensions-jvm/debezium-postgres/deployment/src/main/java/org/apache/camel/quarkus/component/debezium/postgres/deployment/DebeziumPostgresProcessor.java
 delete mode 100644 extensions-jvm/debezium-postgres/integration-test/pom.xml
 delete mode 100644 
extensions-jvm/debezium-postgres/integration-test/src/test/java/org/apache/camel/quarkus/component/debezium/postgres/it/DebeziumPostgresTest.java
 delete mode 100644 extensions-jvm/debezium-postgres/pom.xml
 rename {extensions-jvm => extensions}/debezium-postgres/deployment/pom.xml 
(88%)
 copy 
extensions/{influxdb/deployment/src/main/java/org/apache/camel/quarkus/component/influxdb/deployment/InfluxdbProcessor.java
 => 
debezium-postgres/deployment/src/main/java/org/apache/camel/quarkus/component/debezium/postgres/deployment/DebeziumPostgresProcessor.java}
 (57%)
 copy extensions/{aws2-s3 => debezium-postgres}/pom.xml (91%)
 rename {extensions-jvm => extensions}/debezium-postgres/runtime/pom.xml (85%)
 copy 
extensions/{paho/runtime/src/main/java/org/apache/camel/quarkus/component/paho/graal/SubstituteBase64.java
 => 
debezium-postgres/runtime/src/main/java/org/apache/camel/quarkus/component/debezium/postgres/graal/SubstituteMetrics.java}
 (59%)
 rename {extensions-jvm => 
extensions}/debezium-postgres/runtime/src/main/resources/META-INF/quarkus-extension.yaml
 (89%)
 copy integration-tests/{influxdb => debezium-postgres}/pom.xml (84%)
 rename {extensions-jvm/debezium-postgres/integration-test => 
integration-tests/debezium-postgres}/src/main/java/org/apache/camel/quarkus/component/debezium/postgres/it/DebeziumPostgresResource.java
 (53%)
 copy 
integration-tests/{activemq/src/test/java/org/apache/camel/quarkus/component/activemq/it/ActiveMQIT.java
 => 
debezium-postgres/src/test/java/org/apache/camel/quarkus/component/debezium/postgres/it/DebeziumPostgresIT.java}
 (87%)
 create mode 100644 
integration-tests/debezium-postgres/src/test/java/org/apache/camel/quarkus/component/debezium/postgres/it/DebeziumPostgresTest.java
 create mode 100644 
integration-tests/debezium-postgres/src/test/java/org/apache/camel/quarkus/component/debezium/postgres/it/DebeziumPostgresTestResource.java
 copy integration-tests/{sql/src/main/resources/sql/get-camels.sql => 
debezium-postgres/src/test/resources/init.sql} (87%)

[GitHub] [camel] mmelko opened a new pull request #3847: Update camel-3-migration-guide.adoc

[GitBox]

mmelko opened a new pull request #3847:
URL: https://github.com/apache/camel/pull/3847


   Adding also `getCamelContexts` method that has been removed too and it's 
accessible.
   
   [ ] Make sure there is a [JIRA 
issue](https://issues.apache.org/jira/browse/CAMEL) filed for the change 
(usually before you start working on it).  Trivial changes like typos do not 
require a JIRA issue.  Your pull request should address just this issue, 
without pulling in other changes.
   [ ] Each commit in the pull request should have a meaningful subject line 
and body.
   [ ] If you're unsure, you can format the pull request title like 
`[CAMEL-XXX] Fixes bug in camel-file component`, where you replace `CAMEL-XXX` 
with the appropriate JIRA issue.
   [ ] Write a pull request description that is detailed enough to understand 
what the pull request does, how, and why.
   [ ] Run `mvn clean install -Psourcecheck` in your module with source check 
enabled to make sure basic checks pass and there are no checkstyle violations. 
A more thorough check will be performed on your pull request automatically.
   Below are the contribution guidelines:
   https://github.com/apache/camel/blob/master/CONTRIBUTING.md



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel-quarkus] branch master updated (35f77ad -> a97b3d1)

[aldettinger]

This is an automated email from the ASF dual-hosted git repository.

aldettinger pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git.


from 35f77ad  Restored Kudu IT tests and added a troubleshooting section 
#1206
 add a97b3d1  Disabled Kudu itests on JRE 8 as not supported

No new revisions were added by this update.

Summary of changes:
 .../test/java/org/apache/camel/quarkus/component/kudu/it/KuduIT.java   | 3 +++
 .../test/java/org/apache/camel/quarkus/component/kudu/it/KuduTest.java | 3 +++
 2 files changed, 6 insertions(+)

[GitHub] [camel] mmelko opened a new pull request #3846: Update camel-3-migration-guide.adoc

[GitBox]

mmelko opened a new pull request #3846:
URL: https://github.com/apache/camel/pull/3846


   add formatting for renamed terser component.
   
   [ ] Make sure there is a [JIRA 
issue](https://issues.apache.org/jira/browse/CAMEL) filed for the change 
(usually before you start working on it).  Trivial changes like typos do not 
require a JIRA issue.  Your pull request should address just this issue, 
without pulling in other changes.
   [ ] Each commit in the pull request should have a meaningful subject line 
and body.
   [ ] If you're unsure, you can format the pull request title like 
`[CAMEL-XXX] Fixes bug in camel-file component`, where you replace `CAMEL-XXX` 
with the appropriate JIRA issue.
   [ ] Write a pull request description that is detailed enough to understand 
what the pull request does, how, and why.
   [ ] Run `mvn clean install -Psourcecheck` in your module with source check 
enabled to make sure basic checks pass and there are no checkstyle violations. 
A more thorough check will be performed on your pull request automatically.
   Below are the contribution guidelines:
   https://github.com/apache/camel/blob/master/CONTRIBUTING.md



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-quarkus] JiriOndrusek commented on a change in pull request #1215: Debezium PostgresSQL Connector native support #1191

[GitBox]

JiriOndrusek commented on a change in pull request #1215:
URL: https://github.com/apache/camel-quarkus/pull/1215#discussion_r428044591



##
File path: 
integration-tests/debezium-postgres/src/test/java/org/apache/camel/quarkus/component/debezium/postgres/it/DebeziumPostgresTestResource.java
##
@@ -0,0 +1,98 @@
+/*
+ * 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.debezium.postgres.it;
+
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.util.Collections;
+import java.util.Map;
+
+import 
org.apache.camel.quarkus.testcontainers.ContainerResourceLifecycleManager;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.testcontainers.containers.PostgreSQLContainer;
+import org.testcontainers.utility.TestcontainersConfiguration;
+
+public class DebeziumPostgresTestResource implements 
ContainerResourceLifecycleManager {
+private static final Logger LOGGER = 
LoggerFactory.getLogger(DebeziumPostgresTestResource.class);
+
+private static final int POSTGRES_PORT = 5432;
+private static final String POSTGRES_IMAGE = "debezium/postgres:11";
+
+private PostgreSQLContainer postgresContainer;
+private Connection connection;
+private Path storeFile;
+private String hostname;
+private int port;
+
+@Override
+public Map start() {
+LOGGER.info(TestcontainersConfiguration.getInstance().toString());
+
+try {
+storeFile = Files.createTempFile("debezium-postgress-store-", "");
+
+postgresContainer = new PostgreSQLContainer<>(POSTGRES_IMAGE)
+.withUsername(DebeziumPostgresResource.DB_USERNAME)
+.withPassword(DebeziumPostgresResource.DB_PASSWORD)
+.withDatabaseName(DebeziumPostgresResource.DB_NAME)
+.withInitScript("init.sql");
+
+postgresContainer.start();
+
+final String jdbcUrl = "jdbc:postgresql://" + 
postgresContainer.getContainerIpAddress() + ":"
++ postgresContainer.getMappedPort(POSTGRES_PORT) + "/" + 
DebeziumPostgresResource.DB_NAME + "?user="
++ DebeziumPostgresResource.DB_USERNAME + "=" + 
DebeziumPostgresResource.DB_PASSWORD;
+connection = DriverManager.getConnection(jdbcUrl);
+hostname = postgresContainer.getContainerIpAddress();
+port = postgresContainer.getMappedPort(POSTGRES_PORT);
+
+return Collections.emptyMap();
+} catch (Exception e) {
+throw new RuntimeException(e);
+}
+}
+
+@Override
+public void stop() {
+try {
+if (connection != null) {
+connection.close();
+}
+if (postgresContainer != null) {
+postgresContainer.stop();
+}
+if (storeFile != null) {
+Files.deleteIfExists(storeFile);
+}
+} catch (Exception e) {
+// ignored
+}
+}
+
+@Override
+public void inject(Object testInstance) {
+((DebeziumPostgresTest) testInstance).connection = this.connection;

Review comment:
   @jamesnetherton I've started to work on debebezium-mysql. Because this 
extension will be very similar to debezium-postgres (and probably other 
debezium-* extensions). I'd like to refactor each of them to use some 
debezium-common extension. As a part of that refactor I'll cover also this 
issue with properties. -> From my POV I'd fixed it after merging this one PR.





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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-quarkus] ppalaga opened a new pull request #1249: Fix #1232 Per-extension documentation pages

[GitBox]

ppalaga opened a new pull request #1249:
URL: https://github.com/apache/camel-quarkus/pull/1249


   I initially applied the new plugin for auto-generation of the extension 
pages only to activemq and ahc. I will add it to all extension later when there 
is enough agreement about the approach.



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel-kafka-connector-examples] branch master updated: Use the new topics property placeholder for source connectors

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository 
https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git


The following commit(s) were added to refs/heads/master by this push:
 new 0bd0b68  Use the new topics property placeholder for source connectors
0bd0b68 is described below

commit 0bd0b686c2e67718f661ec94eb7bc14a1ed8ea5a
Author: Andrea Cosentino 
AuthorDate: Wed May 20 16:03:01 2020 +0200

Use the new topics property placeholder for source connectors
---
 aws-s3-to-jms/README.md| 2 +-
 aws-s3-to-jms/config/CamelAWSS3SourceConnector.properties  | 2 +-
 aws2-sqs/aws2-sqs-source/README.md | 2 +-
 aws2-sqs/aws2-sqs-source/config/CamelAWS2SQSSourceConnector.properties | 2 +-
 cql/cql-source/README.md   | 2 +-
 cql/cql-source/config/CamelCassandraQLSourceConnector.properties   | 2 +-
 file/file-source/README.md | 2 +-
 file/file-source/config/CamelFileSourceConnector.properties| 2 +-
 8 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/aws-s3-to-jms/README.md b/aws-s3-to-jms/README.md
index bb266f6..cc8c444 100644
--- a/aws-s3-to-jms/README.md
+++ b/aws-s3-to-jms/README.md
@@ -54,7 +54,7 @@ 
value.converter=org.apache.camel.kafkaconnector.awss3.converters.S3ObjectConvert
 
 camel.source.maxPollDuration=1
 
-camel.source.kafka.topic=mytopic
+topics=mytopic
 
 camel.source.url=aws-s3://camel-kafka-connector?autocloseBody=false
 
diff --git a/aws-s3-to-jms/config/CamelAWSS3SourceConnector.properties 
b/aws-s3-to-jms/config/CamelAWSS3SourceConnector.properties
index 5fd1ba7..9c0d586 100644
--- a/aws-s3-to-jms/config/CamelAWSS3SourceConnector.properties
+++ b/aws-s3-to-jms/config/CamelAWSS3SourceConnector.properties
@@ -22,7 +22,7 @@ 
value.converter=org.apache.camel.kafkaconnector.awss3.converters.S3ObjectConvert
 
 camel.source.maxPollDuration=1
 
-camel.source.kafka.topic=mytopic
+topics=mytopic
 
 camel.source.url=aws-s3://camel-kafka-connector?autocloseBody=false
 
diff --git a/aws2-sqs/aws2-sqs-source/README.md 
b/aws2-sqs/aws2-sqs-source/README.md
index 802c42f..ac5585d 100644
--- a/aws2-sqs/aws2-sqs-source/README.md
+++ b/aws2-sqs/aws2-sqs-source/README.md
@@ -44,7 +44,7 @@ 
value.converter=org.apache.kafka.connect.storage.StringConverter
 
 camel.source.maxPollDuration=1
 
-camel.source.kafka.topic=mytopic
+topics=mytopic
 
 camel.source.url=aws2-sqs://camel-1?deleteAfterRead=false=true
 
diff --git 
a/aws2-sqs/aws2-sqs-source/config/CamelAWS2SQSSourceConnector.properties 
b/aws2-sqs/aws2-sqs-source/config/CamelAWS2SQSSourceConnector.properties
index 9aa53eb..6420890 100644
--- a/aws2-sqs/aws2-sqs-source/config/CamelAWS2SQSSourceConnector.properties
+++ b/aws2-sqs/aws2-sqs-source/config/CamelAWS2SQSSourceConnector.properties
@@ -22,7 +22,7 @@ 
value.converter=org.apache.kafka.connect.storage.StringConverter
 
 camel.source.maxPollDuration=1
 
-camel.source.kafka.topic=mytopic
+topics=mytopic
 
 camel.source.path.queueNameOrArn=camel-1
 camel.source.endpoint.deleteAfterRead=false
diff --git a/cql/cql-source/README.md b/cql/cql-source/README.md
index bb340e9..266a1ff 100644
--- a/cql/cql-source/README.md
+++ b/cql/cql-source/README.md
@@ -89,7 +89,7 @@ 
connector.class=org.apache.camel.kafkaconnector.cql.CamelCqlSourceConnector
 key.converter=org.apache.kafka.connect.storage.StringConverter
 value.converter=org.apache.kafka.connect.storage.StringConverter
 
-camel.source.kafka.topic=mytopic
+topics=mytopic
 
 camel.source.path.hosts=172.17.0.2
 camel.source.path.keyspace=9042/test
diff --git a/cql/cql-source/config/CamelCassandraQLSourceConnector.properties 
b/cql/cql-source/config/CamelCassandraQLSourceConnector.properties
index 7346b56..63b3939 100644
--- a/cql/cql-source/config/CamelCassandraQLSourceConnector.properties
+++ b/cql/cql-source/config/CamelCassandraQLSourceConnector.properties
@@ -20,7 +20,7 @@ 
connector.class=org.apache.camel.kafkaconnector.cql.CamelCqlSourceConnector
 key.converter=org.apache.kafka.connect.storage.StringConverter
 value.converter=org.apache.kafka.connect.storage.StringConverter
 
-camel.source.kafka.topic=mytopic
+topics=mytopic
 
 camel.source.path.hosts=172.17.0.2
 camel.source.path.keyspace=9042/test
diff --git a/file/file-source/README.md b/file/file-source/README.md
index 531bdd8..8be8ea9 100644
--- a/file/file-source/README.md
+++ b/file/file-source/README.md
@@ -44,7 +44,7 @@ 
value.converter=org.apache.kafka.connect.storage.StringConverter
 
 camel.source.maxPollDuration=1
 
-camel.source.kafka.topic=mytopic
+topics=mytopic
 
 camel.source.path.directoryName=/tmp/kafkastuff/
 camel.source.endpoint.idempotent=true
diff --git a/file/file-source/config/CamelFileSourceConnector.properties 

[camel-kafka-connector-examples] branch master updated: Fixed docs

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository 
https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git


The following commit(s) were added to refs/heads/master by this push:
 new 0d5143d  Fixed docs
0d5143d is described below

commit 0d5143ddf206798e6ec7f5b778327da5caefe5f5
Author: Andrea Cosentino 
AuthorDate: Wed May 20 15:18:40 2020 +0200

Fixed docs
---
 aws-s3-to-jms/README.md | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/aws-s3-to-jms/README.md b/aws-s3-to-jms/README.md
index d38abb2..bb266f6 100644
--- a/aws-s3-to-jms/README.md
+++ b/aws-s3-to-jms/README.md
@@ -36,9 +36,9 @@ In this example we'll use `/home/oscerd/connectors/`
 
 ```
 > cd /home/oscerd/connectors/
-> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-sjms2-kafka-connector/0.1.0/camel-sjms2-kafka-connector-0.2.0-package.zip
+> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-sjms2-kafka-connector/0.2.0/camel-sjms2-kafka-connector-0.2.0-package.zip
 > unzip camel-sjms2-kafka-connector-0.2.0-package.zip
-> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-aws-s3-kafka-connector/0.1.0/camel-aws-s3-kafka-connector-0.2.0-package.zip
+> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-aws-s3-kafka-connector/0.2.0/camel-aws-s3-kafka-connector-0.2.0-package.zip
 > unzip camel-aws-s3-kafka-connector-0.2.0-package.zip
 ```
 

[camel-kafka-connector-examples] 02/05: AWS2-SNS example: Bump to version 0.2.0

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch 0.2.0
in repository 
https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git

commit 0f307fdada95d68c39df72fcfe60268c1f620a4e
Author: Andrea Cosentino 
AuthorDate: Wed May 20 15:14:01 2020 +0200

AWS2-SNS example: Bump to version 0.2.0
---
 aws2-sns/aws2-sns-sink/README.md | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/aws2-sns/aws2-sns-sink/README.md b/aws2-sns/aws2-sns-sink/README.md
index ad0ae0e..c422fc1 100644
--- a/aws2-sns/aws2-sns-sink/README.md
+++ b/aws2-sns/aws2-sns-sink/README.md
@@ -28,8 +28,8 @@ In this example we'll use `/home/oscerd/connectors/`
 
 ```
 > cd /home/oscerd/connectors/
-> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-aws2-sns-kafka-connector/0.1.0/camel-aws2-sns-kafka-connector-0.1.0-package.zip
-> unzip camel-aws2-sns-kafka-connector-0.1.0-package.zip
+> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-aws2-sns-kafka-connector/0.2.0/camel-aws2-sns-kafka-connector-0.2.0-package.zip
+> unzip camel-aws2-sns-kafka-connector-0.2.0-package.zip
 ```
 
 Now it's time to setup the connectors

[camel-kafka-connector-examples] branch master updated (ad1ddb8 -> 89b675b)

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a change to branch master
in repository 
https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git.


from ad1ddb8  Update README with the correct list of example
 add 5e8618e  AWS-S3 to JMS example: Bump to version 0.2.0
 add 0f307fd  AWS2-SNS example: Bump to version 0.2.0
 add de12ade  AWS2-SQS example: Bump to version 0.2.0
 add 5f247dc  CQL example: Bump to version 0.2.0
 add bc92535  File example: Bump to version 0.2.0
 new 89b675b  Merge pull request #7 from apache/0.2.0

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:
 aws-s3-to-jms/README.md| 19 ---
 aws2-sns/aws2-sns-sink/README.md   |  4 ++--
 aws2-sqs/aws2-sqs-sink/README.md   |  4 ++--
 aws2-sqs/aws2-sqs-source/README.md |  4 ++--
 cql/cql-sink/README.md |  4 ++--
 cql/cql-source/README.md   |  4 ++--
 file/file-sink/README.md   |  4 ++--
 file/file-source/README.md |  4 ++--
 8 files changed, 18 insertions(+), 29 deletions(-)

[camel-kafka-connector-examples] 01/05: AWS-S3 to JMS example: Bump to version 0.2.0

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch 0.2.0
in repository 
https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git

commit 5e8618e0a085e2a3d41fbbd7af37ffb85bdc765f
Author: Andrea Cosentino 
AuthorDate: Wed May 20 15:13:10 2020 +0200

AWS-S3 to JMS example: Bump to version 0.2.0
---
 aws-s3-to-jms/README.md | 19 ---
 1 file changed, 4 insertions(+), 15 deletions(-)

diff --git a/aws-s3-to-jms/README.md b/aws-s3-to-jms/README.md
index 9abad4f..d38abb2 100644
--- a/aws-s3-to-jms/README.md
+++ b/aws-s3-to-jms/README.md
@@ -36,21 +36,10 @@ In this example we'll use `/home/oscerd/connectors/`
 
 ```
 > cd /home/oscerd/connectors/
-> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-sjms2-kafka-connector/0.1.0/camel-sjms2-kafka-connector-0.1.0-package.zip
-> unzip camel-sjms2-kafka-connector-0.1.0-package.zip
-> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-aws-s3-kafka-connector/0.1.0/camel-aws-s3-kafka-connector-0.1.0-package.zip
-> unzip camel-aws-s3-kafka-connector-0.1.0-package.zip
-```
-
-These are the basic connectors. For camel-sjms2 we have a bunch of provided 
dependencies we need to add in our path, so run the following commands (this is 
a known bug of Camel-sjms2kKafka-connector 0.1.0, already fixed for 0.2.0)
-
-```
-> cd /home/oscerd/connectors/camel-sjms2-kafka-connector
-> wget 
https://repo1.maven.org/maven2/org/apache/activemq/activemq-client/5.15.11/activemq-client-5.15.11.jar
-> wget 
https://repo1.maven.org/maven2/org/apache/geronimo/specs/geronimo-jms_2.0_spec/1.0-alpha-2/geronimo-jms_2.0_spec-1.0-alpha-2.jar
-> wget 
https://repo1.maven.org/maven2/org/apache/geronimo/specs/geronimo-annotation_1.0_spec/1.1.1/geronimo-annotation_1.0_spec-1.1.1.jar
-> wget 
https://repo1.maven.org/maven2/javax/management/j2ee/management-api/1.1-rev-1/management-api-1.1-rev-1.jar
-> wget 
https://repo1.maven.org/maven2/org/fusesource/hawtbuf/hawtbuf/1.11/hawtbuf-1.11.jar
+> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-sjms2-kafka-connector/0.1.0/camel-sjms2-kafka-connector-0.2.0-package.zip
+> unzip camel-sjms2-kafka-connector-0.2.0-package.zip
+> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-aws-s3-kafka-connector/0.1.0/camel-aws-s3-kafka-connector-0.2.0-package.zip
+> unzip camel-aws-s3-kafka-connector-0.2.0-package.zip
 ```
 
 Now it's time to setup the connectors

[camel-kafka-connector-examples] branch 0.2.0 created (now bc92535)

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a change to branch 0.2.0
in repository 
https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git.


  at bc92535  File example: Bump to version 0.2.0

This branch includes the following new commits:

 new 5e8618e  AWS-S3 to JMS example: Bump to version 0.2.0
 new 0f307fd  AWS2-SNS example: Bump to version 0.2.0
 new de12ade  AWS2-SQS example: Bump to version 0.2.0
 new 5f247dc  CQL example: Bump to version 0.2.0
 new bc92535  File example: Bump to version 0.2.0

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.

[camel-kafka-connector-examples] 04/05: CQL example: Bump to version 0.2.0

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch 0.2.0
in repository 
https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git

commit 5f247dc53f07f516a047a4d405f7d2936bcb6ed9
Author: Andrea Cosentino 
AuthorDate: Wed May 20 15:16:06 2020 +0200

CQL example: Bump to version 0.2.0
---
 cql/cql-sink/README.md   | 4 ++--
 cql/cql-source/README.md | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/cql/cql-sink/README.md b/cql/cql-sink/README.md
index 4cfb842..c0be367 100644
--- a/cql/cql-sink/README.md
+++ b/cql/cql-sink/README.md
@@ -28,8 +28,8 @@ In this example we'll use `/home/oscerd/connectors/`
 
 ```
 > cd /home/oscerd/connectors/
-> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-cql-kafka-connector/0.1.0/camel-cql-kafka-connector-0.1.0-package.zip
-> unzip camel-cql-kafka-connector-0.1.0-package.zip
+> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-cql-kafka-connector/0.2.0/camel-cql-kafka-connector-0.2.0-package.zip
+> unzip camel-cql-kafka-connector-0.2.0-package.zip
 ```
 
 ## Setting up Apache Cassandra
diff --git a/cql/cql-source/README.md b/cql/cql-source/README.md
index e98f21d..bb340e9 100644
--- a/cql/cql-source/README.md
+++ b/cql/cql-source/README.md
@@ -28,8 +28,8 @@ In this example we'll use `/home/oscerd/connectors/`
 
 ```
 > cd /home/oscerd/connectors/
-> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-cql-kafka-connector/0.1.0/camel-cql-kafka-connector-0.1.0-package.zip
-> unzip camel-cql-kafka-connector-0.1.0-package.zip
+> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-cql-kafka-connector/0.2.0/camel-cql-kafka-connector-0.2.0-package.zip
+> unzip camel-cql-kafka-connector-0.2.0-package.zip
 ```
 
 ## Setting up Apache Cassandra

[camel-kafka-connector-examples] 05/05: File example: Bump to version 0.2.0

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch 0.2.0
in repository 
https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git

commit bc925351778ddccf9f08d4c2eefa69427a262a2e
Author: Andrea Cosentino 
AuthorDate: Wed May 20 15:17:08 2020 +0200

File example: Bump to version 0.2.0
---
 file/file-sink/README.md   | 4 ++--
 file/file-source/README.md | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/file/file-sink/README.md b/file/file-sink/README.md
index d0d7ce4..83b3065 100644
--- a/file/file-sink/README.md
+++ b/file/file-sink/README.md
@@ -28,8 +28,8 @@ In this example we'll use `/home/oscerd/connectors/`
 
 ```
 > cd /home/oscerd/connectors/
-> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-file-kafka-connector/0.1.0/camel-file-kafka-connector-0.1.0-package.zip
-> unzip camel-file-kafka-connector-0.1.0-package.zip
+> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-file-kafka-connector/0.2.0/camel-file-kafka-connector-0.2.0-package.zip
+> unzip camel-file-kafka-connector-0.2.0-package.zip
 ```
 
 Now it's time to setup the connectors
diff --git a/file/file-source/README.md b/file/file-source/README.md
index 13efba2..531bdd8 100644
--- a/file/file-source/README.md
+++ b/file/file-source/README.md
@@ -28,8 +28,8 @@ In this example we'll use `/home/oscerd/connectors/`
 
 ```
 > cd /home/oscerd/connectors/
-> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-file-kafka-connector/0.1.0/camel-file-kafka-connector-0.1.0-package.zip
-> unzip camel-file-kafka-connector-0.1.0-package.zip
+> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-file-kafka-connector/0.2.0/camel-file-kafka-connector-0.2.0-package.zip
+> unzip camel-file-kafka-connector-0.2.0-package.zip
 ```
 
 Now it's time to setup the connectors

[camel-kafka-connector-examples] 03/05: AWS2-SQS example: Bump to version 0.2.0

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch 0.2.0
in repository 
https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git

commit de12adef23ee30728d0ee133c58a14bb251554a6
Author: Andrea Cosentino 
AuthorDate: Wed May 20 15:15:11 2020 +0200

AWS2-SQS example: Bump to version 0.2.0
---
 aws2-sqs/aws2-sqs-sink/README.md   | 4 ++--
 aws2-sqs/aws2-sqs-source/README.md | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/aws2-sqs/aws2-sqs-sink/README.md b/aws2-sqs/aws2-sqs-sink/README.md
index bd8a5e7..5caccca 100644
--- a/aws2-sqs/aws2-sqs-sink/README.md
+++ b/aws2-sqs/aws2-sqs-sink/README.md
@@ -28,8 +28,8 @@ In this example we'll use `/home/oscerd/connectors/`
 
 ```
 > cd /home/oscerd/connectors/
-> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-aws2-sqs-kafka-connector/0.1.0/camel-aws2-sqs-kafka-connector-0.1.0-package.zip
-> unzip camel-aws2-sqs-kafka-connector-0.1.0-package.zip
+> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-aws2-sqs-kafka-connector/0.2.0/camel-aws2-sqs-kafka-connector-0.2.0-package.zip
+> unzip camel-aws2-sqs-kafka-connector-0.2.0-package.zip
 ```
 
 Now it's time to setup the connectors
diff --git a/aws2-sqs/aws2-sqs-source/README.md 
b/aws2-sqs/aws2-sqs-source/README.md
index 3571b5d..802c42f 100644
--- a/aws2-sqs/aws2-sqs-source/README.md
+++ b/aws2-sqs/aws2-sqs-source/README.md
@@ -28,8 +28,8 @@ In this example we'll use `/home/oscerd/connectors/`
 
 ```
 > cd /home/oscerd/connectors/
-> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-aws2-sqs-kafka-connector/0.1.0/camel-aws2-sqs-kafka-connector-0.1.0-package.zip
-> unzip camel-aws2-sqs-kafka-connector-0.1.0-package.zip
+> wget 
https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-aws2-sqs-kafka-connector/0.2.0/camel-aws2-sqs-kafka-connector-0.2.0-package.zip
+> unzip camel-aws2-sqs-kafka-connector-0.2.0-package.zip
 ```
 
 Now it's time to setup the connectors

[camel-kafka-connector-examples] 01/01: Merge pull request #7 from apache/0.2.0

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository 
https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git

commit 89b675b47cc756c38b0b0ed7fc3b97ea1e43a84b
Merge: ad1ddb8 bc92535
Author: Andrea Cosentino 
AuthorDate: Wed May 20 15:17:56 2020 +0200

Merge pull request #7 from apache/0.2.0

Bump to camel-kafka-connector 0.2.0

 aws-s3-to-jms/README.md| 19 ---
 aws2-sns/aws2-sns-sink/README.md   |  4 ++--
 aws2-sqs/aws2-sqs-sink/README.md   |  4 ++--
 aws2-sqs/aws2-sqs-source/README.md |  4 ++--
 cql/cql-sink/README.md |  4 ++--
 cql/cql-source/README.md   |  4 ++--
 file/file-sink/README.md   |  4 ++--
 file/file-source/README.md |  4 ++--
 8 files changed, 18 insertions(+), 29 deletions(-)

[GitHub] [camel-kafka-connector-examples] oscerd opened a new pull request #7: Bump to camel-kafka-connector 0.2.0

[GitBox]

oscerd opened a new pull request #7:
URL: https://github.com/apache/camel-kafka-connector-examples/pull/7


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-kafka-connector-examples] oscerd merged pull request #7: Bump to camel-kafka-connector 0.2.0

[GitBox]

oscerd merged pull request #7:
URL: https://github.com/apache/camel-kafka-connector-examples/pull/7


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel] omarsmak merged pull request #3845: CAMEL-14801: Second patch to change from label to category field and refine some of the categories

[GitBox]

omarsmak merged pull request #3845:
URL: https://github.com/apache/camel/pull/3845


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel-k-runtime] branch master updated: Update yaml.adoc

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-k-runtime.git


The following commit(s) were added to refs/heads/master by this push:
 new 158c202  Update yaml.adoc
158c202 is described below

commit 158c202c2df60b8e293367a2d685b18147a919a2
Author: Claus Ibsen 
AuthorDate: Wed May 20 15:03:35 2020 +0200

Update yaml.adoc
---
 docs/modules/languages/pages/yaml.adoc | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/docs/modules/languages/pages/yaml.adoc 
b/docs/modules/languages/pages/yaml.adoc
index 3a13334..276fa61 100644
--- a/docs/modules/languages/pages/yaml.adoc
+++ b/docs/modules/languages/pages/yaml.adoc
@@ -182,7 +182,7 @@ from:
 - Choice
 - Circuit Breaker
 - Claim Check
-- Convert Body
+- Convert Body To
 - Delay
 - Dynamic Router
 - Enrich

[GitHub] [camel] omarsmak opened a new pull request #3845: CAMEL-14801: Second patch to change from label to category field and refine some of the categories

[GitBox]

omarsmak opened a new pull request #3845:
URL: https://github.com/apache/camel/pull/3845


   
   
   [ ] Make sure there is a [JIRA 
issue](https://issues.apache.org/jira/browse/CAMEL) filed for the change 
(usually before you start working on it).  Trivial changes like typos do not 
require a JIRA issue.  Your pull request should address just this issue, 
without pulling in other changes.
   [ ] Each commit in the pull request should have a meaningful subject line 
and body.
   [ ] If you're unsure, you can format the pull request title like 
`[CAMEL-XXX] Fixes bug in camel-file component`, where you replace `CAMEL-XXX` 
with the appropriate JIRA issue.
   [ ] Write a pull request description that is detailed enough to understand 
what the pull request does, how, and why.
   [ ] Run `mvn clean install -Psourcecheck` in your module with source check 
enabled to make sure basic checks pass and there are no checkstyle violations. 
A more thorough check will be performed on your pull request automatically.
   Below are the contribution guidelines:
   https://github.com/apache/camel/blob/master/CONTRIBUTING.md



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel-kafka-connector] branch master updated: Camel 3.3 changes

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git


The following commit(s) were added to refs/heads/master by this push:
 new b7894ca  Camel 3.3 changes
 new dd00d3b  Merge pull request #230 from orpiske/camel-3.3-upgrade
b7894ca is described below

commit b7894ca6db85b7ef3cf1f91fd3c9215fdacc01de
Author: Otavio Rodolfo Piske 
AuthorDate: Thu May 14 15:11:41 2020 +0200

Camel 3.3 changes
---
 .../apache/camel/kafkaconnector/utils/CamelMainSupport.java| 10 ++
 parent/pom.xml |  2 +-
 2 files changed, 11 insertions(+), 1 deletion(-)

diff --git 
a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java
 
b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java
index 6d47e10..66f46fb 100644
--- 
a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java
+++ 
b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java
@@ -213,6 +213,16 @@ public class CamelMainSupport {
 @Override
 public void beforeConfigure(BaseMainSupport main) {
 }
+
+@Override
+public void afterConfigure(BaseMainSupport main) {
+
+}
+
+@Override
+public void beforeInitialize(BaseMainSupport main) {
+
+}
 }
 
 private class CamelContextStarter implements Runnable {
diff --git a/parent/pom.xml b/parent/pom.xml
index 1c21538..3c76418 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -30,7 +30,7 @@
 5.15.12
 2.4.1
 5.6.2
-3.2.0
+3.3.0
 2.10.3
 2.8.2
 2.6

[GitHub] [camel-kafka-connector] oscerd merged pull request #230: Version bump to Camel 3.3.0

[GitBox]

oscerd merged pull request #230:
URL: https://github.com/apache/camel-kafka-connector/pull/230


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-kafka-connector] oscerd commented on pull request #230: Version bump to Camel 3.3.0

[GitBox]

oscerd commented on pull request #230:
URL: 
https://github.com/apache/camel-kafka-connector/pull/230#issuecomment-631452316


   Related to #217 



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-kafka-connector] oscerd commented on pull request #230: Version bump to Camel 3.3.0

[GitBox]

oscerd commented on pull request #230:
URL: 
https://github.com/apache/camel-kafka-connector/pull/230#issuecomment-631448417


   I think some connectors are not generated. By the way lets see if all pass 
and then I'll check locally.



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-kafka-connector] orpiske commented on pull request #230: Version bump to Camel 3.3.0

[GitBox]

orpiske commented on pull request #230:
URL: 
https://github.com/apache/camel-kafka-connector/pull/230#issuecomment-631447793


   @oscerd should I close this one? I am investigating #215 and thought about 
trying w/ the latest. 



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-kafka-connector] oscerd commented on pull request #230: Version bump to Camel 3.3.0

[GitBox]

oscerd commented on pull request #230:
URL: 
https://github.com/apache/camel-kafka-connector/pull/230#issuecomment-631446737


   This was already assigned.



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel] branch master updated: Changes in HazelcastAggregationRepository to use replicated maps (#3841)

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
 new 6ece3f8  Changes in HazelcastAggregationRepository to use replicated 
maps (#3841)
6ece3f8 is described below

commit 6ece3f804e5f3694d12df3b71ad225f3e34bfe0a
Author: Marco Longobardi 
AuthorDate: Wed May 20 14:19:55 2020 +0200

Changes in HazelcastAggregationRepository to use replicated maps (#3841)

* Create ReplicatedHazelcastAggregationRepository.java

Changes to use replicated maps

* Update HazelcastAggregationRepository.java

Changes to use replicated maps
---
 .../hazelcast/HazelcastAggregationRepository.java  |  22 +--
 ... ReplicatedHazelcastAggregationRepository.java} | 205 +
 2 files changed, 60 insertions(+), 167 deletions(-)

diff --git 
a/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/HazelcastAggregationRepository.java
 
b/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/HazelcastAggregationRepository.java
index 58fde58..a3409a2 100644
--- 
a/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/HazelcastAggregationRepository.java
+++ 
b/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/HazelcastAggregationRepository.java
@@ -57,20 +57,20 @@ public class HazelcastAggregationRepository extends 
ServiceSupport
   implements 
RecoverableAggregationRepository,
  
OptimisticLockingAggregationRepository {
 private static final Logger LOG = 
LoggerFactory.getLogger(HazelcastAggregationRepository.class.getName());
-private static final String COMPLETED_SUFFIX = "-completed";
+protected static final String COMPLETED_SUFFIX = "-completed";
 
-private boolean optimistic;
-private boolean useLocalHzInstance;
-private boolean useRecovery = true;
+protected boolean optimistic;
+protected boolean useLocalHzInstance;
+protected boolean useRecovery = true;
 private IMap cache;
 private IMap persistedCache;
-private HazelcastInstance hzInstance;
-private String mapName;
-private String persistenceMapName;
-private String deadLetterChannel;
-private long recoveryInterval = 5000;
-private int maximumRedeliveries = 3;
-private boolean allowSerializedHeaders;
+protected HazelcastInstance hzInstance;
+protected String mapName;
+protected String persistenceMapName;
+protected String deadLetterChannel;
+protected long recoveryInterval = 5000;
+protected int maximumRedeliveries = 3;
+protected boolean allowSerializedHeaders;
 
 /**
  * Creates new {@link HazelcastAggregationRepository} that defaults to 
non-optimistic locking
diff --git 
a/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/HazelcastAggregationRepository.java
 
b/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/ReplicatedHazelcastAggregationRepository.java
similarity index 65%
copy from 
components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/HazelcastAggregationRepository.java
copy to 
components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/ReplicatedHazelcastAggregationRepository.java
index 58fde58..21cec1a 100644
--- 
a/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/HazelcastAggregationRepository.java
+++ 
b/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/ReplicatedHazelcastAggregationRepository.java
@@ -18,6 +18,7 @@ package org.apache.camel.processor.aggregate.hazelcast;
 
 import java.util.Collections;
 import java.util.Set;
+import java.util.Map;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.locks.Lock;
 
@@ -46,132 +47,100 @@ import org.slf4j.LoggerFactory;
  * {@link RecoverableAggregationRepository} and {@link 
OptimisticLockingAggregationRepository}.
  * Defaults to thread-safe (non-optimistic) locking and recoverable strategy.
  * Hazelcast settings are given to an end-user and can be controlled with 
repositoryName and persistentRespositoryName,
- * both are {@link com.hazelcast.map.IMap} String, Exchange. However 
HazelcastAggregationRepository
+ * both are {@link com.hazelcast.map.IMap} String, Exchange. However 
ReplicatedHazelcastAggregationRepository
  * can run it's own Hazelcast instance, but obviously no benefits of Hazelcast 
clustering are gained this way.
- * If the {@link HazelcastAggregationRepository} uses it's own local {@link 
HazelcastInstance} it will DESTROY this
+ * If the {@link 

[GitHub] [camel] davsclaus merged pull request #3841: Changes in HazelcastAggregationRepository to use replicated maps

[GitBox]

davsclaus merged pull request #3841:
URL: https://github.com/apache/camel/pull/3841


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel] davsclaus commented on pull request #3843: Camel 14878

[GitBox]

davsclaus commented on pull request #3843:
URL: https://github.com/apache/camel/pull/3843#issuecomment-631437946


   Can we avoid the space in the defaults eg "5 s" and use "5s" as we have 
always done.



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel] branch master updated: Old Fastjson has a serious security problem (#3844)

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
 new fabd4c7  Old Fastjson has a serious security problem (#3844)
fabd4c7 is described below

commit fabd4c707ba7e8545cbe7bd7473474ea6f79aabe
Author: Claus Ibsen 
AuthorDate: Wed May 20 14:12:21 2020 +0200

Old Fastjson has a serious security problem (#3844)
---
 parent/pom.xml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/parent/pom.xml b/parent/pom.xml
index 7e08595..db9cb3b 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -166,7 +166,7 @@
 1.6.0
 4.4.0
 2.4.13
-1.2.62
+1.2.68
 1.8.8
 0.2.0
 3.5.2

[GitHub] [camel-k] nicolaferraro opened a new pull request #1460: Make cron work on quarkus runtime

[GitBox]

nicolaferraro opened a new pull request #1460:
URL: https://github.com/apache/camel-k/pull/1460


   
   
   CI may fail temporary because SNAPSHOTS from 
https://github.com/apache/camel-k-runtime/pull/329 are still not available.
   
   
   
   
   **Release Note**
   ```release-note
   Cron endpoints now work on the Quarkus runtime
   ```
   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[camel] branch master updated: Old Fastjson has a serious security problem (#3844)

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
 new 8dc0f60  Old Fastjson has a serious security problem (#3844)
8dc0f60 is described below

commit 8dc0f6064f091501650e68f9b9bd5a62d3db9c80
Author: chi-chi weng <949409...@qq.com>
AuthorDate: Wed May 20 20:09:00 2020 +0800

Old Fastjson has a serious security problem (#3844)

Old version Fastjson has a serious security problem, which will cause RCE
https://www.anquanke.com/post/id/199527
https://www.cnblogs.com/tr1ple/p/12348886.html
https://github.com/jas502n/fastjson-1.2.58-rce
---
 camel-dependencies/pom.xml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/camel-dependencies/pom.xml b/camel-dependencies/pom.xml
index 00d3fa6..4984431 100644
--- a/camel-dependencies/pom.xml
+++ b/camel-dependencies/pom.xml
@@ -186,7 +186,7 @@
 1.6.0
 4.4.0
 2.4.13
-1.2.62
+1.2.68
 1.8.8
 0.2.0
 3.5.2

[GitHub] [camel] davsclaus merged pull request #3844: Old Fastjson has a serious security problem

[GitBox]

davsclaus merged pull request #3844:
URL: https://github.com/apache/camel/pull/3844


   



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.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org