[camel-kafka-connector] branch 923 updated (fb72485 -> d095f13)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch 923 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. from fb72485 Add a map Camel Headers to Kafka headers option to make the behavior configurable add d095f13 Fixed CS No new revisions were added by this update. Summary of changes: core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java | 4 ++-- .../main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java| 2 +- 2 files changed, 3 insertions(+), 3 deletions(-)
[GitHub] [camel-kafka-connector] oscerd opened a new pull request #937: Add a map Camel Headers to Kafka headers option to make the behavior …
oscerd opened a new pull request #937: URL: https://github.com/apache/camel-kafka-connector/pull/937 …configurable Fixes #923 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 923 created (now fb72485)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch 923 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at fb72485 Add a map Camel Headers to Kafka headers option to make the behavior configurable This branch includes the following new commits: new fb72485 Add a map Camel Headers to Kafka headers option to make the behavior configurable 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-kafka-connector] 01/01: Add a map Camel Headers to Kafka headers option to make the behavior configurable
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch 923
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit fb7248579af1e62c8510693bbfa1041c4ece5961
Author: Andrea Cosentino
AuthorDate: Fri Jan 29 08:56:29 2021 +0100
Add a map Camel Headers to Kafka headers option to make the behavior
configurable
---
.../camel/kafkaconnector/CamelConnectorConfig.java | 4 ++
.../kafkaconnector/CamelSinkConnectorConfig.java | 3 +-
.../apache/camel/kafkaconnector/CamelSinkTask.java | 6 ++-
.../kafkaconnector/CamelSourceConnectorConfig.java | 3 +-
.../camel/kafkaconnector/CamelSourceTask.java | 8 ++-
.../camel/kafkaconnector/CamelSinkTaskTest.java| 59 ++
.../camel/kafkaconnector/CamelSourceTaskTest.java | 25 +
7 files changed, 103 insertions(+), 5 deletions(-)
diff --git
a/core/src/main/java/org/apache/camel/kafkaconnector/CamelConnectorConfig.java
b/core/src/main/java/org/apache/camel/kafkaconnector/CamelConnectorConfig.java
index 196b872..11598a3 100644
---
a/core/src/main/java/org/apache/camel/kafkaconnector/CamelConnectorConfig.java
+++
b/core/src/main/java/org/apache/camel/kafkaconnector/CamelConnectorConfig.java
@@ -47,6 +47,10 @@ public abstract class CamelConnectorConfig extends
AbstractConfig {
public static final String CAMEL_CONNECTOR_MAP_PROPERTIES_CONF =
"camel.map.properties";
public static final String CAMEL_CONNECTOR_MAP_PROPERTIES_DOC = "If set to
true, the connector will transform the exchange properties into kafka headers.";
+public static final Boolean CAMEL_CONNECTOR_MAP_HEADERS_DEFAULT = true;
+public static final String CAMEL_CONNECTOR_MAP_HEADERS_CONF =
"camel.map.headers";
+public static final String CAMEL_CONNECTOR_MAP_HEADERS_DOC = "If set to
true, the connector will transform the camel exchange headers into kafka
headers.";
+
public static final int
CAMEL_CONNECTOR_ERROR_HANDLER_MAXIMUM_REDELIVERIES_DEFAULT = 0;
public static final String
CAMEL_CONNECTOR_ERROR_HANDLER_MAXIMUM_REDELIVERIES_CONF =
"camel.error.handler.max.redeliveries";
public static final String
CAMEL_CONNECTOR_ERROR_HANDLER_MAXIMUM_REDELIVERIES_DOC = "The maximum
redeliveries to be use in case of Default Error Handler";
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 f40749d..1ef5a86 100644
---
a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkConnectorConfig.java
+++
b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkConnectorConfig.java
@@ -68,7 +68,8 @@ public class CamelSinkConnectorConfig extends
CamelConnectorConfig {
.define(CAMEL_CONNECTOR_IDEMPOTENCY_KAFKA_MAX_CACHE_SIZE_CONF,
Type.INT, CAMEL_CONNECTOR_IDEMPOTENCY_KAFKA_MAX_CACHE_SIZE_DEFAULT,
Importance.LOW, CAMEL_CONNECTOR_IDEMPOTENCY_KAFKA_MAX_CACHE_SIZE_DOC)
.define(CAMEL_CONNECTOR_IDEMPOTENCY_KAFKA_POLL_DURATION_CONF,
Type.INT, CAMEL_CONNECTOR_IDEMPOTENCY_KAFKA_POLL_DURATION_DEFAULT,
Importance.LOW, CAMEL_CONNECTOR_IDEMPOTENCY_KAFKA_POLL_DURATION_DOC)
.define(CAMEL_CONNECTOR_REMOVE_HEADERS_PATTERN_CONF, Type.STRING,
CAMEL_CONNECTOR_REMOVE_HEADERS_PATTERN_DEFAULT, Importance.MEDIUM,
CAMEL_CONNECTOR_REMOVE_HEADERS_PATTERN_DOC)
-.define(CAMEL_CONNECTOR_MAP_PROPERTIES_CONF, Type.BOOLEAN,
CAMEL_CONNECTOR_MAP_PROPERTIES_DEFAULT, Importance.MEDIUM,
CAMEL_CONNECTOR_MAP_PROPERTIES_DOC);
+.define(CAMEL_CONNECTOR_MAP_PROPERTIES_CONF, Type.BOOLEAN,
CAMEL_CONNECTOR_MAP_PROPERTIES_DEFAULT, Importance.MEDIUM,
CAMEL_CONNECTOR_MAP_PROPERTIES_DOC)
+.define(CAMEL_CONNECTOR_MAP_HEADERS_CONF, Type.BOOLEAN,
CAMEL_CONNECTOR_MAP_HEADERS_DEFAULT, Importance.MEDIUM,
CAMEL_CONNECTOR_MAP_HEADERS_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 c94ad15..5b97806 100644
--- a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
+++ b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
@@ -60,6 +60,7 @@ public class CamelSinkTask extends SinkTask {
private Endpoint localEndpoint;
private LoggingLevel loggingLevel = LoggingLevel.OFF;
private boolean mapProperties;
+private boolean mapHeaders;
@Override
public String version() {
@@ -103,6 +104,7 @@ public class CamelSinkTask extends SinkTask {
final int idempotentRepositoryKafkaPollDuration =
config.getInt(CamelSinkConnectorConfig.CAMEL_CONNECTOR_IDEMPOTENCY_KAFKA_POLL_DURATION_CONF);
final String headersRemovePattern =
[GitHub] [camel-website] github-actions[bot] commented on pull request #533: Camel-Kafka-connector release note: Fixed API invocation to get close…
github-actions[bot] commented on pull request #533: URL: https://github.com/apache/camel-website/pull/533#issuecomment-769640920 Preview for 19bc65b9378bce86e1d886e3667cf40e9caf23ee is available at https://pr-533--camel.netlify.app This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] github-actions[bot] commented on pull request #532: Create ckc release 0.7.1 note.
github-actions[bot] commented on pull request #532: URL: https://github.com/apache/camel-website/pull/532#issuecomment-769640251 Preview for a801fd898627cca920c40ae6f53c74b596be3f3c is available at https://pr-532--camel.netlify.app This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch regen_bot updated (e74477d -> 7dfa019)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch regen_bot
in repository https://gitbox.apache.org/repos/asf/camel.git.
from e74477d Regen catalog
add abdc063 CAMEL-16098: camel-direct - Add synchronous option
add 7dfa019 Regen for commit abdc0631d2856f694dce04a95069372790431ab5
No new revisions were added by this update.
Summary of changes:
.../apache/camel/catalog/components/direct.json| 3 +-
.../camel/catalog/docs/direct-component.adoc | 3 +-
.../component/direct/DirectEndpointConfigurer.java | 3 +
.../component/direct/DirectEndpointUriFactory.java | 3 +-
.../org/apache/camel/component/direct/direct.json | 3 +-
.../src/main/docs/direct-component.adoc| 3 +-
.../camel/component/direct/DirectEndpoint.java | 19 +++
.../camel/component/direct/DirectProducer.java | 15 ++-
...ctRouteTest.java => DirectSynchronousTest.java} | 26 -
.../async/AsyncDirectForceSynchronousTest.java | 56 ++---
.../endpoint/dsl/DirectEndpointBuilderFactory.java | 127 +
.../modules/ROOT/pages/direct-component.adoc | 3 +-
12 files changed, 236 insertions(+), 28 deletions(-)
copy
core/camel-core/src/test/java/org/apache/camel/component/direct/{DirectRouteTest.java
=> DirectSynchronousTest.java} (72%)
copy
components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyProducerAsyncEndpointTest.java
=>
core/camel-core/src/test/java/org/apache/camel/processor/async/AsyncDirectForceSynchronousTest.java
(63%)
[GitHub] [camel] github-actions[bot] opened a new pull request #4954: Generated sources regen
github-actions[bot] opened a new pull request #4954: URL: https://github.com/apache/camel/pull/4954 Regen bot :robot: found some uncommited changes after running build on :camel: master. Please do not delete `regen_bot` branch after merge/rebase. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-website] branch ckc-fix-release-notes created (now 19bc65b)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch ckc-fix-release-notes in repository https://gitbox.apache.org/repos/asf/camel-website.git. at 19bc65b Camel-Kafka-connector release note: Fixed API invocation to get closed issues No new revisions were added by this update.
[GitHub] [camel-website] oscerd opened a new pull request #533: Camel-Kafka-connector release note: Fixed API invocation to get close…
oscerd opened a new pull request #533: URL: https://github.com/apache/camel-website/pull/533 …d issues 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 regen_bot updated (7396616 -> e74477d)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from 7396616 Sync deps add 20d0557 Camel-SQL: Underline the fact that when you set the datasource on endpoint it will be done only on the endpoint add fc63a41 Regen docs add e74477d Regen catalog No new revisions were added by this update. Summary of changes: .../org/apache/camel/catalog/components/sql.json | 2 +- .../org/apache/camel/catalog/docs/sql-component.adoc | 2 +- .../resources/org/apache/camel/component/sql/sql.json | 2 +- components/camel-sql/src/main/docs/sql-component.adoc | 2 +- .../apache/camel/component/sql/DefaultSqlEndpoint.java | 2 +- .../endpoint/dsl/SqlEndpointBuilderFactory.java| 18 -- docs/components/modules/ROOT/pages/sql-component.adoc | 2 +- 7 files changed, 18 insertions(+), 12 deletions(-)
[camel] branch master updated (abdc063 -> 399cb59)
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.git. from abdc063 CAMEL-16098: camel-direct - Add synchronous option add d35b4e8 Added caffeine lrucache docs add 730cee7 Regen and add to catalog add 399cb59 Regen No new revisions were added by this update. Summary of changes: .../org/apache/camel/catalog/docs.properties | 1 + .../camel/catalog/docs/caffeine-lrucache.adoc | 40 + .../src/main/docs/caffeine-lrucache.adoc | 40 + docs/components/modules/others/nav.adoc| 1 + .../modules/others/pages/caffeine-lrucache.adoc| 42 ++ 5 files changed, 124 insertions(+) create mode 100644 catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/caffeine-lrucache.adoc create mode 100644 components/camel-caffeine-lrucache/src/main/docs/caffeine-lrucache.adoc create mode 100644 docs/components/modules/others/pages/caffeine-lrucache.adoc
[camel] branch regen_bot updated (0dcbe44 -> 7396616)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from 0dcbe44 Sync deps add 4656cf1 Upgrade AWS SDK v2 to version 2.15.72 add 7396616 Sync deps No new revisions were added by this update. Summary of changes: camel-dependencies/pom.xml | 2 +- parent/pom.xml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-)
[GitHub] [camel] oscerd commented on pull request #4952: [CAMEL-14871] doneFileName attribute on the S3Consumers
oscerd commented on pull request #4952: URL: https://github.com/apache/camel/pull/4952#issuecomment-769615423 I'm going to merge this today 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 (e74477d -> abdc063)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git.
from e74477d Regen catalog
add abdc063 CAMEL-16098: camel-direct - Add synchronous option
No new revisions were added by this update.
Summary of changes:
.../camel/catalog/docs/direct-component.adoc | 3 +-
.../component/direct/DirectEndpointConfigurer.java | 3 +
.../component/direct/DirectEndpointUriFactory.java | 3 +-
.../org/apache/camel/component/direct/direct.json | 3 +-
.../src/main/docs/direct-component.adoc| 3 +-
.../camel/component/direct/DirectEndpoint.java | 19 +++
.../camel/component/direct/DirectProducer.java | 15 ++-
...ctRouteTest.java => DirectSynchronousTest.java} | 26 -
.../async/AsyncDirectForceSynchronousTest.java | 56 ++---
.../endpoint/dsl/DirectEndpointBuilderFactory.java | 127 +
.../modules/ROOT/pages/direct-component.adoc | 3 +-
11 files changed, 234 insertions(+), 27 deletions(-)
copy
core/camel-core/src/test/java/org/apache/camel/component/direct/{DirectRouteTest.java
=> DirectSynchronousTest.java} (72%)
copy
components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyProducerAsyncEndpointTest.java
=>
core/camel-core/src/test/java/org/apache/camel/processor/async/AsyncDirectForceSynchronousTest.java
(63%)
[GitHub] [camel-website] github-actions[bot] commented on pull request #532: Create ckc release 0.7.1 note.
github-actions[bot] commented on pull request #532: URL: https://github.com/apache/camel-website/pull/532#issuecomment-769611596 Preview for a801fd898627cca920c40ae6f53c74b596be3f3c is available at https://pr-532--camel.netlify.app This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch camel-3.7.x updated (6045da3 -> 3b25bd5)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch camel-3.7.x in repository https://gitbox.apache.org/repos/asf/camel.git. from 6045da3 CAMEL-16082: Fix Java DSL expression vs predicate when using predicates via ExpressionClause (delegate) making it harder to know if it was a expression or predicate. So introducing PredicateFactory/Aware and initPredicate to handle predicates differently than expressions. new 09eaa25 Camel-SQL: Underline the fact that when you set the datasource on endpoint it will be done only on the endpoint new d69197d Regen docs new 3b25bd5 Regen catalog The 3 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../org/apache/camel/catalog/components/sql.json | 2 +- .../org/apache/camel/catalog/docs/sql-component.adoc | 2 +- .../resources/org/apache/camel/component/sql/sql.json | 2 +- components/camel-sql/src/main/docs/sql-component.adoc | 2 +- .../apache/camel/component/sql/DefaultSqlEndpoint.java | 2 +- .../endpoint/dsl/SqlEndpointBuilderFactory.java| 18 -- docs/components/modules/ROOT/pages/sql-component.adoc | 2 +- 7 files changed, 18 insertions(+), 12 deletions(-)
[camel] 03/03: Regen catalog
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch camel-3.7.x
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 3b25bd54a2fe202955d602d3f3e848b2a6dde81e
Author: Andrea Cosentino
AuthorDate: Fri Jan 29 07:36:48 2021 +0100
Regen catalog
---
.../generated/resources/org/apache/camel/catalog/components/sql.json| 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/sql.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/sql.json
index 1f29822..36a4c7a 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/sql.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/sql.json
@@ -31,7 +31,7 @@
"properties": {
"query": { "kind": "path", "displayName": "Query", "group": "common",
"label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Sets the SQL query to perform. You can
externalize the query by using file: or classpath: as prefix and specify the
location of the file." },
"allowNamedParameters": { "kind": "parameter", "displayName": "Allow Named
Parameters", "group": "common", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Whether to allow using
named parameters in the queries." },
-"dataSource": { "kind": "parameter", "displayName": "Data Source",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "javax.sql.DataSource", "deprecated": false, "autowired": false,
"secret": false, "description": "Sets the DataSource to use to communicate with
the database." },
+"dataSource": { "kind": "parameter", "displayName": "Data Source",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "javax.sql.DataSource", "deprecated": false, "autowired": false,
"secret": false, "description": "Sets the DataSource to use to communicate with
the databaset at endpoint level." },
"dataSourceRef": { "kind": "parameter", "displayName": "Data Source Ref",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": true, "autowired": false,
"secret": false, "description": "Sets the reference to a DataSource to lookup
from the registry, to use for communicating with the database." },
"outputClass": { "kind": "parameter", "displayName": "Output Class",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Specify the full package and class name to use
as conversion when outputType=SelectOne." },
"outputHeader": { "kind": "parameter", "displayName": "Output Header",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Store the query result in a header instead of
the message body. By default, outputHeader == null and the query result is
stored in the message body, any existing content in the message body is
discarded. If outputHeader is set, the value is u [...]
[camel] 01/03: Camel-SQL: Underline the fact that when you set the datasource on endpoint it will be done only on the endpoint
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch camel-3.7.x
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 09eaa2598516b86a67d79f795f61bbebc98a0c03
Author: Andrea Cosentino
AuthorDate: Fri Jan 29 07:28:49 2021 +0100
Camel-SQL: Underline the fact that when you set the datasource on endpoint
it will be done only on the endpoint
---
.../main/java/org/apache/camel/component/sql/DefaultSqlEndpoint.java| 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/components/camel-sql/src/main/java/org/apache/camel/component/sql/DefaultSqlEndpoint.java
b/components/camel-sql/src/main/java/org/apache/camel/component/sql/DefaultSqlEndpoint.java
index a086d8f..0b6a9a0 100644
---
a/components/camel-sql/src/main/java/org/apache/camel/component/sql/DefaultSqlEndpoint.java
+++
b/components/camel-sql/src/main/java/org/apache/camel/component/sql/DefaultSqlEndpoint.java
@@ -44,7 +44,7 @@ public abstract class DefaultSqlEndpoint extends
DefaultPollingEndpoint {
@UriParam(description = "Sets the reference to a DataSource to lookup from
the registry, to use for communicating with the database.")
@Deprecated
private String dataSourceRef;
-@UriParam(description = "Sets the DataSource to use to communicate with
the database.")
+@UriParam(description = "Sets the DataSource to use to communicate with
the databaset at endpoint level.")
private DataSource dataSource;
@UriParam(label = "consumer",
description = "Enables or disables transaction. If enabled then
if processing an exchange failed then the consumer"
[camel] 02/03: Regen docs
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch camel-3.7.x
in repository https://gitbox.apache.org/repos/asf/camel.git
commit d69197dd05bd0af1e4f5dc21f1e4fb87c59a70b9
Author: Andrea Cosentino
AuthorDate: Fri Jan 29 07:34:08 2021 +0100
Regen docs
---
.../org/apache/camel/catalog/docs/sql-component.adoc | 2 +-
.../resources/org/apache/camel/component/sql/sql.json | 2 +-
components/camel-sql/src/main/docs/sql-component.adoc | 2 +-
.../endpoint/dsl/SqlEndpointBuilderFactory.java| 18 --
docs/components/modules/ROOT/pages/sql-component.adoc | 2 +-
5 files changed, 16 insertions(+), 10 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/sql-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/sql-component.adoc
index 2c05bf6..acecc75 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/sql-component.adoc
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/sql-component.adoc
@@ -161,7 +161,7 @@ with the following path and query parameters:
|===
| Name | Description | Default | Type
| *allowNamedParameters* (common) | Whether to allow using named parameters in
the queries. | true | boolean
-| *dataSource* (common) | Sets the DataSource to use to communicate with the
database. | | DataSource
+| *dataSource* (common) | Sets the DataSource to use to communicate with the
databaset at endpoint level. | | DataSource
| *dataSourceRef* (common) | *Deprecated* Sets the reference to a DataSource
to lookup from the registry, to use for communicating with the database. | |
String
| *outputClass* (common) | Specify the full package and class name to use as
conversion when outputType=SelectOne. | | String
| *outputHeader* (common) | Store the query result in a header instead of the
message body. By default, outputHeader == null and the query result is stored
in the message body, any existing content in the message body is discarded. If
outputHeader is set, the value is used as the name of the header to store the
query result and the original message body is preserved. | | String
diff --git
a/components/camel-sql/src/generated/resources/org/apache/camel/component/sql/sql.json
b/components/camel-sql/src/generated/resources/org/apache/camel/component/sql/sql.json
index 4c7d847..993d8e0 100644
---
a/components/camel-sql/src/generated/resources/org/apache/camel/component/sql/sql.json
+++
b/components/camel-sql/src/generated/resources/org/apache/camel/component/sql/sql.json
@@ -31,7 +31,7 @@
"properties": {
"query": { "kind": "path", "displayName": "Query", "group": "common",
"label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Sets the SQL query to perform. You can
externalize the query by using file: or classpath: as prefix and specify the
location of the file." },
"allowNamedParameters": { "kind": "parameter", "displayName": "Allow Named
Parameters", "group": "common", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Whether to allow using
named parameters in the queries." },
-"dataSource": { "kind": "parameter", "displayName": "Data Source",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "javax.sql.DataSource", "deprecated": false, "autowired": false,
"secret": false, "description": "Sets the DataSource to use to communicate with
the database." },
+"dataSource": { "kind": "parameter", "displayName": "Data Source",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "javax.sql.DataSource", "deprecated": false, "autowired": false,
"secret": false, "description": "Sets the DataSource to use to communicate with
the databaset at endpoint level." },
"dataSourceRef": { "kind": "parameter", "displayName": "Data Source Ref",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": true, "autowired": false,
"secret": false, "description": "Sets the reference to a DataSource to lookup
from the registry, to use for communicating with the database." },
"outputClass": { "kind": "parameter", "displayName": "Output Class",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Specify the full package and class name to use
as conversion when outputType=SelectOne." },
"outputHeader": { "kind": "parameter", "displayName": "Output Header",
"group": "common", "label": "", "required": false, "type": "string",
"javaType":
[camel] 01/03: Camel-SQL: Underline the fact that when you set the datasource on endpoint it will be done only on the endpoint
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
commit 20d05579beeb206ef9f81a9abf80770ed2208b62
Author: Andrea Cosentino
AuthorDate: Fri Jan 29 07:28:49 2021 +0100
Camel-SQL: Underline the fact that when you set the datasource on endpoint
it will be done only on the endpoint
---
.../main/java/org/apache/camel/component/sql/DefaultSqlEndpoint.java| 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/components/camel-sql/src/main/java/org/apache/camel/component/sql/DefaultSqlEndpoint.java
b/components/camel-sql/src/main/java/org/apache/camel/component/sql/DefaultSqlEndpoint.java
index a086d8f..0b6a9a0 100644
---
a/components/camel-sql/src/main/java/org/apache/camel/component/sql/DefaultSqlEndpoint.java
+++
b/components/camel-sql/src/main/java/org/apache/camel/component/sql/DefaultSqlEndpoint.java
@@ -44,7 +44,7 @@ public abstract class DefaultSqlEndpoint extends
DefaultPollingEndpoint {
@UriParam(description = "Sets the reference to a DataSource to lookup from
the registry, to use for communicating with the database.")
@Deprecated
private String dataSourceRef;
-@UriParam(description = "Sets the DataSource to use to communicate with
the database.")
+@UriParam(description = "Sets the DataSource to use to communicate with
the databaset at endpoint level.")
private DataSource dataSource;
@UriParam(label = "consumer",
description = "Enables or disables transaction. If enabled then
if processing an exchange failed then the consumer"
[camel] branch master updated (7396616 -> e74477d)
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.git. from 7396616 Sync deps new 20d0557 Camel-SQL: Underline the fact that when you set the datasource on endpoint it will be done only on the endpoint new fc63a41 Regen docs new e74477d Regen catalog The 3 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../org/apache/camel/catalog/components/sql.json | 2 +- .../org/apache/camel/catalog/docs/sql-component.adoc | 2 +- .../resources/org/apache/camel/component/sql/sql.json | 2 +- components/camel-sql/src/main/docs/sql-component.adoc | 2 +- .../apache/camel/component/sql/DefaultSqlEndpoint.java | 2 +- .../endpoint/dsl/SqlEndpointBuilderFactory.java| 18 -- docs/components/modules/ROOT/pages/sql-component.adoc | 2 +- 7 files changed, 18 insertions(+), 12 deletions(-)
[camel] 03/03: Regen catalog
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
commit e74477d90b99a41240e228a981d633150d5f40a2
Author: Andrea Cosentino
AuthorDate: Fri Jan 29 07:36:48 2021 +0100
Regen catalog
---
.../generated/resources/org/apache/camel/catalog/components/sql.json| 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/sql.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/sql.json
index e99d371..03b4a31 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/sql.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/sql.json
@@ -31,7 +31,7 @@
"properties": {
"query": { "kind": "path", "displayName": "Query", "group": "common",
"label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Sets the SQL query to perform. You can
externalize the query by using file: or classpath: as prefix and specify the
location of the file." },
"allowNamedParameters": { "kind": "parameter", "displayName": "Allow Named
Parameters", "group": "common", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Whether to allow using
named parameters in the queries." },
-"dataSource": { "kind": "parameter", "displayName": "Data Source",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "javax.sql.DataSource", "deprecated": false, "autowired": false,
"secret": false, "description": "Sets the DataSource to use to communicate with
the database." },
+"dataSource": { "kind": "parameter", "displayName": "Data Source",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "javax.sql.DataSource", "deprecated": false, "autowired": false,
"secret": false, "description": "Sets the DataSource to use to communicate with
the databaset at endpoint level." },
"dataSourceRef": { "kind": "parameter", "displayName": "Data Source Ref",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": true, "autowired": false,
"secret": false, "description": "Sets the reference to a DataSource to lookup
from the registry, to use for communicating with the database." },
"outputClass": { "kind": "parameter", "displayName": "Output Class",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Specify the full package and class name to use
as conversion when outputType=SelectOne." },
"outputHeader": { "kind": "parameter", "displayName": "Output Header",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Store the query result in a header instead of
the message body. By default, outputHeader == null and the query result is
stored in the message body, any existing content in the message body is
discarded. If outputHeader is set, the value is u [...]
[camel] 02/03: Regen docs
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
commit fc63a41b8ac05412204bac6e93f40d311ce0baf5
Author: Andrea Cosentino
AuthorDate: Fri Jan 29 07:34:08 2021 +0100
Regen docs
---
.../org/apache/camel/catalog/docs/sql-component.adoc | 2 +-
.../resources/org/apache/camel/component/sql/sql.json | 2 +-
components/camel-sql/src/main/docs/sql-component.adoc | 2 +-
.../endpoint/dsl/SqlEndpointBuilderFactory.java| 18 --
docs/components/modules/ROOT/pages/sql-component.adoc | 2 +-
5 files changed, 16 insertions(+), 10 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/sql-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/sql-component.adoc
index b003120..2360151 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/sql-component.adoc
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/sql-component.adoc
@@ -161,7 +161,7 @@ with the following path and query parameters:
|===
| Name | Description | Default | Type
| *allowNamedParameters* (common) | Whether to allow using named parameters in
the queries. | true | boolean
-| *dataSource* (common) | Sets the DataSource to use to communicate with the
database. | | DataSource
+| *dataSource* (common) | Sets the DataSource to use to communicate with the
databaset at endpoint level. | | DataSource
| *dataSourceRef* (common) | *Deprecated* Sets the reference to a DataSource
to lookup from the registry, to use for communicating with the database. | |
String
| *outputClass* (common) | Specify the full package and class name to use as
conversion when outputType=SelectOne. | | String
| *outputHeader* (common) | Store the query result in a header instead of the
message body. By default, outputHeader == null and the query result is stored
in the message body, any existing content in the message body is discarded. If
outputHeader is set, the value is used as the name of the header to store the
query result and the original message body is preserved. | | String
diff --git
a/components/camel-sql/src/generated/resources/org/apache/camel/component/sql/sql.json
b/components/camel-sql/src/generated/resources/org/apache/camel/component/sql/sql.json
index e99d371..03b4a31 100644
---
a/components/camel-sql/src/generated/resources/org/apache/camel/component/sql/sql.json
+++
b/components/camel-sql/src/generated/resources/org/apache/camel/component/sql/sql.json
@@ -31,7 +31,7 @@
"properties": {
"query": { "kind": "path", "displayName": "Query", "group": "common",
"label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Sets the SQL query to perform. You can
externalize the query by using file: or classpath: as prefix and specify the
location of the file." },
"allowNamedParameters": { "kind": "parameter", "displayName": "Allow Named
Parameters", "group": "common", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Whether to allow using
named parameters in the queries." },
-"dataSource": { "kind": "parameter", "displayName": "Data Source",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "javax.sql.DataSource", "deprecated": false, "autowired": false,
"secret": false, "description": "Sets the DataSource to use to communicate with
the database." },
+"dataSource": { "kind": "parameter", "displayName": "Data Source",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "javax.sql.DataSource", "deprecated": false, "autowired": false,
"secret": false, "description": "Sets the DataSource to use to communicate with
the databaset at endpoint level." },
"dataSourceRef": { "kind": "parameter", "displayName": "Data Source Ref",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": true, "autowired": false,
"secret": false, "description": "Sets the reference to a DataSource to lookup
from the registry, to use for communicating with the database." },
"outputClass": { "kind": "parameter", "displayName": "Output Class",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "description": "Specify the full package and class name to use
as conversion when outputType=SelectOne." },
"outputHeader": { "kind": "parameter", "displayName": "Output Header",
"group": "common", "label": "", "required": false, "type": "string",
"javaType":
[GitHub] [camel-kafka-connector] oscerd closed issue #844: Camel-Master: SJMS2 it test is failing
oscerd closed issue #844: URL: https://github.com/apache/camel-kafka-connector/issues/844 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 issue #844: Camel-Master: SJMS2 it test is failing
oscerd commented on issue #844: URL: https://github.com/apache/camel-kafka-connector/issues/844#issuecomment-769603079 seems to be 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] 02/02: Sync deps
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 commit 739661683d61020aba65bc3049f17601f53ba722 Author: Andrea Cosentino AuthorDate: Fri Jan 29 07:08:18 2021 +0100 Sync deps --- 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 ad75201..832b591 100644 --- a/camel-dependencies/pom.xml +++ b/camel-dependencies/pom.xml @@ -71,7 +71,7 @@ 4.0.3 1.11.22 1.11.714 -2.15.71 +2.15.72 2.6.1 1.2.14 1.3.1
[camel] 01/02: Upgrade AWS SDK v2 to version 2.15.72
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 commit 4656cf14bbbc46c4abc5d3cf2e141882b4cac254 Author: Andrea Cosentino AuthorDate: Fri Jan 29 06:55:39 2021 +0100 Upgrade AWS SDK v2 to version 2.15.72 --- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parent/pom.xml b/parent/pom.xml index b52b565..16ec8b3 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -78,7 +78,7 @@ 1.10.1 4.0.3 1.11.714 -2.15.71 +2.15.72 1.11.22 2.6.1 1.2.14
[camel] branch master updated (0dcbe44 -> 7396616)
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.git. from 0dcbe44 Sync deps new 4656cf1 Upgrade AWS SDK v2 to version 2.15.72 new 7396616 Sync deps The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: camel-dependencies/pom.xml | 2 +- parent/pom.xml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-)
[GitHub] [camel-kafka-connector] oscerd closed issue #872: Upgrade to Camel 3.7.1 the 0.7.x branch and release
oscerd closed issue #872: URL: https://github.com/apache/camel-kafka-connector/issues/872 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 quarkus-master updated (5938b32 -> cd7930a)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch quarkus-master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git. discard 5938b32 Upgrade to Quarkus 1.12.0.Final add 52c21b0 polished new cd7930a Upgrade to Quarkus 1.12.0.Final 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 (5938b32) \ N -- N -- N refs/heads/quarkus-master (cd7930a) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: integration-tests/saga/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[camel-quarkus] 01/01: Upgrade to Quarkus 1.12.0.Final
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch quarkus-master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit cd7930ad54445e598af47e464e56e93771dbf76d
Author: James Netherton
AuthorDate: Thu Nov 12 07:00:19 2020 +
Upgrade to Quarkus 1.12.0.Final
---
pom.xml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pom.xml b/pom.xml
index 4602446..b9f3cd2 100644
--- a/pom.xml
+++ b/pom.xml
@@ -92,7 +92,7 @@
${squareup-okio-version}
7.46.0.Final
0.2.0
-1.11.1.Final
+999-SNAPSHOT
0.3.0
1.1.1
0.22.0
[GitHub] [camel-quarkus] github-actions[bot] closed issue #2170: [CI] - Quarkus Master Branch Build Failure
github-actions[bot] closed issue #2170: URL: https://github.com/apache/camel-quarkus/issues/2170 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] github-actions[bot] commented on issue #2170: [CI] - Quarkus Master Branch Build Failure
github-actions[bot] commented on issue #2170: URL: https://github.com/apache/camel-quarkus/issues/2170#issuecomment-769588872 Build fixed with: * Camel Quarkus Commit: cd7930ad54445e598af47e464e56e93771dbf76d * Quarkus Master Commit: 52c21b05714412bf0971c9d90f58c3d56f62ead5 * Link to build: https://github.com/apache/camel-quarkus/actions/runs/519767101 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 #936: Provide option to delete camel kafka submodule if they are not in camel catalog
oscerd commented on pull request #936: URL: https://github.com/apache/camel-kafka-connector/pull/936#issuecomment-769588662 cc @valdar 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 closed issue #902: create a toHeader SMT
oscerd closed issue #902: URL: https://github.com/apache/camel-kafka-connector/issues/902 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 #935: create a toHeader SMT #902
oscerd commented on pull request #935: URL: https://github.com/apache/camel-kafka-connector/pull/935#issuecomment-769588011 Thanks a lot 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 merged pull request #935: create a toHeader SMT #902
oscerd merged pull request #935: URL: https://github.com/apache/camel-kafka-connector/pull/935 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: create a toHeader SMT #902
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 a024c7c create a toHeader SMT #902
a024c7c is described below
commit a024c7cff76c410b24da85e3bcf7d81154ed4fe0
Author: Luigi De Masi
AuthorDate: Thu Jan 28 18:26:26 2021 +0100
create a toHeader SMT #902
---
.../transforms/FieldsToHeadersTransform.java | 192
.../transforms/FieldsToHeadersTransformTest.java | 349 +
2 files changed, 541 insertions(+)
diff --git
a/core/src/main/java/org/apache/camel/kafkaconnector/transforms/FieldsToHeadersTransform.java
b/core/src/main/java/org/apache/camel/kafkaconnector/transforms/FieldsToHeadersTransform.java
new file mode 100644
index 000..ed74886
--- /dev/null
+++
b/core/src/main/java/org/apache/camel/kafkaconnector/transforms/FieldsToHeadersTransform.java
@@ -0,0 +1,192 @@
+/*
+ * 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.kafkaconnector.transforms;
+
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+import org.apache.kafka.common.config.ConfigDef;
+import org.apache.kafka.connect.connector.ConnectRecord;
+import org.apache.kafka.connect.data.Field;
+import org.apache.kafka.connect.data.Schema;
+import org.apache.kafka.connect.data.Struct;
+import org.apache.kafka.connect.transforms.Transformation;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import static
org.apache.kafka.connect.transforms.util.Requirements.requireMapOrNull;
+import static
org.apache.kafka.connect.transforms.util.Requirements.requireStructOrNull;
+
+public abstract class FieldsToHeadersTransform>
implements Transformation {
+
+private static final Logger LOG =
LoggerFactory.getLogger(FieldsToHeadersTransform.class);
+
+private static final String PURPOSE = "fields extraction to headers";
+private static final String FIELDS_CONFIG = "fields";
+private static final String HEADERS_CONFIG = "headers";
+
+public static final ConfigDef CONFIG_DEF = new ConfigDef()
+.define(FIELDS_CONFIG, ConfigDef.Type.LIST,
ConfigDef.NO_DEFAULT_VALUE, ConfigDef.Importance.MEDIUM, "Fields names to
extract and set to headers")
+.define(HEADERS_CONFIG, ConfigDef.Type.LIST,
ConfigDef.NO_DEFAULT_VALUE, ConfigDef.Importance.MEDIUM, "Headers names to set
with extracted fields");
+
+
+private List fields;
+
+private List headers;
+
+
+
+protected abstract Schema operatingSchema(R record);
+
+protected abstract Object operatingValue(R record);
+
+
+@Override
+public R apply(R r) {
+RecordValue value = createRecordValue(r);
+Schema currentSchema;
+Object currentValue;
+for (int i = 0; i < fields.size(); i++) {
+currentSchema = value.getFieldSchema(fields.get(i));
+currentValue = value.getFieldValue(fields.get(i));
+r.headers().add(headers.get(i), currentValue, currentSchema);
+}
+return r;
+}
+
+@Override
+public ConfigDef config() {
+return CONFIG_DEF;
+}
+
+@Override
+public void close() {
+}
+
+@Override
+public void configure(Map map) {
+Map parsedConfig = CONFIG_DEF.parse(map);
+fields = (List) parsedConfig.getOrDefault(FIELDS_CONFIG, new
ArrayList<>());
+headers = (List) parsedConfig.getOrDefault(HEADERS_CONFIG, new
ArrayList<>());
+validateConfig();
+}
+
+private void validateConfig() {
+
+boolean validFields = fields.stream().allMatch(nef -> nef != null &&
!nef.trim().isEmpty());
+boolean validHeaders = headers.stream().allMatch(nef -> nef != null &&
!nef.trim().isEmpty());
+
+if (!(validFields && validHeaders)) {
+throw new IllegalArgumentException("headers and fields
configuration properties cannot be null or contain empty elements.");
+}
+if (fields.size() > headers.size()) {
+String fieldsWithoutCorrespondingHeaders =
[GitHub] [camel-spring-boot] oscerd merged pull request #271: [Github Actions] Periodic Sync Camel Spring Boot Master Branch
oscerd merged pull request #271: URL: https://github.com/apache/camel-spring-boot/pull/271 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
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 15e1596 [create-pull-request] automated change
15e1596 is described below
commit 15e1596322d4d6404dee5e5552802faef693e58f
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Jan 29 01:06:30 2021 +
[create-pull-request] automated change
---
components-starter/camel-corda-starter/pom.xml | 8
components-starter/camel-iota-starter/pom.xml | 12
2 files changed, 20 deletions(-)
diff --git a/components-starter/camel-corda-starter/pom.xml
b/components-starter/camel-corda-starter/pom.xml
index 158a2e5..d667b96 100644
--- a/components-starter/camel-corda-starter/pom.xml
+++ b/components-starter/camel-corda-starter/pom.xml
@@ -41,14 +41,6 @@
- ch.qos.logback
- logback-classic
-
-
- ch.qos.logback
- logback-core
-
-
org.apache.logging.log4j
log4j-core
diff --git a/components-starter/camel-iota-starter/pom.xml
b/components-starter/camel-iota-starter/pom.xml
index 758052f..95d1ad5 100644
--- a/components-starter/camel-iota-starter/pom.xml
+++ b/components-starter/camel-iota-starter/pom.xml
@@ -38,18 +38,6 @@
org.apache.camel
camel-iota
${camel-version}
-
-
-
- ch.qos.logback
- logback-classic
-
-
- ch.qos.logback
- logback-core
-
-
-
[GitHub] [camel-quarkus] github-actions[bot] closed issue #2175: [CI] - Camel Master Branch Build Failure
github-actions[bot] closed issue #2175: URL: https://github.com/apache/camel-quarkus/issues/2175 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] 06/06: Fix infinispan extension and clean up redundant substitutions
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 7a1db484d4b4960dade0923ec5978ce9c8d10201
Author: James Netherton
AuthorDate: Thu Jan 28 10:46:10 2021 +
Fix infinispan extension and clean up redundant substitutions
---
extensions/infinispan/deployment/pom.xml | 4 -
.../infinispan/deployment/InfinispanProcessor.java | 12 +++
extensions/infinispan/runtime/pom.xml | 15
.../graal/SubstituteDefaultCacheManager.java | 100 -
.../runtime/graal/SubstituteInfinispanManager.java | 36
5 files changed, 12 insertions(+), 155 deletions(-)
diff --git a/extensions/infinispan/deployment/pom.xml
b/extensions/infinispan/deployment/pom.xml
index 9326010..1beb5a8 100644
--- a/extensions/infinispan/deployment/pom.xml
+++ b/extensions/infinispan/deployment/pom.xml
@@ -38,10 +38,6 @@
quarkus-jaxb-deployment
-io.quarkus
-quarkus-caffeine-deployment
-
-
org.apache.camel.quarkus
camel-quarkus-core-deployment
diff --git
a/extensions/infinispan/deployment/src/main/java/org/apache/camel/quarkus/component/infinispan/deployment/InfinispanProcessor.java
b/extensions/infinispan/deployment/src/main/java/org/apache/camel/quarkus/component/infinispan/deployment/InfinispanProcessor.java
index f305db1..3a2316b 100644
---
a/extensions/infinispan/deployment/src/main/java/org/apache/camel/quarkus/component/infinispan/deployment/InfinispanProcessor.java
+++
b/extensions/infinispan/deployment/src/main/java/org/apache/camel/quarkus/component/infinispan/deployment/InfinispanProcessor.java
@@ -18,6 +18,9 @@ package
org.apache.camel.quarkus.component.infinispan.deployment;
import io.quarkus.deployment.annotations.BuildStep;
import io.quarkus.deployment.builditem.FeatureBuildItem;
+import io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem;
+import org.apache.camel.component.infinispan.InfinispanProducer;
+import org.apache.camel.component.infinispan.remote.InfinispanRemoteProducer;
class InfinispanProcessor {
@@ -27,4 +30,13 @@ class InfinispanProcessor {
FeatureBuildItem feature() {
return new FeatureBuildItem(FEATURE);
}
+
+// TOOD: This can be removed after this is implemented:
+// https://github.com/apache/camel-quarkus/issues/2176
+@BuildStep
+ReflectiveClassBuildItem registerForReflection() {
+return new ReflectiveClassBuildItem(true, false,
+InfinispanProducer.class.getName(),
+InfinispanRemoteProducer.class.getName());
+}
}
diff --git a/extensions/infinispan/runtime/pom.xml
b/extensions/infinispan/runtime/pom.xml
index aa9aea2..1df845e 100644
--- a/extensions/infinispan/runtime/pom.xml
+++ b/extensions/infinispan/runtime/pom.xml
@@ -58,10 +58,6 @@
io.quarkus
quarkus-jaxb
-
-io.quarkus
-quarkus-caffeine
-
org.infinispan
@@ -87,17 +83,6 @@
-
-
-org.apache.camel
-camel-caffeine-lrucache
-
-
-
-org.graalvm.nativeimage
-svm
-provided
-
diff --git
a/extensions/infinispan/runtime/src/main/java/org/apache/camel/quarkus/infinispan/runtime/graal/SubstituteDefaultCacheManager.java
b/extensions/infinispan/runtime/src/main/java/org/apache/camel/quarkus/infinispan/runtime/graal/SubstituteDefaultCacheManager.java
deleted file mode 100644
index 7ed2456..000
---
a/extensions/infinispan/runtime/src/main/java/org/apache/camel/quarkus/infinispan/runtime/graal/SubstituteDefaultCacheManager.java
+++ /dev/null
@@ -1,100 +0,0 @@
-/*
- * 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.infinispan.runtime.graal;
-
-import java.io.IOException;
-import java.io.InputStream;
-
-import com.oracle.svm.core.annotate.Substitute;
-import com.oracle.svm.core.annotate.TargetClass;
-import
[GitHub] [camel-quarkus] github-actions[bot] commented on issue #2175: [CI] - Camel Master Branch Build Failure
github-actions[bot] commented on issue #2175: URL: https://github.com/apache/camel-quarkus/issues/2175#issuecomment-769553703 Build fixed with: * Camel Quarkus Commit: 7a1db484d4b4960dade0923ec5978ce9c8d10201 * Camel Master Commit: 52c21b05714412bf0971c9d90f58c3d56f62ead5 * Link to build: https://github.com/apache/camel-quarkus/actions/runs/519560395 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 camel-master updated (8231127 -> 7a1db48)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch camel-master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git. discard 8231127 Fix infinispan extension and clean up redundant substitutions discard 12d9358 Regen docs discard 771155f add HazelcastReplicatedmapConsumer test fixes #2095 discard 085c044 Allow to reset build taken for native builds that are super fast. discard e157228 Adjust to camel 3.8 change discard 8faaada Upgrade to Camel 3.8.0 add 5dadd1b Upgrade Quarkus to 1.11.1.Final add ee8e5bb Make install-jdk step the first task in each job for nightly builds. Else running reporting fails JDK version enforcer checks add 52c21b0 polished new 10322c8 Upgrade to Camel 3.8.0 new 11b4390 Adjust to camel 3.8 change new a314471 Allow to reset build taken for native builds that are super fast. new 3943c99 add HazelcastReplicatedmapConsumer test fixes #2095 new 9526e97 Regen docs new 7a1db48 Fix infinispan extension and clean up redundant substitutions 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 (8231127) \ N -- N -- N refs/heads/camel-master (7a1db48) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. The 6 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: .github/workflows/camel-master-cron.yaml | 24 .github/workflows/quarkus-master-cron.yaml | 24 integration-tests/saga/pom.xml | 2 +- pom.xml| 2 +- 4 files changed, 26 insertions(+), 26 deletions(-)
[camel-quarkus] 04/06: add HazelcastReplicatedmapConsumer test fixes #2095
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 3943c9990521c0eecba8bb7911089c39de1dd4a5
Author: Zineb Bendhiba
AuthorDate: Mon Jan 25 10:31:56 2021 +0100
add HazelcastReplicatedmapConsumer test fixes #2095
---
.../hazelcast/it/HazelcastReplicatedmapTest.java | 18 +-
1 file changed, 17 insertions(+), 1 deletion(-)
diff --git
a/integration-tests/hazelcast/src/test/java/org/apache/camel/quarkus/component/hazelcast/it/HazelcastReplicatedmapTest.java
b/integration-tests/hazelcast/src/test/java/org/apache/camel/quarkus/component/hazelcast/it/HazelcastReplicatedmapTest.java
index 222e545..b134a2a 100644
---
a/integration-tests/hazelcast/src/test/java/org/apache/camel/quarkus/component/hazelcast/it/HazelcastReplicatedmapTest.java
+++
b/integration-tests/hazelcast/src/test/java/org/apache/camel/quarkus/component/hazelcast/it/HazelcastReplicatedmapTest.java
@@ -16,16 +16,20 @@
*/
package org.apache.camel.quarkus.component.hazelcast.it;
+import java.util.Arrays;
+import java.util.List;
import java.util.concurrent.TimeUnit;
import io.quarkus.test.common.QuarkusTestResource;
import io.quarkus.test.common.http.TestHTTPEndpoint;
import io.quarkus.test.junit.QuarkusTest;
+import io.restassured.RestAssured;
import io.restassured.http.ContentType;
import
org.apache.camel.quarkus.component.hazelcast.it.model.HazelcastMapRequest;
import org.junit.jupiter.api.Test;
import static io.restassured.RestAssured.given;
+import static org.awaitility.Awaitility.await;
import static org.hamcrest.Matchers.equalTo;
@QuarkusTest
@@ -89,7 +93,7 @@ public class HazelcastReplicatedmapTest {
.then()
.body(equalTo("true"));
-// verify that map doesn't contain value "val2"
+// verify that map doesn't contain value "val3"
given()
.contentType(ContentType.JSON)
.when()
@@ -119,5 +123,17 @@ public class HazelcastReplicatedmapTest {
.then()
.statusCode(202);
+// verify that the consumer has received all added keys
+await().atMost(10L, TimeUnit.SECONDS).until(() -> {
+List body =
RestAssured.get("/added").then().extract().body().as(List.class);
+return body.size() == 2 && body.containsAll(Arrays.asList("1",
"2"));
+});
+
+// verify that the consumer has received all removed keys
+await().atMost(10L, TimeUnit.SECONDS).until(() -> {
+List body =
RestAssured.get("/deleted").then().extract().body().as(List.class);
+return body.size() == 1 && body.contains("1");
+});
+
}
}
[camel-quarkus] 03/06: Allow to reset build taken for native builds that are super fast.
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit a314471ae44ee87d6cfa3597a07f170bb2242e26
Author: Claus Ibsen
AuthorDate: Mon Jan 25 09:55:36 2021 +0100
Allow to reset build taken for native builds that are super fast.
---
.../main/java/org/apache/camel/quarkus/core/FastCamelContext.java | 6 ++
.../main/java/org/apache/camel/quarkus/core/NoShutdownStrategy.java | 2 +-
2 files changed, 7 insertions(+), 1 deletion(-)
diff --git
a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastCamelContext.java
b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastCamelContext.java
index fd96350..2a30802 100644
---
a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastCamelContext.java
+++
b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastCamelContext.java
@@ -177,7 +177,13 @@ public class FastCamelContext extends AbstractCamelContext
implements CatalogCam
setTracing(Boolean.FALSE);
setDebugging(Boolean.FALSE);
setMessageHistory(Boolean.FALSE);
+}
+@Override
+public void build() {
+super.build();
+// we are fast build so the time should be reset to 0
+resetBuildTime();
}
@Override
diff --git
a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/NoShutdownStrategy.java
b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/NoShutdownStrategy.java
index 477bcc3..d48fe02 100644
---
a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/NoShutdownStrategy.java
+++
b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/NoShutdownStrategy.java
@@ -19,8 +19,8 @@ package org.apache.camel.quarkus.core;
import java.util.List;
import java.util.concurrent.TimeUnit;
-import org.apache.camel.LoggingLevel;
import org.apache.camel.CamelContext;
+import org.apache.camel.LoggingLevel;
import org.apache.camel.Service;
import org.apache.camel.spi.RouteStartupOrder;
import org.apache.camel.spi.ShutdownStrategy;
[camel-quarkus] 05/06: Regen docs
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 9526e971fef329746ccfd86a71887218110de1b0
Author: Claus Ibsen
AuthorDate: Thu Jan 28 10:36:45 2021 +0100
Regen docs
---
.../ROOT/pages/reference/extensions/caffeine-lrucache.adoc | 8 +++-
.../azure-storage-datalake.adoc}| 0
.../flight-recorder.adoc => components/hwcloud-smn.adoc}| 0
.../infinispan-embedded.adoc} | 0
.../flight-recorder.adoc => components/kamelet.adoc}| 0
.../{others/flight-recorder.adoc => components/stitch.adoc} | 0
.../ROOT/partials/reference/others/caffeine-lrucache.adoc | 13 +
7 files changed, 20 insertions(+), 1 deletion(-)
diff --git
a/docs/modules/ROOT/pages/reference/extensions/caffeine-lrucache.adoc
b/docs/modules/ROOT/pages/reference/extensions/caffeine-lrucache.adoc
index 421db19..b13c69b 100644
--- a/docs/modules/ROOT/pages/reference/extensions/caffeine-lrucache.adoc
+++ b/docs/modules/ROOT/pages/reference/extensions/caffeine-lrucache.adoc
@@ -6,7 +6,7 @@
:cq-native-supported: true
:cq-status: Stable
:cq-description: An LRUCacheFactory implementation based on Caffeine
-:cq-deprecated: false
+:cq-deprecated: true
:cq-jvm-since: 1.0.0
:cq-native-since: 1.0.0
@@ -15,6 +15,12 @@
An LRUCacheFactory implementation based on Caffeine
+== What's inside
+
+* xref:{cq-camel-components}:others:caffeine-lrucache.adoc[Caffeine Lrucache]
+
+Please refer to the above link for usage and configuration details.
+
== Maven coordinates
[source,xml]
diff --git a/docs/modules/ROOT/partials/reference/others/flight-recorder.adoc
b/docs/modules/ROOT/partials/reference/components/azure-storage-datalake.adoc
similarity index 100%
copy from docs/modules/ROOT/partials/reference/others/flight-recorder.adoc
copy to
docs/modules/ROOT/partials/reference/components/azure-storage-datalake.adoc
diff --git a/docs/modules/ROOT/partials/reference/others/flight-recorder.adoc
b/docs/modules/ROOT/partials/reference/components/hwcloud-smn.adoc
similarity index 100%
copy from docs/modules/ROOT/partials/reference/others/flight-recorder.adoc
copy to docs/modules/ROOT/partials/reference/components/hwcloud-smn.adoc
diff --git a/docs/modules/ROOT/partials/reference/others/flight-recorder.adoc
b/docs/modules/ROOT/partials/reference/components/infinispan-embedded.adoc
similarity index 100%
copy from docs/modules/ROOT/partials/reference/others/flight-recorder.adoc
copy to docs/modules/ROOT/partials/reference/components/infinispan-embedded.adoc
diff --git a/docs/modules/ROOT/partials/reference/others/flight-recorder.adoc
b/docs/modules/ROOT/partials/reference/components/kamelet.adoc
similarity index 100%
copy from docs/modules/ROOT/partials/reference/others/flight-recorder.adoc
copy to docs/modules/ROOT/partials/reference/components/kamelet.adoc
diff --git a/docs/modules/ROOT/partials/reference/others/flight-recorder.adoc
b/docs/modules/ROOT/partials/reference/components/stitch.adoc
similarity index 100%
rename from docs/modules/ROOT/partials/reference/others/flight-recorder.adoc
rename to docs/modules/ROOT/partials/reference/components/stitch.adoc
diff --git a/docs/modules/ROOT/partials/reference/others/caffeine-lrucache.adoc
b/docs/modules/ROOT/partials/reference/others/caffeine-lrucache.adoc
new file mode 100644
index 000..648f4e7
--- /dev/null
+++ b/docs/modules/ROOT/partials/reference/others/caffeine-lrucache.adoc
@@ -0,0 +1,13 @@
+// Do not edit directly!
+// This file was generated by
camel-quarkus-maven-plugin:update-extension-doc-page
+:cq-artifact-id: camel-quarkus-caffeine-lrucache
+:cq-artifact-id-base: caffeine-lrucache
+:cq-native-supported: true
+:cq-status: Stable
+:cq-deprecated: true
+:cq-jvm-since: 1.0.0
+:cq-native-since: 1.0.0
+:cq-camel-part-name: caffeine-lrucache
+:cq-camel-part-title: Caffeine Lrucache
+:cq-camel-part-description: Camel Caffeine LRUCache support
+:cq-extension-page-title: Caffeine LRUCache
[camel-quarkus] 01/06: Upgrade to Camel 3.8.0
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 10322c876a5f275b22864719ab7021e52b192aa6
Author: James Netherton
AuthorDate: Wed Jan 6 08:53:07 2021 +
Upgrade to Camel 3.8.0
---
docs/modules/ROOT/pages/reference/extensions/jsonata.adoc | 2 +-
docs/modules/ROOT/pages/reference/extensions/sjms.adoc | 3 +--
.../modules/ROOT/partials/reference/components/jsonata.adoc | 4 ++--
.../ROOT/partials/reference/components/paho-mqtt5.adoc | 1 +
.../ROOT/partials/reference/components/sjms-batch.adoc | 13 -
.../ROOT/partials/reference/components/spring-rabbitmq.adoc | 1 +
.../ROOT/partials/reference/others/flight-recorder.adoc | 1 +
docs/modules/ROOT/partials/reference/others/jfr.adoc| 1 +
.../apache/camel/component/qute/QuteEndpointConfigurer.java | 3 ---
.../apache/camel/component/qute/QuteEndpointUriFactory.java | 3 +--
.../resources/org/apache/camel/component/qute/qute.json | 3 +--
.../quarkus/component/hazelcast/it/HazelcastQueueTest.java | 2 --
pom.xml | 6 +++---
13 files changed, 13 insertions(+), 30 deletions(-)
diff --git a/docs/modules/ROOT/pages/reference/extensions/jsonata.adoc
b/docs/modules/ROOT/pages/reference/extensions/jsonata.adoc
index d22514b..3b53fd3 100644
--- a/docs/modules/ROOT/pages/reference/extensions/jsonata.adoc
+++ b/docs/modules/ROOT/pages/reference/extensions/jsonata.adoc
@@ -16,7 +16,7 @@ JSON to JSON transformation using JSONATA.
== What's inside
-* xref:{cq-camel-components}::jsonata-component.adoc[JSONATA component], URI
syntax: `jsonata:resourceUri`
+* xref:{cq-camel-components}::jsonata-component.adoc[JSONata component], URI
syntax: `jsonata:resourceUri`
Please refer to the above link for usage and configuration details.
diff --git a/docs/modules/ROOT/pages/reference/extensions/sjms.adoc
b/docs/modules/ROOT/pages/reference/extensions/sjms.adoc
index a9c8263..ccbfe90 100644
--- a/docs/modules/ROOT/pages/reference/extensions/sjms.adoc
+++ b/docs/modules/ROOT/pages/reference/extensions/sjms.adoc
@@ -18,9 +18,8 @@ Send and receive messages to/from a JMS Queue or Topic using
plain JMS 1.x API.
== What's inside
* xref:{cq-camel-components}::sjms-component.adoc[Simple JMS component], URI
syntax: `sjms:destinationType:destinationName`
-* xref:{cq-camel-components}::sjms-batch-component.adoc[Simple JMS Batch
component], URI syntax: `sjms-batch:destinationName`
-Please refer to the above links for usage and configuration details.
+Please refer to the above link for usage and configuration details.
== Maven coordinates
diff --git a/docs/modules/ROOT/partials/reference/components/jsonata.adoc
b/docs/modules/ROOT/partials/reference/components/jsonata.adoc
index 0e6518d..2b9f794 100644
--- a/docs/modules/ROOT/partials/reference/components/jsonata.adoc
+++ b/docs/modules/ROOT/partials/reference/components/jsonata.adoc
@@ -8,6 +8,6 @@
:cq-jvm-since: 1.6.0
:cq-native-since: 1.6.0
:cq-camel-part-name: jsonata
-:cq-camel-part-title: JSONATA
-:cq-camel-part-description: JSON to JSON transformation using JSONATA.
+:cq-camel-part-title: JSONata
+:cq-camel-part-description: Transforms JSON payload using JSONata
transformation.
:cq-extension-page-title: JSONATA
diff --git a/docs/modules/ROOT/partials/reference/components/paho-mqtt5.adoc
b/docs/modules/ROOT/partials/reference/components/paho-mqtt5.adoc
new file mode 100644
index 000..a509c1d
--- /dev/null
+++ b/docs/modules/ROOT/partials/reference/components/paho-mqtt5.adoc
@@ -0,0 +1 @@
+// Empty partial for a Camel bit unsupported by Camel Quarkus to avoid
warnings when this file is included from a Camel page
diff --git a/docs/modules/ROOT/partials/reference/components/sjms-batch.adoc
b/docs/modules/ROOT/partials/reference/components/sjms-batch.adoc
deleted file mode 100644
index eff2868..000
--- a/docs/modules/ROOT/partials/reference/components/sjms-batch.adoc
+++ /dev/null
@@ -1,13 +0,0 @@
-// Do not edit directly!
-// This file was generated by
camel-quarkus-maven-plugin:update-extension-doc-page
-:cq-artifact-id: camel-quarkus-sjms
-:cq-artifact-id-base: sjms
-:cq-native-supported: true
-:cq-status: Stable
-:cq-deprecated: false
-:cq-jvm-since: 1.0.0
-:cq-native-since: 1.0.0
-:cq-camel-part-name: sjms-batch
-:cq-camel-part-title: Simple JMS Batch
-:cq-camel-part-description: Highly performant and transactional batch
consumption of messages from a JMS queue.
-:cq-extension-page-title: Simple JMS
diff --git
a/docs/modules/ROOT/partials/reference/components/spring-rabbitmq.adoc
b/docs/modules/ROOT/partials/reference/components/spring-rabbitmq.adoc
new file mode 100644
index 000..a509c1d
--- /dev/null
+++ b/docs/modules/ROOT/partials/reference/components/spring-rabbitmq.adoc
@@ -0,0 +1 @@
+// Empty partial for a Camel bit
[camel-quarkus] 02/06: Adjust to camel 3.8 change
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 11b43904348df7babc014d723614befccfa94d07
Author: Claus Ibsen
AuthorDate: Mon Jan 25 09:28:14 2021 +0100
Adjust to camel 3.8 change
---
.../java/org/apache/camel/quarkus/core/NoShutdownStrategy.java | 10 ++
1 file changed, 10 insertions(+)
diff --git
a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/NoShutdownStrategy.java
b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/NoShutdownStrategy.java
index 4110fba..477bcc3 100644
---
a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/NoShutdownStrategy.java
+++
b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/NoShutdownStrategy.java
@@ -19,6 +19,7 @@ package org.apache.camel.quarkus.core;
import java.util.List;
import java.util.concurrent.TimeUnit;
+import org.apache.camel.LoggingLevel;
import org.apache.camel.CamelContext;
import org.apache.camel.Service;
import org.apache.camel.spi.RouteStartupOrder;
@@ -130,6 +131,15 @@ public class NoShutdownStrategy implements
ShutdownStrategy {
}
@Override
+public LoggingLevel getLoggingLevel() {
+return LoggingLevel.OFF;
+}
+
+public void setLoggingLevel(LoggingLevel LoggingLevel) {
+// noop
+}
+
+@Override
public void start() {
}
[GitHub] [camel-kafka-connector] claudio4j opened a new pull request #936: Provide option to delete camel kafka submodule if they are not in camel catalog
claudio4j opened a new pull request #936: URL: https://github.com/apache/camel-kafka-connector/pull/936 https://github.com/apache/camel-kafka-connector/issues/149 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 created (now 89341af)
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. at 89341af [create-pull-request] automated change No new revisions were added by this update.
[GitHub] [camel-spring-boot] github-actions[bot] opened a new pull request #271: [Github Actions] Periodic Sync Camel Spring Boot Master Branch
github-actions[bot] opened a new pull request #271: URL: https://github.com/apache/camel-spring-boot/pull/271 Periodic Sync of Camel Spring Boot Master Branch with main Camel Master. see https://github.com/apache/camel-spring-boot/blob/master/.github/workflows/automatic-sync-master.yml 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] 02/04: chore(prometheus): Remove Prometheus JMX exporter configuration from the Prometheus trait
This is an automated email from the ASF dual-hosted git repository. astefanutti pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-k.git commit baf7c6f1e293f232476760c9d80491d5e02e8210 Author: Antonin Stefanutti AuthorDate: Thu Jan 28 17:04:23 2021 +0100 chore(prometheus): Remove Prometheus JMX exporter configuration from the Prometheus trait --- deploy/prometheus-jmx-exporter.yaml | 603 -- deploy/resources.go | 8 - deploy/traits.yaml| 3 - docs/modules/traits/pages/prometheus.adoc | 6 - pkg/trait/prometheus.go | 38 +- 5 files changed, 1 insertion(+), 657 deletions(-) diff --git a/deploy/prometheus-jmx-exporter.yaml b/deploy/prometheus-jmx-exporter.yaml deleted file mode 100644 index c73f818..000 --- a/deploy/prometheus-jmx-exporter.yaml +++ /dev/null @@ -1,603 +0,0 @@ -# --- -# 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. -# --- - -startDelaySecs: 5 -ssl: false -blacklistObjectNames: ["java.lang:*"] -rules: - # Context level - - pattern: 'org.apache.camel<>ExchangesCompleted' -name: org.apache.camel.ExchangesCompleted -help: Exchanges Completed -type: COUNTER -labels: - context: $1 - type: context - - pattern: 'org.apache.camel<>ExchangesFailed' -name: org.apache.camel.ExchangesFailed -help: Exchanges Failed -type: COUNTER -labels: - context: $1 - type: context - - pattern: 'org.apache.camel<>ExchangesInflight' -name: org.apache.camel.ExchangesInflight -help: Exchanges Inflight -type: COUNTER -labels: - context: $1 - type: context - - pattern: 'org.apache.camel<>ExchangesTotal' -name: org.apache.camel.ExchangesTotal -help: Exchanges Total -type: COUNTER -labels: - context: $1 - type: context - - pattern: 'org.apache.camel<>ExchangesTotal' -name: org.apache.camel.ExchangesTotal -help: Exchanges Total -type: COUNTER -labels: - context: $1 - type: context - - pattern: 'org.apache.camel<>FailuresHandled' -name: org.apache.camel.FailuresHandled -help: Failures Handled -labels: - context: $1 - type: context -type: COUNTER - - pattern: 'org.apache.camel<>ExternalRedeliveries' -name: org.apache.camel.ExternalRedeliveries -help: External Redeliveries -labels: - context: $1 - type: context -type: COUNTER - - pattern: 'org.apache.camel<>MaxProcessingTime' -name: org.apache.camel.MaxProcessingTime -help: Maximum Processing Time -labels: - context: $1 - type: context -type: GAUGE - - pattern: 'org.apache.camel<>MeanProcessingTime' -name: org.apache.camel.MeanProcessingTime -help: Mean Processing Time -labels: - context: $1 - type: context -type: GAUGE - - pattern: 'org.apache.camel<>MinProcessingTime' -name: org.apache.camel.MinProcessingTime -help: Minimum Processing Time -labels: - context: $1 - type: context -type: GAUGE - - pattern: 'org.apache.camel<>LastProcessingTime' -name: org.apache.camel.LastProcessingTime -help: Last Processing Time -labels: - context: $1 - type: context -type: GAUGE - - pattern: 'org.apache.camel<>DeltaProcessingTime' -name: org.apache.camel.DeltaProcessingTime -help: Delta Processing Time -labels: - context: $1 - type: context -type: GAUGE - - pattern: 'org.apache.camel<>Redeliveries' -name: org.apache.camel.Redeliveries -help: Redeliveries -labels: - context: $1 - type: context -type: GAUGE - - pattern: 'org.apache.camel<>TotalProcessingTime' -name: org.apache.camel.TotalProcessingTime -help: Total Processing Time -labels: - context: $1 - type: context -type: GAUGE - - pattern: 'org.apache.camel<>InflightExchanges' -name: org.apache.camel.InflightExchanges -help: Inflight Exchanges -labels: - context: $1 - type: context -type: GAUGE - - - # Route level
[camel-k] 04/04: chore(e2e): Remove Quarkus trait configuration from monitoring e2e test
This is an automated email from the ASF dual-hosted git repository. astefanutti pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-k.git commit 5817d05252bd3065c11e21833a7365afdcb59bfa Author: Antonin Stefanutti AuthorDate: Thu Jan 28 17:30:49 2021 +0100 chore(e2e): Remove Quarkus trait configuration from monitoring e2e test --- e2e/yaks/openshift/monitoring/Metrics.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/e2e/yaks/openshift/monitoring/Metrics.java b/e2e/yaks/openshift/monitoring/Metrics.java index 203e1f8..38c423f 100644 --- a/e2e/yaks/openshift/monitoring/Metrics.java +++ b/e2e/yaks/openshift/monitoring/Metrics.java @@ -1,4 +1,4 @@ -// camel-k: language=java trait=quarkus.enabled=true trait=prometheus.enabled=true +// camel-k: language=java trait=prometheus.enabled=true /* * Licensed to the Apache Software Foundation (ASF) under one or more
[camel-k] 03/04: chore(prometheus): Remove Quarkus references from the Prometheus trait documentation
This is an automated email from the ASF dual-hosted git repository. astefanutti pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-k.git commit 05ba4375f7ed01493b7c0d2b1dfb2c5ab8f45078 Author: Antonin Stefanutti AuthorDate: Thu Jan 28 17:09:02 2021 +0100 chore(prometheus): Remove Quarkus references from the Prometheus trait documentation --- deploy/traits.yaml| 2 +- docs/modules/traits/pages/prometheus.adoc | 4 +--- pkg/trait/prometheus.go | 6 ++ 3 files changed, 4 insertions(+), 8 deletions(-) diff --git a/deploy/traits.yaml b/deploy/traits.yaml index f130ae1..cb0bbc9 100755 --- a/deploy/traits.yaml +++ b/deploy/traits.yaml @@ -502,7 +502,7 @@ traits: - Kubernetes - Knative - OpenShift - description: 'The Prometheus trait configures a Prometheus-compatible endpoint. This trait also exposes the integration with `Service` and `ServiceMonitor` resources, so that the endpoint can be scraped automatically, when using the Prometheus Operator. The metrics exposed vary depending on the configured runtime. With the default Quarkus runtime, metrics are exposed using MicroProfile Metrics. While with the Java main runtime, metrics are exposed using the Prometheus JMX exporter. WAR [...] + description: 'The Prometheus trait configures a Prometheus-compatible endpoint. This trait also exposes the integration with `Service` and `ServiceMonitor` resources, so that the endpoint can be scraped automatically, when using the Prometheus Operator. The metrics are exposed using MicroProfile Metrics. WARNING: The creation of the `ServiceMonitor` resource requires the https://github.com/coreos/prometheus-operator[Prometheus Operator] custom resource definition to be installed. You c [...] properties: - name: enabled type: bool diff --git a/docs/modules/traits/pages/prometheus.adoc b/docs/modules/traits/pages/prometheus.adoc index 6ab4ef9..1bc57ac 100755 --- a/docs/modules/traits/pages/prometheus.adoc +++ b/docs/modules/traits/pages/prometheus.adoc @@ -5,9 +5,7 @@ The Prometheus trait configures a Prometheus-compatible endpoint. This trait als `Service` and `ServiceMonitor` resources, so that the endpoint can be scraped automatically, when using the Prometheus Operator. -The metrics exposed vary depending on the configured runtime. With the default Quarkus runtime, metrics are -exposed using MicroProfile Metrics. While with the Java main runtime, metrics are exposed using the Prometheus -JMX exporter. +The metrics are exposed using MicroProfile Metrics. WARNING: The creation of the `ServiceMonitor` resource requires the https://github.com/coreos/prometheus-operator[Prometheus Operator] custom resource definition to be installed. diff --git a/pkg/trait/prometheus.go b/pkg/trait/prometheus.go index 40e994c..6c4ffcb 100644 --- a/pkg/trait/prometheus.go +++ b/pkg/trait/prometheus.go @@ -31,12 +31,10 @@ import ( ) // The Prometheus trait configures a Prometheus-compatible endpoint. This trait also exposes the integration with -//`Service` and `ServiceMonitor` resources, so that the endpoint can be scraped automatically, when using the +// `Service` and `ServiceMonitor` resources, so that the endpoint can be scraped automatically, when using the // Prometheus Operator. // -// The metrics exposed vary depending on the configured runtime. With the default Quarkus runtime, metrics are -// exposed using MicroProfile Metrics. While with the Java main runtime, metrics are exposed using the Prometheus -// JMX exporter. +// The metrics are exposed using MicroProfile Metrics. // // WARNING: The creation of the `ServiceMonitor` resource requires the https://github.com/coreos/prometheus-operator[Prometheus Operator] // custom resource definition to be installed.
[camel-k] branch master updated (c06ef01 -> 5817d05)
This is an automated email from the ASF dual-hosted git repository. astefanutti pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel-k.git. from c06ef01 fix(trait): using proper contentKey for sources new 201f6ab chore(prometheus): Remove runtime provider API use from the Prometheus trait new baf7c6f chore(prometheus): Remove Prometheus JMX exporter configuration from the Prometheus trait new 05ba437 chore(prometheus): Remove Quarkus references from the Prometheus trait documentation new 5817d05 chore(e2e): Remove Quarkus trait configuration from monitoring e2e test The 4 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: deploy/prometheus-jmx-exporter.yaml| 603 - deploy/resources.go| 8 - deploy/traits.yaml | 5 +- docs/modules/traits/pages/prometheus.adoc | 10 +- e2e/yaks/openshift/monitoring/Metrics.java | 2 +- pkg/trait/prometheus.go| 60 +-- 6 files changed, 10 insertions(+), 678 deletions(-) delete mode 100644 deploy/prometheus-jmx-exporter.yaml
[camel-k] 01/04: chore(prometheus): Remove runtime provider API use from the Prometheus trait
This is an automated email from the ASF dual-hosted git repository.
astefanutti pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-k.git
commit 201f6abb126c142ee7cdfcb9a797440d3c782fea
Author: Antonin Stefanutti
AuthorDate: Thu Jan 28 16:55:46 2021 +0100
chore(prometheus): Remove runtime provider API use from the Prometheus trait
---
pkg/trait/prometheus.go | 16
1 file changed, 4 insertions(+), 12 deletions(-)
diff --git a/pkg/trait/prometheus.go b/pkg/trait/prometheus.go
index 1ce9505..1758739 100644
--- a/pkg/trait/prometheus.go
+++ b/pkg/trait/prometheus.go
@@ -19,6 +19,7 @@ package trait
import (
"fmt"
+
corev1 "k8s.io/api/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/util/intstr"
@@ -82,12 +83,8 @@ func (t *prometheusTrait) Configure(e *Environment) (bool,
error) {
func (t *prometheusTrait) Apply(e *Environment) (err error) {
if e.IntegrationInPhase(v1.IntegrationPhaseInitialization) {
- switch e.CamelCatalog.Runtime.Provider {
- case v1.RuntimeProviderQuarkus:
- // Add the Camel Quarkus MP Metrics extension
-
util.StringSliceUniqueAdd(,
"mvn:org.apache.camel.quarkus:camel-quarkus-microprofile-metrics")
- }
- return nil
+ // Add the Camel Quarkus MP Metrics extension
+ util.StringSliceUniqueAdd(,
"mvn:org.apache.camel.quarkus:camel-quarkus-microprofile-metrics")
}
container := e.getIntegrationContainer()
@@ -107,12 +104,7 @@ func (t *prometheusTrait) Apply(e *Environment) (err
error) {
Reason: v1.IntegrationConditionPrometheusAvailableReason,
}
- var port int
- switch e.CamelCatalog.Runtime.Provider {
- case v1.RuntimeProviderQuarkus:
- port = 8080
- }
-
+ port := 8080
if t.Port == nil {
t.Port =
}
[GitHub] [camel-k] astefanutti merged pull request #1956: chore(prometheus): Remove runtime references from the Prometheus trait
astefanutti merged pull request #1956: URL: https://github.com/apache/camel-k/pull/1956 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] luigidemasi opened a new pull request #935: create a toHeader SMT #902
luigidemasi opened a new pull request #935: URL: https://github.com/apache/camel-kafka-connector/pull/935 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-k] astefanutti opened a new pull request #1956: chore(prometheus): Remove runtime references from the Prometheus trait
astefanutti opened a new pull request #1956: URL: https://github.com/apache/camel-k/pull/1956 **Release Note** ```release-note NONE ``` This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] astefanutti commented on issue #1923: [ppc64le] bundle image generated using `bundle` and `bundle-build` targets incompatible with `opm`
astefanutti commented on issue #1923: URL: https://github.com/apache/camel-k/issues/1923#issuecomment-769178411 Awesome, thanks @amitsadaphule! 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-k] amitsadaphule commented on issue #1923: [ppc64le] bundle image generated using `bundle` and `bundle-build` targets incompatible with `opm`
amitsadaphule commented on issue #1923: URL: https://github.com/apache/camel-k/issues/1923#issuecomment-769177715 Sure @astefanutti ! I'll try and raise a PR in next week with that documentation. 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] branch master updated: fix(trait): using proper contentKey for sources
This is an automated email from the ASF dual-hosted git repository.
nferraro pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-k.git
The following commit(s) were added to refs/heads/master by this push:
new c06ef01 fix(trait): using proper contentKey for sources
c06ef01 is described below
commit c06ef01abdb5c376a6909040c502f5520cd2597f
Author: Pasquale Congiusti
AuthorDate: Thu Jan 28 10:12:31 2021 +0100
fix(trait): using proper contentKey for sources
* If an integration is providing specifically a ConfigMap's item we now use
its key, leaving "content" as default
* Added some unit test to check default and content ref behavior also for
sources
Fix #1951
---
pkg/trait/trait_test.go | 60 +++-
pkg/trait/trait_types.go | 7 --
2 files changed, 64 insertions(+), 3 deletions(-)
diff --git a/pkg/trait/trait_test.go b/pkg/trait/trait_test.go
index 491a856..6336fd7 100644
--- a/pkg/trait/trait_test.go
+++ b/pkg/trait/trait_test.go
@@ -207,7 +207,65 @@ func TestTraitHierarchyDecode(t *testing.T) {
assert.Equal(t, 15, *kns.Target)
}
-func TestConfigureVolumesAndMounts(t *testing.T) {
+func TestConfigureVolumesAndMountsSources(t *testing.T) {
+ env := Environment{
+ Resources: kubernetes.NewCollection(),
+ Integration: {
+ ObjectMeta: metav1.ObjectMeta{
+ Name: TestDeploymentName,
+ Namespace: "ns",
+ },
+ Spec: v1.IntegrationSpec{
+ Sources: []v1.SourceSpec{
+ {
+ DataSpec: v1.DataSpec{
+ Name:
"source1.java",
+ ContentRef: "my-cm1",
+ ContentKey:
"source1.java",
+ },
+ Type: "data",
+ },
+ {
+ DataSpec: v1.DataSpec{
+ Name:
"source2.java",
+ ContentRef: "my-cm2",
+ },
+ Type: "data",
+ },
+ },
+ },
+ },
+ }
+
+ vols := make([]corev1.Volume, 0)
+ mnts := make([]corev1.VolumeMount, 0)
+
+ env.Resources.AddAll(env.ComputeConfigMaps())
+ env.ConfigureVolumesAndMounts(, )
+
+ assert.Len(t, vols, 2)
+ assert.Len(t, mnts, 2)
+
+ v := findVolume(vols, func(v corev1.Volume) bool { return
v.ConfigMap.Name == "my-cm1" })
+ assert.NotNil(t, v)
+ assert.NotNil(t, v.VolumeSource.ConfigMap)
+ assert.Len(t, v.VolumeSource.ConfigMap.Items, 1)
+ assert.Equal(t, "source1.java", v.VolumeSource.ConfigMap.Items[0].Key)
+
+ m := findVVolumeMount(mnts, func(m corev1.VolumeMount) bool { return
m.Name == v.Name })
+ assert.NotNil(t, m)
+
+ v = findVolume(vols, func(v corev1.Volume) bool { return
v.ConfigMap.Name == "my-cm2" })
+ assert.NotNil(t, v)
+ assert.NotNil(t, v.VolumeSource.ConfigMap)
+ assert.Len(t, v.VolumeSource.ConfigMap.Items, 1)
+ assert.Equal(t, "content", v.VolumeSource.ConfigMap.Items[0].Key)
+
+ m = findVVolumeMount(mnts, func(m corev1.VolumeMount) bool { return
m.Name == v.Name })
+ assert.NotNil(t, m)
+}
+
+func TestConfigureVolumesAndMountsResourcesAndProperties(t *testing.T) {
env := Environment{
Resources: kubernetes.NewCollection(),
Integration: {
diff --git a/pkg/trait/trait_types.go b/pkg/trait/trait_types.go
index f28fc8f..e896b3b 100644
--- a/pkg/trait/trait_types.go
+++ b/pkg/trait/trait_types.go
@@ -529,12 +529,15 @@ func (e *Environment) ConfigureVolumesAndMounts(vols
*[]corev1.Volume, mnts *[]c
//
// Volumes :: Sources
//
-
for i, s := range e.Integration.Sources() {
cmName := fmt.Sprintf("%s-source-%03d", e.Integration.Name, i)
if s.ContentRef != "" {
cmName = s.ContentRef
}
+ cmKey := "content"
+ if s.ContentKey != "" {
+ cmKey = s.ContentKey
+ }
resName := strings.TrimPrefix(s.Name, "/")
refName := fmt.Sprintf("i-source-%03d", i)
resPath := path.Join(SourcesMountPath, refName)
@@ -548,7 +551,7 @@ func (e *Environment)
[GitHub] [camel-k] nicolaferraro merged pull request #1953: fix(trait): using proper contentKey for sources
nicolaferraro merged pull request #1953: URL: https://github.com/apache/camel-k/pull/1953 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-k] nicolaferraro closed issue #1951: Ability to have sources for integrations as ConfigMaps
nicolaferraro closed issue #1951: URL: https://github.com/apache/camel-k/issues/1951 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-website] github-actions[bot] commented on pull request #532: Create ckc release 0.7.1 note.
github-actions[bot] commented on pull request #532: URL: https://github.com/apache/camel-website/pull/532#issuecomment-769168930 Preview for a801fd898627cca920c40ae6f53c74b596be3f3c is available at https://pr-532--camel.netlify.app This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] astefanutti commented on issue #1923: [ppc64le] bundle image generated using `bundle` and `bundle-build` targets incompatible with `opm`
astefanutti commented on issue #1923: URL: https://github.com/apache/camel-k/issues/1923#issuecomment-769168032 Thanks for the update. Do you think some of this documentation could be included into Camel K documentation? I'm thinking about the OLM deployment from source for example, that is not cover in the existing documentation AFAIK: https://github.com/ppc64le/build-scripts/tree/master/c/camel-k#olm-installation-and-validation 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-website] valdar opened a new pull request #532: Create ckc release 0.7.1 note.
valdar opened a new pull request #532: URL: https://github.com/apache/camel-website/pull/532 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-website] branch ckc-0.7.1-release-notes created (now a801fd8)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch ckc-0.7.1-release-notes in repository https://gitbox.apache.org/repos/asf/camel-website.git. at a801fd8 Create ckc release 0.7.1 note. This branch includes the following new commits: new a801fd8 Create ckc release 0.7.1 note. 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-website] 01/01: Create ckc release 0.7.1 note.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch ckc-0.7.1-release-notes in repository https://gitbox.apache.org/repos/asf/camel-website.git commit a801fd898627cca920c40ae6f53c74b596be3f3c Author: Andrea Tarocchi AuthorDate: Thu Jan 28 16:00:29 2021 +0100 Create ckc release 0.7.1 note. --- content/releases/ckc/release-0.7.1.md | 10 ++ 1 file changed, 10 insertions(+) diff --git a/content/releases/ckc/release-0.7.1.md b/content/releases/ckc/release-0.7.1.md new file mode 100644 index 000..7cea74e --- /dev/null +++ b/content/releases/ckc/release-0.7.1.md @@ -0,0 +1,10 @@ +--- +url: "/releases/ckc-0.7.1/" +date: 2021-01-28 +type: release-note +version: "0.7.1" +title: "Camel Kafka Connector release 0.7.1" +preview: "" +changelog: "" +category: "camel-kafka-connector" +---
svn commit: r45625 - in /release/camel/camel-kafka-connector/0.7.1: ./ camel-kafka-connector-0.7.1-src.zip camel-kafka-connector-0.7.1-src.zip.asc camel-kafka-connector-0.7.1-src.zip.sha512
Author: valdar Date: Thu Jan 28 15:00:08 2021 New Revision: 45625 Log: Camel Kafka Connector 0.7.1 import. Added: release/camel/camel-kafka-connector/0.7.1/ release/camel/camel-kafka-connector/0.7.1/camel-kafka-connector-0.7.1-src.zip (with props) release/camel/camel-kafka-connector/0.7.1/camel-kafka-connector-0.7.1-src.zip.asc (with props) release/camel/camel-kafka-connector/0.7.1/camel-kafka-connector-0.7.1-src.zip.sha512 Added: release/camel/camel-kafka-connector/0.7.1/camel-kafka-connector-0.7.1-src.zip == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/0.7.1/camel-kafka-connector-0.7.1-src.zip -- svn:mime-type = application/zip Added: release/camel/camel-kafka-connector/0.7.1/camel-kafka-connector-0.7.1-src.zip.asc == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/0.7.1/camel-kafka-connector-0.7.1-src.zip.asc -- svn:mime-type = application/pgp-signature Added: release/camel/camel-kafka-connector/0.7.1/camel-kafka-connector-0.7.1-src.zip.sha512 == --- release/camel/camel-kafka-connector/0.7.1/camel-kafka-connector-0.7.1-src.zip.sha512 (added) +++ release/camel/camel-kafka-connector/0.7.1/camel-kafka-connector-0.7.1-src.zip.sha512 Thu Jan 28 15:00:08 2021 @@ -0,0 +1 @@ +5ec43ee22ecf69fed2e265dc27547c3bbf85c1e872f3fb1ec1c52c3efd773c878ac9545a10c1d1cbae104fa5fb9d2605b167f9d2d235365438a83b7d5395d6f5 camel-kafka-connector-0.7.1-src.zip
[GitHub] [camel-k] vkasala opened a new issue #1955: Group all traits test under one e2e directory
vkasala opened a new issue #1955: URL: https://github.com/apache/camel-k/issues/1955 I would like to move all trait related tests into one directory e.g. e2e/common/traits to give it more structure. I would also like to have a suffix in the name e.g. addons_test.go -> addons_trait_test.go Thanks 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 merged pull request #934: Upgrade archetype instructions to version 0.8.0
oscerd merged pull request #934: URL: https://github.com/apache/camel-kafka-connector/pull/934 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: Upgrade archetype instructions to version 0.8.0
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 7e30724 Upgrade archetype instructions to version 0.8.0 7e30724 is described below commit 7e30724eec4733fc08559af182ff6d306459d6dd Author: Andrea Cosentino AuthorDate: Thu Jan 28 15:09:04 2021 +0100 Upgrade archetype instructions to version 0.8.0 --- .../ROOT/pages/archetype-apicurio-connector.adoc | 18 +- docs/modules/ROOT/pages/archetype-connector.adoc | 16 .../ROOT/pages/archetype-dataformat-connector.adoc | 18 +- 3 files changed, 26 insertions(+), 26 deletions(-) diff --git a/docs/modules/ROOT/pages/archetype-apicurio-connector.adoc b/docs/modules/ROOT/pages/archetype-apicurio-connector.adoc index 83e4462..dfbf76a 100644 --- a/docs/modules/ROOT/pages/archetype-apicurio-connector.adoc +++ b/docs/modules/ROOT/pages/archetype-apicurio-connector.adoc @@ -9,7 +9,7 @@ You can do that through the following command. [source,bash] -> mvn archetype:generate -DarchetypeGroupId=org.apache.camel.kafkaconnector.archetypes -DarchetypeArtifactId=camel-kafka-connector-extensible-apicurio-archetype -DarchetypeVersion=0.7.0-SNAPSHOT +> mvn archetype:generate -DarchetypeGroupId=org.apache.camel.kafkaconnector.archetypes -DarchetypeArtifactId=camel-kafka-connector-extensible-apicurio-archetype -DarchetypeVersion=0.8.0-SNAPSHOT [INFO] Scanning for projects... [INFO] [INFO] --< org.apache.maven:standalone-pom >--- @@ -23,23 +23,23 @@ You can do that through the following command. [INFO] [INFO] --- maven-archetype-plugin:3.1.2:generate (default-cli) @ standalone-pom --- [INFO] Generating project in Interactive mode -[INFO] Archetype repository not defined. Using the one from [org.apache.camel.kafkaconnector.archetypes:camel-kafka-connector-extensible-apicurio-archetype:0.7.0-SNAPSHOT] found in catalog local +[INFO] Archetype repository not defined. Using the one from [org.apache.camel.kafkaconnector.archetypes:camel-kafka-connector-extensible-apicurio-archetype:0.8.0-SNAPSHOT] found in catalog local Define value for property 'groupId': org.apache.camel.kafkaconnector.extended Define value for property 'artifactId': myconnector-extended Define value for property 'version' 1.0-SNAPSHOT: : Define value for property 'package' org.apache.camel.kafkaconnector.extended: : Define value for property 'camel-kafka-connector-name': camel-aws2-s3-kafka-connector -[INFO] Using property: camel-kafka-connector-version = 0.7.0-SNAPSHOT +[INFO] Using property: camel-kafka-connector-version = 0.8.0-SNAPSHOT Confirm properties configuration: groupId: org.apache.camel.kafkaconnector.extended artifactId: myconnector-extended version: 1.0-SNAPSHOT package: org.apache.camel.kafkaconnector.extended camel-kafka-connector-name: camel-aws2-s3-kafka-connector -camel-kafka-connector-version: 0.7.0-SNAPSHOT +camel-kafka-connector-version: 0.8.0-SNAPSHOT Y: : Y [INFO] -[INFO] Using following parameters for creating project from Archetype: camel-kafka-connector-extensible-apicurio-archetype:0.7.0-SNAPSHOT +[INFO] Using following parameters for creating project from Archetype: camel-kafka-connector-extensible-apicurio-archetype:0.8.0-SNAPSHOT [INFO] [INFO] Parameter: groupId, Value: org.apache.camel.kafkaconnector.extended [INFO] Parameter: artifactId, Value: myconnector-extended @@ -50,7 +50,7 @@ camel-kafka-connector-version: 0.7.0-SNAPSHOT [INFO] Parameter: version, Value: 1.0-SNAPSHOT [INFO] Parameter: groupId, Value: org.apache.camel.kafkaconnector.extended [INFO] Parameter: camel-kafka-connector-name, Value: camel-aws2-s3-kafka-connector -[INFO] Parameter: camel-kafka-connector-version, Value: 0.7.0-SNAPSHOT +[INFO] Parameter: camel-kafka-connector-version, Value: 0.8.0-SNAPSHOT [INFO] Parameter: artifactId, Value: myconnector-extended [INFO] Project created from Archetype in dir: /home/workspace/myconnector-extended [INFO] @@ -76,7 +76,7 @@ This is the resulting POM org.apache.camel.kafkaconnector parent - 0.7.0-SNAPSHOT + 0.8.0-SNAPSHOT org.apache.camel.kafkaconnector.extended @@ -110,12 +110,12 @@ This is the resulting POM org.apache.camel.kafkaconnector camel-kafka-connector - 0.7.0-SNAPSHOT + 0.8.0-SNAPSHOT org.apache.camel.kafkaconnector camel-aws2-s3-kafka-connector - 0.7.0-SNAPSHOT + 0.8.0-SNAPSHOT org.jboss.resteasy diff --git
[GitHub] [camel-kafka-connector] oscerd opened a new pull request #934: Upgrade archetype instructions to version 0.8.0
oscerd opened a new pull request #934: URL: https://github.com/apache/camel-kafka-connector/pull/934 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: Upgrade archetype instructions to version 0.8.0
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch archetype-docs-to-0.8.0 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit ef5a3bea688f8aa7cc13e299e7517682c6b22dbf Author: Andrea Cosentino AuthorDate: Thu Jan 28 15:09:04 2021 +0100 Upgrade archetype instructions to version 0.8.0 --- .../ROOT/pages/archetype-apicurio-connector.adoc | 18 +- docs/modules/ROOT/pages/archetype-connector.adoc | 16 .../ROOT/pages/archetype-dataformat-connector.adoc | 18 +- 3 files changed, 26 insertions(+), 26 deletions(-) diff --git a/docs/modules/ROOT/pages/archetype-apicurio-connector.adoc b/docs/modules/ROOT/pages/archetype-apicurio-connector.adoc index 83e4462..dfbf76a 100644 --- a/docs/modules/ROOT/pages/archetype-apicurio-connector.adoc +++ b/docs/modules/ROOT/pages/archetype-apicurio-connector.adoc @@ -9,7 +9,7 @@ You can do that through the following command. [source,bash] -> mvn archetype:generate -DarchetypeGroupId=org.apache.camel.kafkaconnector.archetypes -DarchetypeArtifactId=camel-kafka-connector-extensible-apicurio-archetype -DarchetypeVersion=0.7.0-SNAPSHOT +> mvn archetype:generate -DarchetypeGroupId=org.apache.camel.kafkaconnector.archetypes -DarchetypeArtifactId=camel-kafka-connector-extensible-apicurio-archetype -DarchetypeVersion=0.8.0-SNAPSHOT [INFO] Scanning for projects... [INFO] [INFO] --< org.apache.maven:standalone-pom >--- @@ -23,23 +23,23 @@ You can do that through the following command. [INFO] [INFO] --- maven-archetype-plugin:3.1.2:generate (default-cli) @ standalone-pom --- [INFO] Generating project in Interactive mode -[INFO] Archetype repository not defined. Using the one from [org.apache.camel.kafkaconnector.archetypes:camel-kafka-connector-extensible-apicurio-archetype:0.7.0-SNAPSHOT] found in catalog local +[INFO] Archetype repository not defined. Using the one from [org.apache.camel.kafkaconnector.archetypes:camel-kafka-connector-extensible-apicurio-archetype:0.8.0-SNAPSHOT] found in catalog local Define value for property 'groupId': org.apache.camel.kafkaconnector.extended Define value for property 'artifactId': myconnector-extended Define value for property 'version' 1.0-SNAPSHOT: : Define value for property 'package' org.apache.camel.kafkaconnector.extended: : Define value for property 'camel-kafka-connector-name': camel-aws2-s3-kafka-connector -[INFO] Using property: camel-kafka-connector-version = 0.7.0-SNAPSHOT +[INFO] Using property: camel-kafka-connector-version = 0.8.0-SNAPSHOT Confirm properties configuration: groupId: org.apache.camel.kafkaconnector.extended artifactId: myconnector-extended version: 1.0-SNAPSHOT package: org.apache.camel.kafkaconnector.extended camel-kafka-connector-name: camel-aws2-s3-kafka-connector -camel-kafka-connector-version: 0.7.0-SNAPSHOT +camel-kafka-connector-version: 0.8.0-SNAPSHOT Y: : Y [INFO] -[INFO] Using following parameters for creating project from Archetype: camel-kafka-connector-extensible-apicurio-archetype:0.7.0-SNAPSHOT +[INFO] Using following parameters for creating project from Archetype: camel-kafka-connector-extensible-apicurio-archetype:0.8.0-SNAPSHOT [INFO] [INFO] Parameter: groupId, Value: org.apache.camel.kafkaconnector.extended [INFO] Parameter: artifactId, Value: myconnector-extended @@ -50,7 +50,7 @@ camel-kafka-connector-version: 0.7.0-SNAPSHOT [INFO] Parameter: version, Value: 1.0-SNAPSHOT [INFO] Parameter: groupId, Value: org.apache.camel.kafkaconnector.extended [INFO] Parameter: camel-kafka-connector-name, Value: camel-aws2-s3-kafka-connector -[INFO] Parameter: camel-kafka-connector-version, Value: 0.7.0-SNAPSHOT +[INFO] Parameter: camel-kafka-connector-version, Value: 0.8.0-SNAPSHOT [INFO] Parameter: artifactId, Value: myconnector-extended [INFO] Project created from Archetype in dir: /home/workspace/myconnector-extended [INFO] @@ -76,7 +76,7 @@ This is the resulting POM org.apache.camel.kafkaconnector parent - 0.7.0-SNAPSHOT + 0.8.0-SNAPSHOT org.apache.camel.kafkaconnector.extended @@ -110,12 +110,12 @@ This is the resulting POM org.apache.camel.kafkaconnector camel-kafka-connector - 0.7.0-SNAPSHOT + 0.8.0-SNAPSHOT org.apache.camel.kafkaconnector camel-aws2-s3-kafka-connector - 0.7.0-SNAPSHOT + 0.8.0-SNAPSHOT org.jboss.resteasy diff --git a/docs/modules/ROOT/pages/archetype-connector.adoc b/docs/modules/ROOT/pages/archetype-connector.adoc index 19d8731..1fc53d5 100644 ---
[camel-kafka-connector] branch archetype-docs-to-0.8.0 created (now ef5a3be)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch archetype-docs-to-0.8.0 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at ef5a3be Upgrade archetype instructions to version 0.8.0 This branch includes the following new commits: new ef5a3be Upgrade archetype instructions to version 0.8.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.
[camel] branch regen_bot updated (58d9b8d -> 0dcbe44)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from 58d9b8d Add upgrade note about infinispan add c7e3f32 Upgrade Kubernetes-client and model to version 5.0.1 add 0dcbe44 Sync deps No new revisions were added by this update. Summary of changes: camel-dependencies/pom.xml | 4 ++-- parent/pom.xml | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-)
[GitHub] [camel-quarkus] jamesnetherton closed issue #2126: Align Kubernetes client version with Quarkus
jamesnetherton closed issue #2126: URL: https://github.com/apache/camel-quarkus/issues/2126 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 issue #2126: Align Kubernetes client version with Quarkus
jamesnetherton commented on issue #2126: URL: https://github.com/apache/camel-quarkus/issues/2126#issuecomment-769074567 This is done & ready for 3.8.0. I verified the JVM / native tests + did some basic tests against a real cluster. 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 merged pull request #933: Update docs to 0.7.1
oscerd merged pull request #933: URL: https://github.com/apache/camel-kafka-connector/pull/933 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-kafka-connector-0.7.x updated (25f0c4a -> dc61d7a)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch camel-kafka-connector-0.7.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. from 25f0c4a [maven-release-plugin] prepare for next development iteration new d6fc231 Upgrade docs to 0.7.1 as latest release new dc61d7a Regen The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: connectors/pom.xml | 2 +- docs/modules/ROOT/pages/connectors.adoc | 698 2 files changed, 350 insertions(+), 350 deletions(-)
[GitHub] [camel-kafka-connector] oscerd opened a new pull request #933: Update docs to 0.7.1
oscerd opened a new pull request #933: URL: https://github.com/apache/camel-kafka-connector/pull/933 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/02: Upgrade docs to 0.7.1 as latest release
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch camel-kafka-connector-0.7.x
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit d6fc231a1881fb4ae09e25d46188f1e7652e456d
Author: Andrea Cosentino
AuthorDate: Thu Jan 28 14:22:07 2021 +0100
Upgrade docs to 0.7.1 as latest release
---
connectors/pom.xml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/connectors/pom.xml b/connectors/pom.xml
index c97ec92..8cc7f28 100644
--- a/connectors/pom.xml
+++ b/connectors/pom.xml
@@ -163,7 +163,7 @@
camel-kafka-connector-docs-maven-plugin
${project.version}
-0.7.0
+0.7.1
[camel-kafka-connector] 01/02: Upgrade docs to 0.7.1 as latest release
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch 0.7.1-docs
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit f0d7d411f7c8c84e45f70ead882426f1426e2a9d
Author: Andrea Cosentino
AuthorDate: Thu Jan 28 14:22:07 2021 +0100
Upgrade docs to 0.7.1 as latest release
---
connectors/pom.xml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/connectors/pom.xml b/connectors/pom.xml
index c97ec92..8cc7f28 100644
--- a/connectors/pom.xml
+++ b/connectors/pom.xml
@@ -163,7 +163,7 @@
camel-kafka-connector-docs-maven-plugin
${project.version}
-0.7.0
+0.7.1
[camel-kafka-connector] branch 0.7.1-docs created (now 233b936)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch 0.7.1-docs in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at 233b936 Regen This branch includes the following new commits: new f0d7d41 Upgrade docs to 0.7.1 as latest release new 233b936 Regen The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[GitHub] [camel-kafka-connector] oscerd merged pull request #932: Bump docs to 0.7.1
oscerd merged pull request #932: URL: https://github.com/apache/camel-kafka-connector/pull/932 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 #932: Bump docs to 0.7.1
oscerd opened a new pull request #932: URL: https://github.com/apache/camel-kafka-connector/pull/932 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/02: Upgrade docs to 0.7.1 as latest release
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 a111609d9ada2432764c22268bd225359a511994
Author: Andrea Cosentino
AuthorDate: Thu Jan 28 14:22:07 2021 +0100
Upgrade docs to 0.7.1 as latest release
---
connectors/pom.xml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/connectors/pom.xml b/connectors/pom.xml
index e032354..52dc8a2 100644
--- a/connectors/pom.xml
+++ b/connectors/pom.xml
@@ -163,7 +163,7 @@
camel-kafka-connector-docs-maven-plugin
${project.version}
-0.7.0
+0.7.1
[camel-kafka-connector] branch master updated (513f1e2 -> 96dd421)
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 513f1e2 Added AWS v2 S3 sink test case new a111609 Upgrade docs to 0.7.1 as latest release new 96dd421 Regen The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: connectors/pom.xml | 2 +- docs/modules/ROOT/pages/connectors.adoc | 698 2 files changed, 350 insertions(+), 350 deletions(-)
[camel-kafka-connector] branch docs-0.7.1 created (now 362423d)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch docs-0.7.1 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at 362423d Regen This branch includes the following new commits: new 4833168 Upgrade docs to 0.7.1 as latest release new 362423d Regen The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[camel-kafka-connector] 01/02: Upgrade docs to 0.7.1 as latest release
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch docs-0.7.1
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 483316884ddbc7dc05d40ed7e1ca591222fc1568
Author: Andrea Cosentino
AuthorDate: Thu Jan 28 14:22:07 2021 +0100
Upgrade docs to 0.7.1 as latest release
---
connectors/pom.xml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/connectors/pom.xml b/connectors/pom.xml
index e032354..52dc8a2 100644
--- a/connectors/pom.xml
+++ b/connectors/pom.xml
@@ -163,7 +163,7 @@
camel-kafka-connector-docs-maven-plugin
${project.version}
-0.7.0
+0.7.1
[camel-spring-boot] branch master updated: Regen
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 b5daec7 Regen
b5daec7 is described below
commit b5daec7665cac4c5c4cdb2b69af3bd6508b0c572
Author: Andrea Cosentino
AuthorDate: Thu Jan 28 14:40:11 2021 +0100
Regen
---
components-starter/camel-corda-starter/pom.xml | 8
components-starter/camel-iota-starter/pom.xml | 12
tooling/camel-spring-boot-dependencies/pom.xml | 7 ++-
3 files changed, 26 insertions(+), 1 deletion(-)
diff --git a/components-starter/camel-corda-starter/pom.xml
b/components-starter/camel-corda-starter/pom.xml
index d667b96..158a2e5 100644
--- a/components-starter/camel-corda-starter/pom.xml
+++ b/components-starter/camel-corda-starter/pom.xml
@@ -41,6 +41,14 @@
+ ch.qos.logback
+ logback-classic
+
+
+ ch.qos.logback
+ logback-core
+
+
org.apache.logging.log4j
log4j-core
diff --git a/components-starter/camel-iota-starter/pom.xml
b/components-starter/camel-iota-starter/pom.xml
index 95d1ad5..758052f 100644
--- a/components-starter/camel-iota-starter/pom.xml
+++ b/components-starter/camel-iota-starter/pom.xml
@@ -38,6 +38,18 @@
org.apache.camel
camel-iota
${camel-version}
+
+
+
+ ch.qos.logback
+ logback-classic
+
+
+ ch.qos.logback
+ logback-core
+
+
+
diff --git a/tooling/camel-spring-boot-dependencies/pom.xml
b/tooling/camel-spring-boot-dependencies/pom.xml
index f53bb3b..da63c3f 100644
--- a/tooling/camel-spring-boot-dependencies/pom.xml
+++ b/tooling/camel-spring-boot-dependencies/pom.xml
@@ -159,7 +159,7 @@
io.methvin
directory-watcher
-0.12.0
+0.13.0
io.nessus
@@ -2919,6 +2919,11 @@
org.apache.camel
+camel-huaweicloud-smn
+3.8.0-SNAPSHOT
+
+
+org.apache.camel
camel-hystrix
3.8.0-SNAPSHOT
[GitHub] [camel-kafka-connector] oscerd merged pull request #931: Added AWS v2 S3 sink test case
oscerd merged pull request #931: URL: https://github.com/apache/camel-kafka-connector/pull/931 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: Added AWS v2 S3 sink test case
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 513f1e2 Added AWS v2 S3 sink test case
513f1e2 is described below
commit 513f1e2aa85aa0d71bba16abed7d97abbbe63cc1
Author: Otavio Rodolfo Piske
AuthorDate: Thu Jan 28 14:01:28 2021 +0100
Added AWS v2 S3 sink test case
---
.../kafkaconnector/aws/v2/s3/common/S3Utils.java | 97 +
.../s3/{source => common}/TestS3Configuration.java | 2 +-
.../aws/v2/s3/sink/CamelAWSS3PropertyFactory.java | 76 +++
.../aws/v2/s3/sink/CamelSinkAWSS3ITCase.java | 152 +
.../aws/v2/s3/source/CamelSourceAWSS3ITCase.java | 52 +--
5 files changed, 332 insertions(+), 47 deletions(-)
diff --git
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/s3/common/S3Utils.java
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/s3/common/S3Utils.java
new file mode 100644
index 000..25e0ec7
--- /dev/null
+++
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/s3/common/S3Utils.java
@@ -0,0 +1,97 @@
+/*
+ * 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.kafkaconnector.aws.v2.s3.common;
+
+import java.util.List;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import software.amazon.awssdk.services.s3.S3Client;
+import software.amazon.awssdk.services.s3.model.CreateBucketRequest;
+import software.amazon.awssdk.services.s3.model.DeleteBucketRequest;
+import software.amazon.awssdk.services.s3.model.DeleteObjectRequest;
+import software.amazon.awssdk.services.s3.model.ListObjectsV2Request;
+import software.amazon.awssdk.services.s3.model.ListObjectsV2Response;
+import software.amazon.awssdk.services.s3.model.S3Object;
+
+public final class S3Utils {
+private static final Logger LOG = LoggerFactory.getLogger(S3Utils.class);
+
+private S3Utils() {
+
+}
+
+public static List listObjects(S3Client s3Client, String
bucketName) {
+try {
+ListObjectsV2Request listObjectsRequest =
ListObjectsV2Request.builder()
+.bucket(bucketName)
+.build();
+
+ListObjectsV2Response objectListing =
s3Client.listObjectsV2(listObjectsRequest);
+
+return objectListing.contents();
+} catch (Exception e) {
+LOG.debug("Error listing: {}", e.getMessage(), e);
+throw e;
+}
+}
+
+/**
+ * Delete an S3 bucket using the provided client. Coming from AWS
documentation:
+ * https://docs.aws.amazon.com/AmazonS3/latest/dev/Versioning.html
+ *
+ * AWS SDK v1 doc for reference:
+ *
https://docs.aws.amazon.com/AmazonS3/latest/dev/delete-or-empty-bucket.html#delete-bucket-sdk-java
+ * @param s3Client the AmazonS3 client instance used to delete the bucket
+ * @param bucketName a String containing the bucket name
+ */
+public static void deleteBucket(S3Client s3Client, String bucketName) {
+// Delete all objects from the bucket. This is sufficient
+// for non versioned buckets. For versioned buckets, when you attempt
to delete objects, Amazon S3 inserts
+// delete markers for all objects, but doesn't delete the object
versions.
+// To delete objects from versioned buckets, delete all of the object
versions before deleting
+// the bucket (see below for an example).
+ListObjectsV2Request listObjectsRequest =
ListObjectsV2Request.builder()
+.bucket(bucketName)
+.build();
+
+ListObjectsV2Response objectListing;
+do {
+objectListing = s3Client.listObjectsV2(listObjectsRequest);
+
+for (S3Object s3Object : objectListing.contents()) {
+
s3Client.deleteObject(DeleteObjectRequest.builder().bucket(bucketName).key(s3Object.key()).build());
+}
+
+listObjectsRequest =
ListObjectsV2Request.builder().bucket(bucketName)
+
[GitHub] [camel-examples] lburgazzoli merged pull request #33: CAMEL-16080: Kamelet example
lburgazzoli merged pull request #33: URL: https://github.com/apache/camel-examples/pull/33 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: CAMEL-16080: Kamelet example
This is an automated email from the ASF dual-hosted git repository.
lburgazzoli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-examples.git
The following commit(s) were added to refs/heads/master by this push:
new 78685c4 CAMEL-16080: Kamelet example
78685c4 is described below
commit 78685c4893103df222c29c077da5464577f66880
Author: Luca Burgazzoli
AuthorDate: Wed Jan 27 17:35:16 2021 +0100
CAMEL-16080: Kamelet example
---
examples/camel-example-kamelet/pom.xml | 101 +
examples/camel-example-kamelet/readme.adoc | 25 +
.../org/apache/camel/example/MyApplication.java| 41 +
.../org/apache/camel/example/MyRouteTemplates.java | 43 +
.../java/org/apache/camel/example/MyRoutes.java| 34 +++
.../src/main/resources/application.properties | 25 +
.../src/main/resources/logback.xml | 30 ++
examples/pom.xml | 1 +
8 files changed, 300 insertions(+)
diff --git a/examples/camel-example-kamelet/pom.xml
b/examples/camel-example-kamelet/pom.xml
new file mode 100644
index 000..fb6db60
--- /dev/null
+++ b/examples/camel-example-kamelet/pom.xml
@@ -0,0 +1,101 @@
+
+
+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/maven-v4_0_0.xsd;>
+
+4.0.0
+
+
+org.apache.camel.example
+examples
+3.8.0-SNAPSHOT
+
+
+camel-example-kamelet
+jar
+Camel :: Example :: Kamelet
+How to use Kamelets
+
+
+Beginner
+
+
+
+
+
+
+org.apache.camel
+camel-bom
+${camel.version}
+pom
+import
+
+
+
+
+
+
+
+org.apache.camel
+camel-core
+
+
+org.apache.camel
+camel-main
+
+
+org.apache.camel
+camel-kamelet
+
+
+
+
+org.apache.logging.log4j
+log4j-api
+${log4j2-version}
+runtime
+
+
+ch.qos.logback
+logback-core
+${logback-version}
+
+
+ch.qos.logback
+logback-classic
+${logback-version}
+
+
+
+
+
+
+
+org.apache.camel
+camel-maven-plugin
+${camel.version}
+
+false
+
org.apache.camel.example.MyApplication
+
+
+
+
+
+
diff --git a/examples/camel-example-kamelet/readme.adoc
b/examples/camel-example-kamelet/readme.adoc
new file mode 100644
index 000..d824a42
--- /dev/null
+++ b/examples/camel-example-kamelet/readme.adoc
@@ -0,0 +1,25 @@
+== Camel Example Kamelet
+
+This examples shows how to use Route Templates (parameterized routes) to
specify a skeleton route
+which can be used for creating and adding new routes via Kamelets.
+
+The route template is defined via Java in the `MyRouteTemplates.java` source
file.
+The routes are defined via Java in the `MyRoutes.java` source file.
+
+The example runs standalone via Camel Main in the `MyApplication.java` source
file.
+
+=== How to run
+
+You can run this example using
+
+mvn camel:run
+
+=== Help and contributions
+
+If you hit any problem using Camel or have some feedback, then please
+https://camel.apache.org/support.html[let us know].
+
+We also love contributors, so
+https://camel.apache.org/contributing.html[get involved] :-)
+
+The Camel riders!
diff --git
a/examples/camel-example-kamelet/src/main/java/org/apache/camel/example/MyApplication.java
b/examples/camel-example-kamelet/src/main/java/org/apache/camel/example/MyApplication.java
new file mode 100644
index 000..f5c47d0
--- /dev/null
+++
b/examples/camel-example-kamelet/src/main/java/org/apache/camel/example/MyApplication.java
@@ -0,0 +1,41 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the
[GitHub] [camel-k] amitsadaphule commented on issue #1923: [ppc64le] bundle image generated using `bundle` and `bundle-build` targets incompatible with `opm`
amitsadaphule commented on issue #1923: URL: https://github.com/apache/camel-k/issues/1923#issuecomment-769056265 I've published the build-script for ppc64le and the documentation related to validation on Openshift at https://github.com/ppc64le/build-scripts/tree/master/c/camel-k 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] 02/02: Sync deps
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 commit 0dcbe44d35545a4fc29e5e7b0e9e687d564cbf28 Author: Andrea Cosentino AuthorDate: Thu Jan 28 14:03:04 2021 +0100 Sync deps --- camel-dependencies/pom.xml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/camel-dependencies/pom.xml b/camel-dependencies/pom.xml index 296f392..ad75201 100644 --- a/camel-dependencies/pom.xml +++ b/camel-dependencies/pom.xml @@ -374,8 +374,8 @@ 1.1.3 2.7.0 7.48.0.Final -5.0.0 -5.0.0 +5.0.1 +5.0.1 1.12.0 5.1.0.RELEASE 0.10
