[GitHub] [camel] aryankoul commented on pull request #4697: [CAMEL-15341] Create camel-azure-storage-datalake to serve Azure DataLakes Gen2
aryankoul commented on pull request #4697: URL: https://github.com/apache/camel/pull/4697#issuecomment-765885449 > LGTM! Thank you @aryankoul ! > Once this is merged, the next step to create the Spring boot starter in camel-spring-boot and if you have time, would be great if you can add an example demonstrate the component in the camel-examples repo, you can re-use [this](https://github.com/apache/camel-examples/tree/master/examples/camel-example-debezium-eventhubs-blob) example for datalake component. > > Let's see if others have any other comments cc @davsclaus @oscerd > > P/S: there are some conflicts, can you please resolve them? thanks Thanks @omarsmak! Sure, i'll look into the camel-examples repo. 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] jam01 opened a new pull request #4914: implement logging mdc support CAMEL-12879
jam01 opened a new pull request #4914: URL: https://github.com/apache/camel/pull/4914 Adds traceId and spanId string methods to SpanAdapter Adds and replaces MDC fields when activating, deactivating a span Bumps opentracing to 0.33.0 Note, there was a warning in the parent pom ``` cannot upgrade opentracing until https://github.com/eclipse/microprofile-opentracing v2 is released ``` microprofile-opentracing v2 was released about a month ago, however I could not find the dependencies to that artifact, so I'm not sure if there's anything else that needs to be changed 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] opened a new issue #2161: [CI] - Quarkus Master Branch Build Failure
github-actions[bot] opened a new issue #2161: URL: https://github.com/apache/camel-quarkus/issues/2161 The [quarkus-master](https://github.com/apache/camel-quarkus/tree/quarkus-master) branch build is failing: * Build ID: 505141649-275-574c551b-b19c-41c6-beba-82e5374576a1 * Camel Quarkus Commit: c8a1cb349500723062590d7ef20eddef216cc4a8 * Quarkus Master Commit: 6023d9f17f419bf2f8c84953568d0e56de3ddb37 * Link to build: https://github.com/apache/camel-quarkus/actions/runs/505141649 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-spring-boot] github-actions[bot] opened a new pull request #264: [Github Actions] Periodic Sync Camel Spring Boot Master Branch
github-actions[bot] opened a new pull request #264: URL: https://github.com/apache/camel-spring-boot/pull/264 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-spring-boot] branch automatic-periodic-sync updated (9e20a9c -> 47eb193)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch automatic-periodic-sync in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git. omit 9e20a9c [create-pull-request] automated change add a68e59a [create-pull-request] automated change add 7387004 Polished add 47eb193 [create-pull-request] automated change This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (9e20a9c) \ N -- N -- N refs/heads/automatic-periodic-sync (47eb193) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: .../resources/org/apache/camel/springboot/catalog/components/jslt.json | 1 + components-starter/pom.xml | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-)
[camel] branch regen_bot updated (e625a7f -> 8878b36)
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 e625a7f (chores) avoid catching Throwable as it can lead to
unexpected (#4911)
add c8604fd CAMEL-16061 - JSLT-Component: Object-Mapper changes large
Decimal-Numbers (to scientific notation)
add 8878b36 Regen catalog
No new revisions were added by this update.
Summary of changes:
.../org/apache/camel/catalog/components/jslt.json | 1 +
.../apache/camel/catalog/docs/jslt-component.adoc | 3 +-
.../component/jslt/JsltEndpointConfigurer.java | 6
.../component/jslt/JsltEndpointUriFactory.java | 3 +-
.../org/apache/camel/component/jslt/jslt.json | 1 +
.../camel-jslt/src/main/docs/jslt-component.adoc | 3 +-
.../apache/camel/component/jslt/JsltEndpoint.java | 16 ++
...jectFilterTest.java => JsltBigDecimalTest.java} | 8 ++---
.../{objectFilter => useBigDecimal}/input.json | 4 +--
.../camel/component/jslt/useBigDecimal/output.json | 10 +++
.../jslt/useBigDecimal/transformation.json | 3 ++
.../endpoint/dsl/JsltEndpointBuilderFactory.java | 35 ++
.../modules/ROOT/pages/jslt-component.adoc | 3 +-
13 files changed, 86 insertions(+), 10 deletions(-)
copy
components/camel-jslt/src/test/java/org/apache/camel/component/jslt/{JsltObjectFilterTest.java
=> JsltBigDecimalTest.java} (93%)
copy
components/camel-jslt/src/test/resources/org/apache/camel/component/jslt/{objectFilter
=> useBigDecimal}/input.json (56%)
create mode 100644
components/camel-jslt/src/test/resources/org/apache/camel/component/jslt/useBigDecimal/output.json
create mode 100644
components/camel-jslt/src/test/resources/org/apache/camel/component/jslt/useBigDecimal/transformation.json
[camel] 01/02: CAMEL-16061 - JSLT-Component: Object-Mapper changes large Decimal-Numbers (to scientific notation)
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 c8604fd2eec9d66943b409d3d0a0d8ad7785a572 Author: Andrea Cosentino AuthorDate: Fri Jan 22 22:44:05 2021 +0100 CAMEL-16061 - JSLT-Component: Object-Mapper changes large Decimal-Numbers (to scientific notation) --- .../apache/camel/catalog/docs/jslt-component.adoc | 3 +- .../component/jslt/JsltEndpointConfigurer.java | 6 ++ .../component/jslt/JsltEndpointUriFactory.java | 3 +- .../org/apache/camel/component/jslt/jslt.json | 1 + .../camel-jslt/src/main/docs/jslt-component.adoc | 3 +- .../apache/camel/component/jslt/JsltEndpoint.java | 16 + .../camel/component/jslt/JsltBigDecimalTest.java | 75 ++ .../camel/component/jslt/useBigDecimal/input.json | 13 .../camel/component/jslt/useBigDecimal/output.json | 10 +++ .../jslt/useBigDecimal/transformation.json | 3 + .../endpoint/dsl/JsltEndpointBuilderFactory.java | 35 ++ .../modules/ROOT/pages/jslt-component.adoc | 3 +- 12 files changed, 167 insertions(+), 4 deletions(-) diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/jslt-component.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/jslt-component.adoc index 28b75d0..7924a76 100644 --- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/jslt-component.adoc +++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/jslt-component.adoc @@ -90,7 +90,7 @@ with the following path and query parameters: |=== -=== Query Parameters (5 parameters): +=== Query Parameters (6 parameters): [width="100%",cols="2,5,^1,2",options="header"] @@ -99,6 +99,7 @@ with the following path and query parameters: | *allowContextMapAll* (producer) | Sets whether the context map should allow access to all details. By default only the message body and headers can be accessed. This option can be enabled for full access to the current Exchange and CamelContext. Doing so impose a potential security risk as this opens access to the full power of CamelContext API. | false | boolean | *allowTemplateFromHeader* (producer) | Whether to allow to use resource template from header or not (default false). Enabling this allows to specify dynamic templates via message header. However this can be seen as a potential security vulnerability if the header is coming from a malicious user, so use this with care. | false | boolean | *contentCache* (producer) | Sets whether to use resource content cache or not | false | boolean +| *mapBigDecimalAsFloats* (producer) | If true, the mapper will use the USE_BIG_DECIMAL_FOR_FLOATS in serialization features | false | boolean | *prettyPrint* (common) | If true, JSON in output message is pretty printed. | false | boolean | *lazyStartProducer* (producer) | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and [...] |=== diff --git a/components/camel-jslt/src/generated/java/org/apache/camel/component/jslt/JsltEndpointConfigurer.java b/components/camel-jslt/src/generated/java/org/apache/camel/component/jslt/JsltEndpointConfigurer.java index 9492314..f375445 100644 --- a/components/camel-jslt/src/generated/java/org/apache/camel/component/jslt/JsltEndpointConfigurer.java +++ b/components/camel-jslt/src/generated/java/org/apache/camel/component/jslt/JsltEndpointConfigurer.java @@ -29,6 +29,8 @@ public class JsltEndpointConfigurer extends PropertyConfigurerSupport implements case "contentCache": target.setContentCache(property(camelContext, boolean.class, value)); return true; case "lazystartproducer": case "lazyStartProducer": target.setLazyStartProducer(property(camelContext, boolean.class, value)); return true; +case "mapbigdecimalasfloats": +case "mapBigDecimalAsFloats": target.setMapBigDecimalAsFloats(property(camelContext, boolean.class, value)); return true; case "prettyprint": case "prettyPrint": target.setPrettyPrint(property(camelContext, boolean.class, value)); return true; default: return false; @@ -46,6 +48,8 @@ public class JsltEndpointConfigurer extends PropertyConfigurerSupport implements case "contentCache": return boolean.class; case "lazystartproducer": case "lazyStartProducer": return boolean.class; +case "mapbigdecimalasfloats": +case "mapBigDecimalAsFloats":
[camel] branch master updated (e625a7f -> 8878b36)
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 e625a7f (chores) avoid catching Throwable as it can lead to
unexpected (#4911)
new c8604fd CAMEL-16061 - JSLT-Component: Object-Mapper changes large
Decimal-Numbers (to scientific notation)
new 8878b36 Regen catalog
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/camel/catalog/components/jslt.json | 1 +
.../apache/camel/catalog/docs/jslt-component.adoc | 3 +-
.../component/jslt/JsltEndpointConfigurer.java | 6
.../component/jslt/JsltEndpointUriFactory.java | 3 +-
.../org/apache/camel/component/jslt/jslt.json | 1 +
.../camel-jslt/src/main/docs/jslt-component.adoc | 3 +-
.../apache/camel/component/jslt/JsltEndpoint.java | 16 ++
...jectFilterTest.java => JsltBigDecimalTest.java} | 8 ++---
.../{objectFilter => useBigDecimal}/input.json | 4 +--
.../camel/component/jslt/useBigDecimal/output.json | 10 +++
.../jslt/useBigDecimal/transformation.json | 3 ++
.../endpoint/dsl/JsltEndpointBuilderFactory.java | 35 ++
.../modules/ROOT/pages/jslt-component.adoc | 3 +-
13 files changed, 86 insertions(+), 10 deletions(-)
copy
components/camel-jslt/src/test/java/org/apache/camel/component/jslt/{JsltObjectFilterTest.java
=> JsltBigDecimalTest.java} (93%)
copy
components/camel-jslt/src/test/resources/org/apache/camel/component/jslt/{objectFilter
=> useBigDecimal}/input.json (56%)
create mode 100644
components/camel-jslt/src/test/resources/org/apache/camel/component/jslt/useBigDecimal/output.json
create mode 100644
components/camel-jslt/src/test/resources/org/apache/camel/component/jslt/useBigDecimal/transformation.json
[camel] 02/02: 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 8878b362ce8579e7fecc20a9d8df89505543f44a
Author: Andrea Cosentino
AuthorDate: Fri Jan 22 22:48:41 2021 +0100
Regen catalog
---
.../generated/resources/org/apache/camel/catalog/components/jslt.json| 1 +
1 file changed, 1 insertion(+)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/jslt.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/jslt.json
index 434b9cd..e2a5dd2 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/jslt.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/jslt.json
@@ -33,6 +33,7 @@
"allowContextMapAll": { "kind": "parameter", "displayName": "Allow Context
Map All", "group": "producer", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Sets whether the
context map should allow access to all details. By default only the message
body and headers can be accessed. This option can be enabled for full access to
the current Exchange and CamelContext. [...]
"allowTemplateFromHeader": { "kind": "parameter", "displayName": "Allow
Template From Header", "group": "producer", "label": "", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "description": "Whether to allow
to use resource template from header or not (default false). Enabling this
allows to specify dynamic templates via message header. However this can be
seen as a potential security vuln [...]
"contentCache": { "kind": "parameter", "displayName": "Content Cache",
"group": "producer", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "description": "Sets whether to use resource
content cache or not" },
+"mapBigDecimalAsFloats": { "kind": "parameter", "displayName": "Map Big
Decimal As Floats", "group": "producer", "label": "", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "description": "If true, the
mapper will use the USE_BIG_DECIMAL_FOR_FLOATS in serialization features" },
"prettyPrint": { "kind": "parameter", "displayName": "Pretty Print",
"group": "common", "label": "common", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "description": "If true, JSON in output message
is pretty printed." },
"lazyStartProducer": { "kind": "parameter", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during sta [...]
}
[GitHub] [camel] attrobit commented on a change in pull request #4909: camel-milo: added possibility to read node values via producer.
attrobit commented on a change in pull request #4909:
URL: https://github.com/apache/camel/pull/4909#discussion_r562876321
##
File path:
components/camel-milo/src/main/java/org/apache/camel/component/milo/client/MiloClientProducer.java
##
@@ -53,7 +57,15 @@ public boolean process(Exchange exchange, AsyncCallback
async) {
final CompletableFuture future;
-if (this.methodId == null) {
+if (msg.getHeaders().containsKey(HEADER_NODE_IDS)) {
Review comment:
done.
##
File path:
components/camel-milo/src/test/java/org/apache/camel/component/milo/ReadValuesClientTest.java
##
@@ -0,0 +1,66 @@
+package org.apache.camel.component.milo;
Review comment:
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
[GitHub] [camel] attrobit commented on a change in pull request #4909: camel-milo: added possibility to read node values via producer.
attrobit commented on a change in pull request #4909: URL: https://github.com/apache/camel/pull/4909#discussion_r562876505 ## File path: components/camel-milo/src/main/java/org/apache/camel/component/milo/client/MiloClientProducer.java ## @@ -35,6 +37,8 @@ private final boolean defaultAwaitWrites; +private static final String HEADER_NODE_IDS = "opcua.nodeIds"; Review comment: changed it to CamelMilo.nodeIds This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-k-runtime] branch master updated: Fixes #589, fix kamelet-reify component scheme in CamelK catalog
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-k-runtime.git
The following commit(s) were added to refs/heads/master by this push:
new ab7f0dc Fixes #589, fix kamelet-reify component scheme in CamelK
catalog
ab7f0dc is described below
commit ab7f0dce6854f6e4590798406a9689919d5076ec
Author: Dhiraj Bokde
AuthorDate: Thu Jan 21 23:27:17 2021 -0800
Fixes #589, fix kamelet-reify component scheme in CamelK catalog
---
support/camel-k-maven-plugin/src/it/generate-catalog/verify.groovy | 2 +-
.../org/apache/camel/k/tooling/maven/processors/CatalogProcessor3x.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/support/camel-k-maven-plugin/src/it/generate-catalog/verify.groovy
b/support/camel-k-maven-plugin/src/it/generate-catalog/verify.groovy
index 1e90f10..5ca2797 100644
--- a/support/camel-k-maven-plugin/src/it/generate-catalog/verify.groovy
+++ b/support/camel-k-maven-plugin/src/it/generate-catalog/verify.groovy
@@ -83,7 +83,7 @@ new File(basedir, "catalog.yaml").withReader {
assert schemes.size() == 1
schemes[0].with {
-assert id == 'wrap'
+assert id == 'kamelet-reify'
assert passive == false
assert http == false
}
diff --git
a/support/camel-k-maven-plugin/src/main/java/org/apache/camel/k/tooling/maven/processors/CatalogProcessor3x.java
b/support/camel-k-maven-plugin/src/main/java/org/apache/camel/k/tooling/maven/processors/CatalogProcessor3x.java
index d4974e4..bb239a2 100644
---
a/support/camel-k-maven-plugin/src/main/java/org/apache/camel/k/tooling/maven/processors/CatalogProcessor3x.java
+++
b/support/camel-k-maven-plugin/src/main/java/org/apache/camel/k/tooling/maven/processors/CatalogProcessor3x.java
@@ -171,7 +171,7 @@ public class CatalogProcessor3x implements CatalogProcessor
{
.groupId("org.apache.camel.k")
.artifactId("camel-k-kamelet-reify")
.addScheme(new CamelScheme.Builder()
-.id("wrap")
+.id("kamelet-reify")
.build())
.build()
);
[GitHub] [camel-k-runtime] lburgazzoli closed issue #589: Fix missing wrap component error in camelk catalog
lburgazzoli closed issue #589: URL: https://github.com/apache/camel-k-runtime/issues/589 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-runtime] lburgazzoli merged pull request #590: Fixes #589, fixed kamelet-reify component scheme in CamelK catalog
lburgazzoli merged pull request #590: URL: https://github.com/apache/camel-k-runtime/pull/590 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-runtime] dhirajsb commented on pull request #590: Fixes #589, fixed kamelet-reify component scheme in CamelK catalog
dhirajsb commented on pull request #590: URL: https://github.com/apache/camel-k-runtime/pull/590#issuecomment-765590576 @lburgazzoli ok, but it also looks like this change needs to go in to make sure the catalog uses correct scheme name. 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 merged pull request #1940: fix(ci): Use AdoptOpenJDK/install-jdk@v1 action
astefanutti merged pull request #1940: URL: https://github.com/apache/camel-k/pull/1940 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 release-1.3.x updated: fix(ci): Use AdoptOpenJDK/install-jdk@v1 action
This is an automated email from the ASF dual-hosted git repository.
astefanutti pushed a commit to branch release-1.3.x
in repository https://gitbox.apache.org/repos/asf/camel-k.git
The following commit(s) were added to refs/heads/release-1.3.x by this push:
new 5fee3e7 fix(ci): Use AdoptOpenJDK/install-jdk@v1 action
5fee3e7 is described below
commit 5fee3e7568df14dcebf0ef5ac30e19b3c4f67756
Author: Antonin Stefanutti
AuthorDate: Tue Jan 12 13:05:25 2021 +0100
fix(ci): Use AdoptOpenJDK/install-jdk@v1 action
---
.github/workflows/build.yml | 4 ++--
.github/workflows/builder.yml| 4 ++--
.github/workflows/knative.yml| 8
.github/workflows/kubernetes.yml | 4 ++--
.github/workflows/local.yml | 4 ++--
.github/workflows/openshift.yml | 4 ++--
.github/workflows/release.yml| 4 ++--
7 files changed, 16 insertions(+), 16 deletions(-)
diff --git a/.github/workflows/build.yml b/.github/workflows/build.yml
index b0d087f..5ca0114 100644
--- a/.github/workflows/build.yml
+++ b/.github/workflows/build.yml
@@ -46,9 +46,9 @@ jobs:
runs-on: ${{ matrix.os }}
steps:
- name: Set up JDK 11
- uses: joschi/setup-jdk@v2
+ uses: AdoptOpenJDK/install-jdk@v1
with:
-java-version: "11"
+version: "11"
- name: Install Go
uses: actions/setup-go@v1
with:
diff --git a/.github/workflows/builder.yml b/.github/workflows/builder.yml
index 9a33caf..59230db 100644
--- a/.github/workflows/builder.yml
+++ b/.github/workflows/builder.yml
@@ -64,9 +64,9 @@ jobs:
echo "Final status:"
df -h
- name: Set up JDK 11
- uses: joschi/setup-jdk@v2
+ uses: AdoptOpenJDK/install-jdk@v1
with:
-java-version: "11"
+version: "11"
- name: Set Go
uses: actions/setup-go@v1
with:
diff --git a/.github/workflows/knative.yml b/.github/workflows/knative.yml
index 1a6406e..7380641 100644
--- a/.github/workflows/knative.yml
+++ b/.github/workflows/knative.yml
@@ -58,9 +58,9 @@ jobs:
echo "Final status:"
df -h
- name: Set up JDK 11
- uses: joschi/setup-jdk@v2
+ uses: AdoptOpenJDK/install-jdk@v1
with:
-java-version: "11"
+version: "11"
- name: Set Go
uses: actions/setup-go@v1
with:
@@ -169,9 +169,9 @@ jobs:
echo "Final status:"
df -h
- name: Set up JDK 11
-uses: joschi/setup-jdk@v2
+uses: AdoptOpenJDK/install-jdk@v1
with:
- java-version: "11"
+ version: "11"
- name: Set Go
uses: actions/setup-go@v1
with:
diff --git a/.github/workflows/kubernetes.yml b/.github/workflows/kubernetes.yml
index 8a9f919..2401352 100644
--- a/.github/workflows/kubernetes.yml
+++ b/.github/workflows/kubernetes.yml
@@ -60,9 +60,9 @@ jobs:
echo "Final status:"
df -h
- name: Set up JDK 11
- uses: joschi/setup-jdk@v2
+ uses: AdoptOpenJDK/install-jdk@v1
with:
-java-version: "11"
+version: "11"
- name: Set Go
uses: actions/setup-go@v1
with:
diff --git a/.github/workflows/local.yml b/.github/workflows/local.yml
index 6d9c9d1..2b25e66 100644
--- a/.github/workflows/local.yml
+++ b/.github/workflows/local.yml
@@ -60,9 +60,9 @@ jobs:
echo "Final status:"
df -h
- name: Set up JDK 11
- uses: joschi/setup-jdk@v2
+ uses: AdoptOpenJDK/install-jdk@v1
with:
-java-version: "11"
+version: "11"
- name: Set Go
uses: actions/setup-go@v1
with:
diff --git a/.github/workflows/openshift.yml b/.github/workflows/openshift.yml
index 9370855..beb44e8 100644
--- a/.github/workflows/openshift.yml
+++ b/.github/workflows/openshift.yml
@@ -60,9 +60,9 @@ jobs:
echo "Final status:"
df -h
- name: Set up JDK 11
- uses: joschi/setup-jdk@v2
+ uses: AdoptOpenJDK/install-jdk@v1
with:
-java-version: "11"
+version: "11"
- name: Set Go
uses: actions/setup-go@v1
with:
diff --git a/.github/workflows/release.yml b/.github/workflows/release.yml
index 35ebcee..67f0b77 100644
--- a/.github/workflows/release.yml
+++ b/.github/workflows/release.yml
@@ -27,9 +27,9 @@ jobs:
runs-on: ubuntu-latest
steps:
- name: Set up JDK 11
- uses: joschi/setup-jdk@v2
+ uses: AdoptOpenJDK/install-jdk@v1
with:
-java-version: "11"
+version: "11"
- name: Install Go
uses: actions/setup-go@v1
with:
[GitHub] [camel-k-runtime] nicolaferraro commented on issue #592: Catalog contains duplicate entry for same schema (cron)
nicolaferraro commented on issue #592: URL: https://github.com/apache/camel-k-runtime/issues/592#issuecomment-765574553 > is that true also for the master component ? Yes. I think we can add a guard to fail in case of duplicate schemas. Also for master the capability contains reference to the runtime part. 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 commented on issue #1939: Flaky e2e test (cron-fallback)
nicolaferraro commented on issue #1939: URL: https://github.com/apache/camel-k/issues/1939#issuecomment-765573246 Yeah, that's why restarting CI 2-3 times was working XD 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-runtime] lburgazzoli commented on issue #592: Catalog contains duplicate entry for same schema (cron)
lburgazzoli commented on issue #592: URL: https://github.com/apache/camel-k-runtime/issues/592#issuecomment-765569748 is that true also for the master component ? 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 pull request #917: Upgrade to 3.7.1 and regen
oscerd closed pull request #917: URL: https://github.com/apache/camel-kafka-connector/pull/917 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 #917: Upgrade to 3.7.1 and regen
oscerd commented on pull request #917: URL: https://github.com/apache/camel-kafka-connector/pull/917#issuecomment-765566344 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 opened a new pull request #917: Upgrade to 3.7.1 and regen
oscerd opened a new pull request #917: URL: https://github.com/apache/camel-kafka-connector/pull/917 Related to #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-kafka-connector] 01/01: Upgrade to 3.7.1 and regen
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch 3.7.1 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 53a1b6b7e03599fe9ecfcc29b4c24c1c0a573a7b Author: Andrea Cosentino AuthorDate: Fri Jan 22 18:20:21 2021 +0100 Upgrade to 3.7.1 and regen --- .../resources/connectors/camel-activemq-sink.json | 2 +- .../resources/connectors/camel-activemq-source.json| 2 +- .../src/generated/resources/connectors/camel-ahc-sink.json | 2 +- .../generated/resources/connectors/camel-ahc-ws-sink.json | 2 +- .../resources/connectors/camel-ahc-ws-source.json | 2 +- .../generated/resources/connectors/camel-ahc-wss-sink.json | 2 +- .../resources/connectors/camel-ahc-wss-source.json | 2 +- .../generated/resources/connectors/camel-amqp-sink.json| 2 +- .../generated/resources/connectors/camel-amqp-source.json | 2 +- .../generated/resources/connectors/camel-apns-sink.json| 2 +- .../generated/resources/connectors/camel-apns-source.json | 2 +- .../resources/connectors/camel-arangodb-sink.json | 2 +- .../src/generated/resources/connectors/camel-as2-sink.json | 2 +- .../generated/resources/connectors/camel-as2-source.json | 2 +- .../resources/connectors/camel-asterisk-sink.json | 2 +- .../resources/connectors/camel-asterisk-source.json| 2 +- .../resources/connectors/camel-atlasmap-sink.json | 2 +- .../generated/resources/connectors/camel-atmos-sink.json | 2 +- .../generated/resources/connectors/camel-atmos-source.json | 2 +- .../connectors/camel-atmosphere-websocket-sink.json| 2 +- .../connectors/camel-atmosphere-websocket-source.json | 2 +- .../generated/resources/connectors/camel-atom-source.json | 2 +- .../resources/connectors/camel-atomix-map-sink.json| 2 +- .../resources/connectors/camel-atomix-map-source.json | 2 +- .../resources/connectors/camel-atomix-messaging-sink.json | 2 +- .../connectors/camel-atomix-messaging-source.json | 2 +- .../resources/connectors/camel-atomix-multimap-sink.json | 2 +- .../resources/connectors/camel-atomix-queue-sink.json | 2 +- .../resources/connectors/camel-atomix-queue-source.json| 2 +- .../resources/connectors/camel-atomix-set-sink.json| 2 +- .../resources/connectors/camel-atomix-set-source.json | 2 +- .../resources/connectors/camel-atomix-value-sink.json | 2 +- .../resources/connectors/camel-atomix-value-source.json| 2 +- .../generated/resources/connectors/camel-avro-sink.json| 2 +- .../generated/resources/connectors/camel-avro-source.json | 2 +- .../generated/resources/connectors/camel-aws-cw-sink.json | 2 +- .../generated/resources/connectors/camel-aws-ddb-sink.json | 2 +- .../resources/connectors/camel-aws-ddbstream-source.json | 2 +- .../generated/resources/connectors/camel-aws-ec2-sink.json | 2 +- .../generated/resources/connectors/camel-aws-ecs-sink.json | 2 +- .../generated/resources/connectors/camel-aws-eks-sink.json | 2 +- .../generated/resources/connectors/camel-aws-iam-sink.json | 2 +- .../connectors/camel-aws-kinesis-firehose-sink.json| 2 +- .../resources/connectors/camel-aws-kinesis-sink.json | 2 +- .../resources/connectors/camel-aws-kinesis-source.json | 2 +- .../generated/resources/connectors/camel-aws-kms-sink.json | 2 +- .../resources/connectors/camel-aws-lambda-sink.json| 2 +- .../generated/resources/connectors/camel-aws-mq-sink.json | 2 +- .../generated/resources/connectors/camel-aws-msk-sink.json | 2 +- .../generated/resources/connectors/camel-aws-s3-sink.json | 2 +- .../resources/connectors/camel-aws-s3-source.json | 2 +- .../generated/resources/connectors/camel-aws-sdb-sink.json | 2 +- .../generated/resources/connectors/camel-aws-ses-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sns-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sqs-sink.json | 2 +- .../resources/connectors/camel-aws-sqs-source.json | 2 +- .../generated/resources/connectors/camel-aws-swf-sink.json | 2 +- .../resources/connectors/camel-aws-swf-source.json | 2 +- .../resources/connectors/camel-aws-translate-sink.json | 2 +- .../resources/connectors/camel-aws2-athena-sink.json | 2 +- .../generated/resources/connectors/camel-aws2-cw-sink.json | 2 +- .../resources/connectors/camel-aws2-ddb-sink.json | 2 +- .../resources/connectors/camel-aws2-ddbstream-source.json | 2 +- .../resources/connectors/camel-aws2-ec2-sink.json | 2 +- .../resources/connectors/camel-aws2-ecs-sink.json | 2 +- .../resources/connectors/camel-aws2-eks-sink.json | 2 +- .../resources/connectors/camel-aws2-eventbridge-sink.json | 2 +- .../resources/connectors/camel-aws2-iam-sink.json | 14 +++---
[camel-kafka-connector] branch 3.7.1 created (now 53a1b6b)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch 3.7.1 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at 53a1b6b Upgrade to 3.7.1 and regen This branch includes the following new commits: new 53a1b6b Upgrade to 3.7.1 and regen The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[GitHub] [camel-k] astefanutti commented on issue #1939: Flaky e2e test (cron-fallback)
astefanutti commented on issue #1939: URL: https://github.com/apache/camel-k/issues/1939#issuecomment-765563718 And you've just cut the project CI budget by half ! 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 #1939: Flaky e2e test (cron-fallback)
astefanutti commented on issue #1939: URL: https://github.com/apache/camel-k/issues/1939#issuecomment-765563180 The needle in the haystack . That was too much cron dependencies for me :) 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 merged pull request #1938: Backport fix #1936: avoid patching if the target resource contains all expecte…
nicolaferraro merged pull request #1938: URL: https://github.com/apache/camel-k/pull/1938 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 release-1.3.x updated: Fix #1936: avoid patching if the target resource contains all expected fields
This is an automated email from the ASF dual-hosted git repository.
nferraro pushed a commit to branch release-1.3.x
in repository https://gitbox.apache.org/repos/asf/camel-k.git
The following commit(s) were added to refs/heads/release-1.3.x by this push:
new 0148fea Fix #1936: avoid patching if the target resource contains all
expected fields
0148fea is described below
commit 0148fea36b93d84125e5a7c3098036bb1dde79b4
Author: nicolaferraro
AuthorDate: Fri Jan 22 13:28:23 2021 +0100
Fix #1936: avoid patching if the target resource contains all expected
fields
---
pkg/trait/builder.go | 2 ++
pkg/trait/deployer.go| 28
pkg/trait/trait_types.go | 5 +
pkg/util/patch/patch.go | 20
4 files changed, 43 insertions(+), 12 deletions(-)
diff --git a/pkg/trait/builder.go b/pkg/trait/builder.go
index bdf9d42..3fa45d7 100644
--- a/pkg/trait/builder.go
+++ b/pkg/trait/builder.go
@@ -485,6 +485,7 @@ func mountRegistrySecret(name string, secret
registrySecret, volumes *[]corev1.V
*volumeMounts = append(*volumeMounts, corev1.VolumeMount{
Name: "registry-secret",
MountPath: secret.mountPath,
+ ReadOnly: true,
})
if secret.refEnv != "" {
@@ -530,6 +531,7 @@ func mountRegistryConfigMap(name string, config
registryConfigMap, volumes *[]co
*volumeMounts = append(*volumeMounts, corev1.VolumeMount{
Name: "registry-config",
MountPath: config.mountPath,
+ ReadOnly: true,
})
}
diff --git a/pkg/trait/deployer.go b/pkg/trait/deployer.go
index b3cf394..81aaee8 100644
--- a/pkg/trait/deployer.go
+++ b/pkg/trait/deployer.go
@@ -19,7 +19,6 @@ package trait
import (
"github.com/pkg/errors"
-
"k8s.io/apimachinery/pkg/types"
"sigs.k8s.io/controller-runtime/pkg/client"
@@ -95,17 +94,22 @@ func (t *deployerTrait) Apply(e *Environment) error {
return err
}
- p, err := patch.PositiveMergePatch(object,
resource)
- if err != nil {
- return err
- } else if len(p) == 0 {
- // Avoid triggering a patch request for
nothing
- continue
- }
-
- err = env.Client.Patch(env.C, resource,
client.RawPatch(types.MergePatchType, p))
- if err != nil {
- return errors.Wrap(err, "error during
patch resource")
+ if !patch.SpecEqualDeepDerivative(object,
resource) {
+ // If both objects have a "Spec" field
and it contains all expected fields
+ // (plus optional others), then avoid
patching
+
+ p, err :=
patch.PositiveMergePatch(object, resource)
+ if err != nil {
+ return err
+ } else if len(p) == 0 {
+ // Avoid triggering a patch
request for nothing
+ continue
+ }
+
+ err = env.Client.Patch(env.C, resource,
client.RawPatch(types.MergePatchType, p))
+ if err != nil {
+ return errors.Wrap(err, "error
during patch resource")
+ }
}
}
return nil
diff --git a/pkg/trait/trait_types.go b/pkg/trait/trait_types.go
index 8343fb9..f28fc8f 100644
--- a/pkg/trait/trait_types.go
+++ b/pkg/trait/trait_types.go
@@ -559,6 +559,7 @@ func (e *Environment) ConfigureVolumesAndMounts(vols
*[]corev1.Volume, mnts *[]c
*mnts = append(*mnts, corev1.VolumeMount{
Name: refName,
MountPath: resPath,
+ ReadOnly: true,
})
}
@@ -603,6 +604,7 @@ func (e *Environment) ConfigureVolumesAndMounts(vols
*[]corev1.Volume, mnts *[]c
*mnts = append(*mnts, corev1.VolumeMount{
Name: refName,
MountPath: resPath,
+ ReadOnly: true,
})
}
@@ -639,6 +641,7 @@ func (e *Environment) ConfigureVolumesAndMounts(vols
*[]corev1.Volume, mnts *[]c
*mnts = append(*mnts, corev1.VolumeMount{
Name: propertiesType +
[camel-k] branch master updated: Fix #1936: avoid patching if the target resource contains all expected fields
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 3b992da Fix #1936: avoid patching if the target resource contains all
expected fields
3b992da is described below
commit 3b992dacb1bf81d781a263dbc1b12ee7d0ffcfef
Author: nicolaferraro
AuthorDate: Fri Jan 22 13:28:23 2021 +0100
Fix #1936: avoid patching if the target resource contains all expected
fields
---
pkg/trait/builder.go | 2 ++
pkg/trait/deployer.go| 28
pkg/trait/trait_types.go | 5 +
pkg/util/patch/patch.go | 20
4 files changed, 43 insertions(+), 12 deletions(-)
diff --git a/pkg/trait/builder.go b/pkg/trait/builder.go
index bdf9d42..3fa45d7 100644
--- a/pkg/trait/builder.go
+++ b/pkg/trait/builder.go
@@ -485,6 +485,7 @@ func mountRegistrySecret(name string, secret
registrySecret, volumes *[]corev1.V
*volumeMounts = append(*volumeMounts, corev1.VolumeMount{
Name: "registry-secret",
MountPath: secret.mountPath,
+ ReadOnly: true,
})
if secret.refEnv != "" {
@@ -530,6 +531,7 @@ func mountRegistryConfigMap(name string, config
registryConfigMap, volumes *[]co
*volumeMounts = append(*volumeMounts, corev1.VolumeMount{
Name: "registry-config",
MountPath: config.mountPath,
+ ReadOnly: true,
})
}
diff --git a/pkg/trait/deployer.go b/pkg/trait/deployer.go
index b3cf394..81aaee8 100644
--- a/pkg/trait/deployer.go
+++ b/pkg/trait/deployer.go
@@ -19,7 +19,6 @@ package trait
import (
"github.com/pkg/errors"
-
"k8s.io/apimachinery/pkg/types"
"sigs.k8s.io/controller-runtime/pkg/client"
@@ -95,17 +94,22 @@ func (t *deployerTrait) Apply(e *Environment) error {
return err
}
- p, err := patch.PositiveMergePatch(object,
resource)
- if err != nil {
- return err
- } else if len(p) == 0 {
- // Avoid triggering a patch request for
nothing
- continue
- }
-
- err = env.Client.Patch(env.C, resource,
client.RawPatch(types.MergePatchType, p))
- if err != nil {
- return errors.Wrap(err, "error during
patch resource")
+ if !patch.SpecEqualDeepDerivative(object,
resource) {
+ // If both objects have a "Spec" field
and it contains all expected fields
+ // (plus optional others), then avoid
patching
+
+ p, err :=
patch.PositiveMergePatch(object, resource)
+ if err != nil {
+ return err
+ } else if len(p) == 0 {
+ // Avoid triggering a patch
request for nothing
+ continue
+ }
+
+ err = env.Client.Patch(env.C, resource,
client.RawPatch(types.MergePatchType, p))
+ if err != nil {
+ return errors.Wrap(err, "error
during patch resource")
+ }
}
}
return nil
diff --git a/pkg/trait/trait_types.go b/pkg/trait/trait_types.go
index 8343fb9..f28fc8f 100644
--- a/pkg/trait/trait_types.go
+++ b/pkg/trait/trait_types.go
@@ -559,6 +559,7 @@ func (e *Environment) ConfigureVolumesAndMounts(vols
*[]corev1.Volume, mnts *[]c
*mnts = append(*mnts, corev1.VolumeMount{
Name: refName,
MountPath: resPath,
+ ReadOnly: true,
})
}
@@ -603,6 +604,7 @@ func (e *Environment) ConfigureVolumesAndMounts(vols
*[]corev1.Volume, mnts *[]c
*mnts = append(*mnts, corev1.VolumeMount{
Name: refName,
MountPath: resPath,
+ ReadOnly: true,
})
}
@@ -639,6 +641,7 @@ func (e *Environment) ConfigureVolumesAndMounts(vols
*[]corev1.Volume, mnts *[]c
*mnts = append(*mnts, corev1.VolumeMount{
Name: propertiesType +
"-properties",
[GitHub] [camel-k] nicolaferraro merged pull request #1937: Fix #1936: avoid patching if the target resource contains all expecte…
nicolaferraro merged pull request #1937: URL: https://github.com/apache/camel-k/pull/1937 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 #1936: SinkBinding on KSVC results into ping-pong between operators
nicolaferraro closed issue #1936: URL: https://github.com/apache/camel-k/issues/1936 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 edited a comment on issue #1939: Flaky e2e test (cron-fallback)
astefanutti edited a comment on issue #1939: URL: https://github.com/apache/camel-k/issues/1939#issuecomment-765557557 OK, sounds good. It'd better be that. I did my tests quickly as I was bringing CI back on track, so I may have overlooked things or forgotten others . 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-runtime] nicolaferraro opened a new issue #592: Catalog contains duplicate entry for same schema (cron)
nicolaferraro opened a new issue #592: URL: https://github.com/apache/camel-k-runtime/issues/592 See: https://github.com/apache/camel-k/issues/1939#issuecomment-765560895 cc: @lburgazzoli 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 commented on issue #1939: Flaky e2e test (cron-fallback)
nicolaferraro commented on issue #1939: URL: https://github.com/apache/camel-k/issues/1939#issuecomment-765560895 Found it! Catalog contains both: ``` camel-k-cron: groupId: org.apache.camel.k artifactId: camel-k-cron schemes: - id: cron http: false passive: false ``` And ``` camel-quarkus-cron: groupId: org.apache.camel.quarkus artifactId: camel-quarkus-cron schemes: - id: cron http: false passive: false javaTypes: - org.apache.camel.component.cron.CronComponent ``` So depending on the status of some butterflies, the right component gets loaded. I think `camel-quarkus-cron` is the right one, the other is part of the cron capability. Opening issue in the runtime. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] astefanutti commented on issue #1939: Flaky e2e test (cron-fallback)
astefanutti commented on issue #1939: URL: https://github.com/apache/camel-k/issues/1939#issuecomment-765557557 OK, sounds good. It'd better be that. I did my tests quickly as I were bringing CI back on track so I may have overlooked things or forgotten others . 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] oscerd commented on a change in pull request #4913: CAMEL-12489 - camel-infinspan: split remote and embedded components
oscerd commented on a change in pull request #4913: URL: https://github.com/apache/camel/pull/4913#discussion_r562771239 ## File path: catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties ## @@ -175,7 +175,6 @@ ignite-queue ignite-set imap imaps -infinispan Review comment: I think we need a special case for infinispan in the catalog generation This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] lburgazzoli commented on pull request #4913: CAMEL-12489 - camel-infinspan: split remote and embedded components
lburgazzoli commented on pull request #4913: URL: https://github.com/apache/camel/pull/4913#issuecomment-765547383 @davsclaus @oscerd @tristantarrant This PR implements https://issues.apache.org/jira/browse/CAMEL-12489 so now there's two Infinispan components provided by dedicated artefacts: - **infinispan** (remote via Hot Rod) - **infinispan-embedded** (local/embedded) As the recommended way to interact with Infinispan is as a client via the Hot Rod protocol, I kept `infinispan` as scheme for the remote component instead of introducing a new one. The embedded/local mode is still present but requires to use a dedicated scheme `infinispan-embedded`. As result of this refactor: - there is a clean separation between remote and embedded configuration options - artefacts have a much clean dependency tree - the code is simpler as we have less code branch to deal with the different behaviours - remote and embedded support the same functionalities (i.e. query are now supported also on the embedded cache) I'm working to adapt the documents but I'd really appreciate a quick review (I know, 174 changed files)) 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 commented on issue #1939: Flaky e2e test (cron-fallback)
nicolaferraro commented on issue #1939: URL: https://github.com/apache/camel-k/issues/1939#issuecomment-765532585 > Hum that's what I did (adding the extra dependencies, not running it locally) and thought too, but IIRC if failed randomly also. Have you tried to run it multiple times? No, it seems to work.. at least locally.. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] zbendhiba opened a new pull request #2160: Enable the failing test - bug is fixed in CAMEL-16035 fixes #2127
zbendhiba opened a new pull request #2160: URL: https://github.com/apache/camel-quarkus/pull/2160 [ ] An issue should be filed for the change unless this is a trivial change (fixing a typo or similar). One issue should ideally be fixed by not more than one commit and the other way round, each commit should fix just one issue, without pulling in other changes. [ ] Each commit in the pull request should have a meaningful and properly spelled subject line and body. Copying the title of the associated issue is typically enough. Please include the issue number in the commit message prefixed by #. [ ] The pull request description should explain what the pull request does, how, and why. If the info is available in the associated issue or some other external document, a link is enough. [ ] Phrases like Fix # or Fixes # will auto-close the named issue upon merging the pull request. Using them is typically a good idea. [ ] Please run mvn process-resources -Pformat (and amend the changes if necessary) before sending the pull request. [ ] Contributor guide is your good friend: https://camel.apache.org/camel-quarkus/latest/contributor-guide.html This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] zbendhiba opened a new pull request #4912: CAMEL-16018: HazelcastReplicatedConsumer not receiving events (#4868)
zbendhiba opened a new pull request #4912: URL: https://github.com/apache/camel/pull/4912 cherry-pick from master commit 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-runtime] lburgazzoli commented on pull request #590: Fixes #589, fixed kamelet-reify component scheme in CamelK catalog
lburgazzoli commented on pull request #590: URL: https://github.com/apache/camel-k-runtime/pull/590#issuecomment-765492817 That error should have been fixed by https://github.com/apache/camel-k-runtime/pull/583 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 (dc86b59 -> e625a7f)
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 dc86b59 Sync deps add e625a7f (chores) avoid catching Throwable as it can lead to unexpected (#4911) No new revisions were added by this update. Summary of changes: .../org/apache/camel/component/facebook/FacebookConsumer.java | 2 +- .../org/apache/camel/component/facebook/FacebookProducer.java | 2 +- .../component/facebook/data/FacebookMethodsTypeHelper.java | 5 ++--- .../apache/camel/component/file/watch/FileWatchConsumer.java | 2 +- .../main/java/org/apache/camel/component/file/GenericFile.java | 2 +- .../camel/component/file/GenericFilePollingConsumer.java | 2 +- .../camel/component/google/pubsub/GooglePubsubConsumer.java| 2 +- .../component/google/pubsub/consumer/CamelMessageReceiver.java | 2 +- .../camel/component/optaplanner/OptaPlannerProducer.java | 2 +- .../main/java/org/apache/camel/component/quartz/CamelJob.java | 2 +- .../org/apache/camel/component/rabbitmq/RabbitMQComponent.java | 2 +- .../org/apache/camel/component/rabbitmq/RabbitMQConsumer.java | 2 +- .../org/apache/camel/component/rabbitmq/RabbitMQProducer.java | 2 +- .../camel/component/rabbitmq/reply/CorrelationTimeoutMap.java | 2 +- .../java/org/apache/camel/component/sjms/SjmsConsumer.java | 4 ++-- .../main/java/org/apache/camel/component/sjms/SjmsHelper.java | 6 +++--- .../main/java/org/apache/camel/component/sjms/SjmsMessage.java | 2 +- .../java/org/apache/camel/component/sjms/SjmsProducer.java | 2 +- .../apache/camel/component/sjms/TransactionOnCompletion.java | 2 +- .../camel/component/sjms/consumer/EndpointMessageListener.java | 6 +++--- .../sjms/consumer/SimpleMessageListenerContainer.java | 10 +- 21 files changed, 31 insertions(+), 32 deletions(-)
[GitHub] [camel] davsclaus commented on pull request #4909: camel-milo: added possibility to read node values via producer.
davsclaus commented on pull request #4909: URL: https://github.com/apache/camel/pull/4909#issuecomment-765480421 For headers we prefer that they are prefixed with CamelComponentName, eg CamelMilo - then we know they are from this component. And this also avoids routing those special headers over the network as they will be filtered out. 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-runtime] dhirajsb commented on pull request #590: Fixes #589, fixed kamelet-reify component scheme in CamelK catalog
dhirajsb commented on pull request #590: URL: https://github.com/apache/camel-k-runtime/pull/590#issuecomment-765473057 @lburgazzoli can you verify that these missed name changes from `wrap` to `kamelet-reify` in catalog are what's causing the error: ``` java.lang.IllegalArgumentException: Cannot compute endpoint URI: unable to find an EndpointUriFactory for scheme kamelet-reify ``` 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: (chores) avoid catching Throwable as it can lead to unexpected (#4911)
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new e625a7f (chores) avoid catching Throwable as it can lead to
unexpected (#4911)
e625a7f is described below
commit e625a7f0b380e2728d93bdfe785b620977380bf9
Author: Otavio Rodolfo Piske
AuthorDate: Fri Jan 22 15:55:11 2021 +0100
(chores) avoid catching Throwable as it can lead to unexpected (#4911)
situations
Includes changes to the following components: camel-facebook,
camel-file-watch
camel-file, camel-google-pubsubl, camel-google-pubsub,
camel-optaplanner, camel-rabbitmq, camel-quartz, camel-sjms
---
.../org/apache/camel/component/facebook/FacebookConsumer.java | 2 +-
.../org/apache/camel/component/facebook/FacebookProducer.java | 2 +-
.../component/facebook/data/FacebookMethodsTypeHelper.java | 5 ++---
.../apache/camel/component/file/watch/FileWatchConsumer.java | 2 +-
.../main/java/org/apache/camel/component/file/GenericFile.java | 2 +-
.../camel/component/file/GenericFilePollingConsumer.java | 2 +-
.../camel/component/google/pubsub/GooglePubsubConsumer.java| 2 +-
.../component/google/pubsub/consumer/CamelMessageReceiver.java | 2 +-
.../camel/component/optaplanner/OptaPlannerProducer.java | 2 +-
.../main/java/org/apache/camel/component/quartz/CamelJob.java | 2 +-
.../org/apache/camel/component/rabbitmq/RabbitMQComponent.java | 2 +-
.../org/apache/camel/component/rabbitmq/RabbitMQConsumer.java | 2 +-
.../org/apache/camel/component/rabbitmq/RabbitMQProducer.java | 2 +-
.../camel/component/rabbitmq/reply/CorrelationTimeoutMap.java | 2 +-
.../java/org/apache/camel/component/sjms/SjmsConsumer.java | 4 ++--
.../main/java/org/apache/camel/component/sjms/SjmsHelper.java | 6 +++---
.../main/java/org/apache/camel/component/sjms/SjmsMessage.java | 2 +-
.../java/org/apache/camel/component/sjms/SjmsProducer.java | 2 +-
.../apache/camel/component/sjms/TransactionOnCompletion.java | 2 +-
.../camel/component/sjms/consumer/EndpointMessageListener.java | 6 +++---
.../sjms/consumer/SimpleMessageListenerContainer.java | 10 +-
21 files changed, 31 insertions(+), 32 deletions(-)
diff --git
a/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/FacebookConsumer.java
b/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/FacebookConsumer.java
index 5a3f5a6..343c4fe 100644
---
a/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/FacebookConsumer.java
+++
b/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/FacebookConsumer.java
@@ -178,7 +178,7 @@ public class FacebookConsumer extends ScheduledPollConsumer
{
processResult(result, rawJSON);
return 1; // number of messages polled
}
-} catch (Throwable t) {
+} catch (Exception t) {
throw RuntimeCamelException.wrapRuntimeCamelException(t);
}
}
diff --git
a/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/FacebookProducer.java
b/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/FacebookProducer.java
index 1e0c27d..34682ee 100644
---
a/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/FacebookProducer.java
+++
b/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/FacebookProducer.java
@@ -113,7 +113,7 @@ public class FacebookProducer extends DefaultAsyncProducer {
rawJSON);
}
-} catch (Throwable t) {
+} catch (Exception t) {
exchange.setException(RuntimeCamelException.wrapRuntimeCamelException(t));
} finally {
callback.done(false);
diff --git
a/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/data/FacebookMethodsTypeHelper.java
b/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/data/FacebookMethodsTypeHelper.java
index 6b94608..5bf235e 100644
---
a/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/data/FacebookMethodsTypeHelper.java
+++
b/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/data/FacebookMethodsTypeHelper.java
@@ -356,12 +356,11 @@ public final class FacebookMethodsTypeHelper {
try {
return method.getMethod().invoke(facebook, values);
-} catch (Throwable e) {
+} catch (Exception e) {
// skip wrapper exception to simplify stack
String msg;
if (e.getCause() instanceof FacebookException) {
-e = e.getCause();
-msg = ((FacebookException)
[GitHub] [camel] orpiske merged pull request #4911: (chores) avoid catching Throwable as it can lead to unexpected situations
orpiske merged pull request #4911: URL: https://github.com/apache/camel/pull/4911 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] jamesnetherton commented on pull request #1931: Use Quarkus fast-jar package format apache/camel-k-runtime#360
jamesnetherton commented on pull request #1931: URL: https://github.com/apache/camel-k/pull/1931#issuecomment-765457997 Seems a Spectrum tweak is also required, so opened https://github.com/container-tools/spectrum/pull/4. 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] lburgazzoli commented on issue #1941: kamelet-binding : suport for error handling
lburgazzoli commented on issue #1941: URL: https://github.com/apache/camel-k/issues/1941#issuecomment-765457605 /cc @nicolaferraro 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] lburgazzoli opened a new issue #1941: kamelet-binding : suport for error handling
lburgazzoli opened a new issue #1941: URL: https://github.com/apache/camel-k/issues/1941 ```yaml apiVersion: camel.apache.org/v1alpha1 kind: KameletBinding metadata: name: telegram-text-source-to-kafka spec: source: ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: telegram-text-source properties: botToken: the-token-here sink: ref: kind: KafkaTopic apiVersion: kafka.strimzi.io/v1beta1 name: my-topic error-handler: ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: retry-handler properties: ... ``` 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 #1869: './kamel run xxx' and 'make test-integration' pod failures on Ubuntu 16.04 (with minikube)
amitsadaphule commented on issue #1869: URL: https://github.com/apache/camel-k/issues/1869#issuecomment-765453535 Thanks @astefanutti for the support! I'll try to check from my side too. 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 edited a comment on issue #1869: './kamel run xxx' and 'make test-integration' pod failures on Ubuntu 16.04 (with minikube)
amitsadaphule edited a comment on issue #1869: URL: https://github.com/apache/camel-k/issues/1869#issuecomment-765450861 Same issue even after deleting ik, it and re-executing `./kamel run examples/Sample.java`. ``` # kubectl get all -n default NAMEREADY STATUS RESTARTS AGE pod/camel-k-operator-57bbcbd6dc-j5kcv 1/1 Running0 4h28m pod/sample-95d958b69-z556d 0/1 ImagePullBackOff 0 55s NAME TYPECLUSTER-IP EXTERNAL-IP PORT(S) AGE service/kubernetes ClusterIP 10.96.0.1443/TCP 10d NAME READY UP-TO-DATE AVAILABLE AGE deployment.apps/camel-k-operator 1/1 11 4h28m deployment.apps/sample 0/1 10 56s NAME DESIRED CURRENT READY AGE replicaset.apps/camel-k-operator-57bbcbd6dc 1 1 1 4h28m replicaset.apps/sample-95d958b69 1 1 0 56s ``` ``` # kubectl get ik,it -A NAMESPACE NAME PHASE TYPE IMAGE default integrationkit.camel.apache.org/kit-c05e6g5f57dq9p35q41g Ready platform 10.103.184.236/default/camel-k-kit-c05e6g5f57dq9p35q41g@sha256:bb486d97a46e7d45e55497c99d01d869bfb1c71023220dda2c7d1343ed6bc200 NAMESPACE NAME PHASE KIT REPLICAS default integration.camel.apache.org/sample Running kit-c05e6g5f57dq9p35q41g 1 ``` ``` # kubectl describe pod sample-95d958b69-z556d -n default ... ... Events: Type Reason Age From Message -- --- Normal Scheduled 2m22sdefault-scheduler Successfully assigned default/sample-95d958b69-z556d to p006vm87 Normal Pulling55s (x4 over 2m18s) kubeletPulling image "10.103.184.236/default/camel-k-kit-c05e6g5f57dq9p35q41g@sha256:bb486d97a46e7d45e55497c99d01d869bfb1c71023220dda2c7d1343ed6bc200" Warning Failed 55s (x4 over 2m18s) kubeletFailed to pull image "10.103.184.236/default/camel-k-kit-c05e6g5f57dq9p35q41g@sha256:bb486d97a46e7d45e55497c99d01d869bfb1c71023220dda2c7d1343ed6bc200": rpc error: code = Unknown desc = Error response from daemon: Get https://10.103.184.236/v2/: dial tcp 10.103.184.236:443: connect: connection refused Warning Failed 55s (x4 over 2m18s) kubeletError: ErrImagePull Normal BackOff44s (x6 over 2m17s) kubeletBack-off pulling image "10.103.184.236/default/camel-k-kit-c05e6g5f57dq9p35q41g@sha256:bb486d97a46e7d45e55497c99d01d869bfb1c71023220dda2c7d1343ed6bc200" Warning Failed 29s (x7 over 2m17s) kubeletError: ImagePullBackOff ``` Maybe something is wrong with the registry setup itself? Is there a different way to setup the local registry for minikube instead of `minikube addons enable registry` that is known to be working for 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
[GitHub] [camel-k] astefanutti commented on issue #1869: './kamel run xxx' and 'make test-integration' pod failures on Ubuntu 16.04 (with minikube)
astefanutti commented on issue #1869: URL: https://github.com/apache/camel-k/issues/1869#issuecomment-765452467 No worries, so now that we are sure the IP matches, we need to understand: ``` Get https://10.106.145.48/v2/: dial tcp 10.106.145.48:443: connect: connection refused ``` I'm surprised it uses HTTPS as the registry is configured as `insecure`. I'd have a look at the registry deployment and understand why the kubelet tries to pull the image using HTTPS. 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 #1869: './kamel run xxx' and 'make test-integration' pod failures on Ubuntu 16.04 (with minikube)
amitsadaphule commented on issue #1869: URL: https://github.com/apache/camel-k/issues/1869#issuecomment-765450861 Same issue even after deleting ik, it and re-executing `./kamel run examples/Sample.java`. ``` # kubectl get all -n default NAMEREADY STATUS RESTARTS AGE pod/camel-k-operator-57bbcbd6dc-j5kcv 1/1 Running0 4h28m pod/sample-95d958b69-z556d 0/1 ImagePullBackOff 0 55s NAME TYPECLUSTER-IP EXTERNAL-IP PORT(S) AGE service/kubernetes ClusterIP 10.96.0.1443/TCP 10d NAME READY UP-TO-DATE AVAILABLE AGE deployment.apps/camel-k-operator 1/1 11 4h28m deployment.apps/sample 0/1 10 56s NAME DESIRED CURRENT READY AGE replicaset.apps/camel-k-operator-57bbcbd6dc 1 1 1 4h28m replicaset.apps/sample-95d958b69 1 1 0 56s ``` ``` # kubectl get ik,it -A NAMESPACE NAME PHASE TYPE IMAGE default integrationkit.camel.apache.org/kit-c05e6g5f57dq9p35q41g Ready platform 10.103.184.236/default/camel-k-kit-c05e6g5f57dq9p35q41g@sha256:bb486d97a46e7d45e55497c99d01d869bfb1c71023220dda2c7d1343ed6bc200 NAMESPACE NAME PHASE KIT REPLICAS default integration.camel.apache.org/sample Running kit-c05e6g5f57dq9p35q41g 1 ``` ``` # kubectl describe pod sample-95d958b69-z556d -n default ... ... Events: Type Reason Age From Message -- --- Normal Scheduled 2m22sdefault-scheduler Successfully assigned default/sample-95d958b69-z556d to p006vm87 Normal Pulling55s (x4 over 2m18s) kubeletPulling image "10.103.184.236/default/camel-k-kit-c05e6g5f57dq9p35q41g@sha256:bb486d97a46e7d45e55497c99d01d869bfb1c71023220dda2c7d1343ed6bc200" Warning Failed 55s (x4 over 2m18s) kubeletFailed to pull image "10.103.184.236/default/camel-k-kit-c05e6g5f57dq9p35q41g@sha256:bb486d97a46e7d45e55497c99d01d869bfb1c71023220dda2c7d1343ed6bc200": rpc error: code = Unknown desc = Error response from daemon: Get https://10.103.184.236/v2/: dial tcp 10.103.184.236:443: connect: connection refused Warning Failed 55s (x4 over 2m18s) kubeletError: ErrImagePull Normal BackOff44s (x6 over 2m17s) kubeletBack-off pulling image "10.103.184.236/default/camel-k-kit-c05e6g5f57dq9p35q41g@sha256:bb486d97a46e7d45e55497c99d01d869bfb1c71023220dda2c7d1343ed6bc200" Warning Failed 29s (x7 over 2m17s) kubeletError: ImagePullBackOff ``` This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] orpiske merged pull request #916: (chores) fixed typo in AWS v2 Cloud Watch test
orpiske merged pull request #916: URL: https://github.com/apache/camel-kafka-connector/pull/916 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: (chores) fixed typo in AWS v2 Cloud Watch test
This is an automated email from the ASF dual-hosted git repository.
orpiske 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 ba46490 (chores) fixed typo in AWS v2 Cloud Watch test
ba46490 is described below
commit ba464900bdc0aa150bba7c91336b681dda982d0d
Author: Otavio Rodolfo Piske
AuthorDate: Fri Jan 22 14:52:43 2021 +0100
(chores) fixed typo in AWS v2 Cloud Watch test
---
.../camel/kafkaconnector/aws/v2/cw/sink/CamelSinkAWSCWITCase.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/cw/sink/CamelSinkAWSCWITCase.java
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/cw/sink/CamelSinkAWSCWITCase.java
index 62c7122..0888b10 100644
---
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/cw/sink/CamelSinkAWSCWITCase.java
+++
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/cw/sink/CamelSinkAWSCWITCase.java
@@ -154,7 +154,7 @@ public class CamelSinkAWSCWITCase extends
CamelSinkAWSTestSupport {
runTest(testProperties, topicName, expect);
} catch (Exception e) {
-LOG.error("Amazon SQS test failed: {}", e.getMessage(), e);
+LOG.error("Amazon CloudWatch test failed: {}", e.getMessage(), e);
fail(e.getMessage());
}
}
[GitHub] [camel-k] amitsadaphule edited a comment on issue #1869: './kamel run xxx' and 'make test-integration' pod failures on Ubuntu 16.04 (with minikube)
amitsadaphule edited a comment on issue #1869: URL: https://github.com/apache/camel-k/issues/1869#issuecomment-765442414 @astefanutti sorry about the mixed up logs. The one from `kubectl get ip camel-k -o yaml` that I posted above is from a different VM altogether. And the pod description there matches the IP: ``` Events: Type Reason Age From Message -- --- Normal BackOff 9m38s (x1055 over 4h9m) kubelet Back-off pulling image "10.103.184.236/default/camel-k-kit-c03kvrjdiqnieco98l2g@sha256:5938d9b4fc02824a622db92ab3650685a0e53c6faa8c82d2e14a72442e00ab5e" Warning Failed 4m40s (x1077 over 4h9m) kubelet Error: ImagePullBackOff ``` I'll still try executing `kubectl delete ik,it --all` to delete the following resources and re-creating the build. ``` # kubectl get ik,it -A NAMESPACE NAME PHASE TYPE IMAGE default integrationkit.camel.apache.org/kit-c03kvrjdiqnieco98l2g Ready platform 10.103.184.236/default/camel-k-kit-c03kvrjdiqnieco98l2g@sha256:5938d9b4fc02824a622db92ab3650685a0e53c6faa8c82d2e14a72442e00ab5e NAMESPACE NAME PHASE KIT REPLICAS default integration.camel.apache.org/sample Running kit-c03kvrjdiqnieco98l2g 1 ``` 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 #1869: './kamel run xxx' and 'make test-integration' pod failures on Ubuntu 16.04 (with minikube)
amitsadaphule commented on issue #1869: URL: https://github.com/apache/camel-k/issues/1869#issuecomment-765442414 @astefanutti sorry about the mixed up logs. The one from `kubectl get ip camel-k -o yaml` that I posted above is from a different VM altogether. And the pod description there matches the IP: ``` Events: Type Reason Age From Message -- --- Normal BackOff 9m38s (x1055 over 4h9m) kubelet Back-off pulling image "10.103.184.236/default/camel-k-kit-c03kvrjdiqnieco98l2g@sha256:5938d9b4fc02824a622db92ab3650685a0e53c6faa8c82d2e14a72442e00ab5e" Warning Failed 4m40s (x1077 over 4h9m) kubelet Error: ImagePullBackOff ``` I'll still try executing `kubectl delete ik,it --all` and re-creating the build. 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 (d65450f -> dc86b59)
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 d65450f Sync deps add 961f04a Upgrade Univocity Parsers to version 2.9.1 add dc86b59 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-k] astefanutti edited a comment on issue #1939: Flaky e2e test (cron-fallback)
astefanutti edited a comment on issue #1939: URL: https://github.com/apache/camel-k/issues/1939#issuecomment-765440112 Hum that's what I did (adding the extra dependencies, not running it locally) and thought too, but IIRC if failed randomly also. Have you tried to run it multiple times? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-quarkus] branch master updated: IPFS native support
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
The following commit(s) were added to refs/heads/master by this push:
new 6023d9f IPFS native support
6023d9f is described below
commit 6023d9f17f419bf2f8c84953568d0e56de3ddb37
Author: James Netherton
AuthorDate: Fri Jan 22 10:48:29 2021 +
IPFS native support
Fixes #770
---
.../ROOT/pages/reference/extensions/ipfs.adoc | 8 +--
.../ROOT/partials/reference/components/ipfs.adoc | 6 +-
extensions-jvm/pom.xml | 1 -
.../ipfs/deployment/pom.xml| 0
.../component/ipfs/deployment/IpfsProcessor.java | 16 -
{extensions-jvm => extensions}/ipfs/pom.xml| 1 -
.../ipfs/runtime/pom.xml | 1 +
.../main/resources/META-INF/quarkus-extension.yaml | 3 +-
extensions/pom.xml | 1 +
.../ipfs}/pom.xml | 59 ++--
.../quarkus/component/ipfs/it/IpfsResource.java| 41 ++-
.../camel/quarkus/component/ipfs/it/IpfsIT.java| 16 +
.../camel/quarkus/component/ipfs/it/IpfsTest.java | 79 ++
.../component/ipfs/it/IpfsTestResource.java| 54 +++
integration-tests/pom.xml | 1 +
tooling/scripts/test-categories.yaml | 1 +
16 files changed, 227 insertions(+), 61 deletions(-)
diff --git a/docs/modules/ROOT/pages/reference/extensions/ipfs.adoc
b/docs/modules/ROOT/pages/reference/extensions/ipfs.adoc
index 106a412..f2252ce 100644
--- a/docs/modules/ROOT/pages/reference/extensions/ipfs.adoc
+++ b/docs/modules/ROOT/pages/reference/extensions/ipfs.adoc
@@ -2,15 +2,15 @@
// This file was generated by
camel-quarkus-maven-plugin:update-extension-doc-page
= IPFS
:cq-artifact-id: camel-quarkus-ipfs
-:cq-native-supported: false
-:cq-status: Preview
+:cq-native-supported: true
+:cq-status: Stable
:cq-description: Access the Interplanetary File System (IPFS).
:cq-deprecated: false
:cq-jvm-since: 1.1.0
-:cq-native-since: n/a
+:cq-native-since: 1.7.0
[.badges]
-[.badge-key]##JVM since##[.badge-supported]##1.1.0##
[.badge-key]##Native##[.badge-unsupported]##unsupported##
+[.badge-key]##JVM since##[.badge-supported]##1.1.0## [.badge-key]##Native
since##[.badge-supported]##1.7.0##
Access the Interplanetary File System (IPFS).
diff --git a/docs/modules/ROOT/partials/reference/components/ipfs.adoc
b/docs/modules/ROOT/partials/reference/components/ipfs.adoc
index 96e5dc8..99005c8 100644
--- a/docs/modules/ROOT/partials/reference/components/ipfs.adoc
+++ b/docs/modules/ROOT/partials/reference/components/ipfs.adoc
@@ -2,11 +2,11 @@
// This file was generated by
camel-quarkus-maven-plugin:update-extension-doc-page
:cq-artifact-id: camel-quarkus-ipfs
:cq-artifact-id-base: ipfs
-:cq-native-supported: false
-:cq-status: Preview
+:cq-native-supported: true
+:cq-status: Stable
:cq-deprecated: false
:cq-jvm-since: 1.1.0
-:cq-native-since: n/a
+:cq-native-since: 1.7.0
:cq-camel-part-name: ipfs
:cq-camel-part-title: IPFS
:cq-camel-part-description: Access the Interplanetary File System (IPFS).
diff --git a/extensions-jvm/pom.xml b/extensions-jvm/pom.xml
index 79aef61..5b1ad12 100644
--- a/extensions-jvm/pom.xml
+++ b/extensions-jvm/pom.xml
@@ -77,7 +77,6 @@
iec60870
ignite
iota
-ipfs
irc
jasypt
jbpm
diff --git a/extensions-jvm/ipfs/deployment/pom.xml
b/extensions/ipfs/deployment/pom.xml
similarity index 100%
rename from extensions-jvm/ipfs/deployment/pom.xml
rename to extensions/ipfs/deployment/pom.xml
diff --git
a/extensions-jvm/ipfs/deployment/src/main/java/org/apache/camel/quarkus/component/ipfs/deployment/IpfsProcessor.java
b/extensions/ipfs/deployment/src/main/java/org/apache/camel/quarkus/component/ipfs/deployment/IpfsProcessor.java
similarity index 62%
rename from
extensions-jvm/ipfs/deployment/src/main/java/org/apache/camel/quarkus/component/ipfs/deployment/IpfsProcessor.java
rename to
extensions/ipfs/deployment/src/main/java/org/apache/camel/quarkus/component/ipfs/deployment/IpfsProcessor.java
index c9dfa54..1220635 100644
---
a/extensions-jvm/ipfs/deployment/src/main/java/org/apache/camel/quarkus/component/ipfs/deployment/IpfsProcessor.java
+++
b/extensions/ipfs/deployment/src/main/java/org/apache/camel/quarkus/component/ipfs/deployment/IpfsProcessor.java
@@ -17,30 +17,14 @@
package org.apache.camel.quarkus.component.ipfs.deployment;
import io.quarkus.deployment.annotations.BuildStep;
-import io.quarkus.deployment.annotations.ExecutionTime;
-import io.quarkus.deployment.annotations.Record;
import io.quarkus.deployment.builditem.FeatureBuildItem;
-import io.quarkus.deployment.pkg.steps.NativeBuild;
-import org.apache.camel.quarkus.core.JvmOnlyRecorder;
-import
[GitHub] [camel-quarkus] jamesnetherton merged pull request #2159: IPFS native support
jamesnetherton merged pull request #2159: URL: https://github.com/apache/camel-quarkus/pull/2159 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] jamesnetherton closed issue #770: IPFS native support
jamesnetherton closed issue #770: URL: https://github.com/apache/camel-quarkus/issues/770 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 #1939: Flaky e2e test (cron-fallback)
astefanutti commented on issue #1939: URL: https://github.com/apache/camel-k/issues/1939#issuecomment-765440112 Hum that's what I did and thought too, but IIRC if failed randomly also. Have you tried to run it multiple times? 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 commented on issue #1939: Flaky e2e test (cron-fallback)
nicolaferraro commented on issue #1939: URL: https://github.com/apache/camel-k/issues/1939#issuecomment-765438220 > That's a good question . > > I've looked at the dependencies and it seems the quartz dependencies are added correctly. It may be an issue with how Quarkus resolve classes... This works: ``` kamel local run cron-fallback.groovy -d camel-quarkus:quartz -d camel-quarkus:cron ``` So I guess the camel-quarkus:cron dependency is missing for some reason. 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 (ab21765 -> d65450f)
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 ab21765 Avoid catching Throwable because it could also catch Java Errors that shouldn't be handled (#4907) add bf0413a Upgrade Activemq to version 5.16.1 add d65450f 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-k-runtime] lburgazzoli opened a new pull request #591: loader(java): support for jshell scripts
lburgazzoli opened a new pull request #591: URL: https://github.com/apache/camel-k-runtime/pull/591 **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 #1939: Flaky e2e test (cron-fallback)
astefanutti commented on issue #1939: URL: https://github.com/apache/camel-k/issues/1939#issuecomment-765427350 That's a good question . I've looked at the dependencies and it seems the quartz dependencies are added correctly. It may be an issue with how Quarkus resolve classes... 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 commented on issue #1939: Flaky e2e test (cron-fallback)
nicolaferraro commented on issue #1939: URL: https://github.com/apache/camel-k/issues/1939#issuecomment-765424571 > Note that I've faced the issue by running the TestRunCronExample e2e test locally as well, so it does not seem CI environment specific. Uh, so why sometimes it passes :facepalm: ? 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 edited a comment on issue #1939: Flaky e2e test (cron-fallback)
astefanutti edited a comment on issue #1939: URL: https://github.com/apache/camel-k/issues/1939#issuecomment-765423170 Note that I've faced the issue by running the TestRunCronExample/cron-fallback e2e test locally as well, so it does not seem CI environment specific. 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 edited a comment on issue #1939: Flaky e2e test (cron-fallback)
astefanutti edited a comment on issue #1939: URL: https://github.com/apache/camel-k/issues/1939#issuecomment-765423170 Note that I've faced the issue by running the TestRunCronExample e2e test locally as well, so it does not seem CI environment specific. 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 #1939: Flaky e2e test (cron-fallback)
astefanutti commented on issue #1939: URL: https://github.com/apache/camel-k/issues/1939#issuecomment-765423170 Note that I've faced the issue by running the TestRunCronExample e2e test locally as well, so it does not seem environment specific. 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] orpiske opened a new pull request #4911: (chores) avoid catching Throwable as it can lead to unexpected situations
orpiske opened a new pull request #4911: URL: https://github.com/apache/camel/pull/4911 Includes changes to the following components: camel-facebook, camel-file-watch camel-file, camel-google-pubsubl, camel-google-pubsub, camel-optaplanner, camel-rabbitmq, camel-quartz, camel-sjms - [x] Make sure there is a [JIRA issue](https://issues.apache.org/jira/browse/CAMEL) filed for the change (usually before you start working on it). Trivial changes like typos do not require a JIRA issue. Your pull request should address just this issue, without pulling in other changes. - [x] Each commit in the pull request should have a meaningful subject line and body. - [x] If you're unsure, you can format the pull request title like `[CAMEL-XXX] Fixes bug in camel-file component`, where you replace `CAMEL-XXX` with the appropriate JIRA issue. - [x] Write a pull request description that is detailed enough to understand what the pull request does, how, and why. - [x] Run `mvn clean install -Psourcecheck` in your module with source check enabled to make sure basic checks pass and there are no checkstyle violations. A more thorough check will be performed on your pull request automatically. Below are the contribution guidelines: https://github.com/apache/camel/blob/master/CONTRIBUTING.md This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] astefanutti opened a new pull request #1940: fix(ci): Use AdoptOpenJDK/install-jdk@v1 action
astefanutti opened a new pull request #1940: URL: https://github.com/apache/camel-k/pull/1940 Backport #1901 to 1.3.x. **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 pull request #1938: Backport fix #1936: avoid patching if the target resource contains all expecte…
astefanutti commented on pull request #1938: URL: https://github.com/apache/camel-k/pull/1938#issuecomment-765412486 Let's wait until CI passes for the master branch PR has CI is still broken on 1.3.x branch. 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 pull request #1937: Fix #1936: avoid patching if the target resource contains all expecte…
astefanutti commented on pull request #1937: URL: https://github.com/apache/camel-k/pull/1937#issuecomment-765411435 I didn't see that one coming ! 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 #1869: './kamel run xxx' and 'make test-integration' pod failures on Ubuntu 16.04 (with minikube)
astefanutti commented on issue #1869: URL: https://github.com/apache/camel-k/issues/1869#issuecomment-765407637 Thanks, I'm surprised that the IntegrationPlatform has: ``` status: build: registry: address: 10.103.184.236 ``` While the Integration pod tries to pull the image from `10.106.145.48/default/camel-k-kit-bvhfthd6er6mi7d78k6g...`. My understanding is that the IP addresses should match. It seems `10.103.184.236` is the correct one as the operator has been able to push the image, and that `10.106.145.48` is not correct. Though it is supposed to be the same. I would try to check which IP address can be used to reach the registry. Then I would try to delete all the IntegrationKit and Integration resources: ``` $ kubectl delete ik,it --all ``` Then re-create the Integration, so that it creates a fresh new container image build. 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 (d65450f -> dc86b59)
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 d65450f Sync deps new 961f04a Upgrade Univocity Parsers to version 2.9.1 new dc86b59 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(-)
[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 dc86b59a6bf0972c33dbf3fc6560b643101a4d79 Author: Andrea Cosentino AuthorDate: Fri Jan 22 14:43:20 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 9136128..2300b01 100644 --- a/camel-dependencies/pom.xml +++ b/camel-dependencies/pom.xml @@ -546,7 +546,7 @@ 7.55.3 4.0.7 2.2.3.Final -2.9.0 +2.9.1 2.0.1.Final 0.10.2 2.0
[camel] 01/02: Upgrade Univocity Parsers to version 2.9.1
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 961f04ab2d49a48bee2ed88c5f4ae4b65e6c6915 Author: Andrea Cosentino AuthorDate: Fri Jan 22 14:41:46 2021 +0100 Upgrade Univocity Parsers to version 2.9.1 --- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parent/pom.xml b/parent/pom.xml index caa9c37..3cac716 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -533,7 +533,7 @@ 7.55.3 4.0.7 2.2.3.Final -2.9.0 +2.9.1 2.0.1.Final 0.10.2 2.0
[GitHub] [camel-k] nicolaferraro merged pull request #1934: fix(api): Add missing x-descriptors field to Kamelet property type
nicolaferraro merged pull request #1934: URL: https://github.com/apache/camel-k/pull/1934 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(api): Add missing x-descriptors field to Kamelet property type
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 0d741a7 fix(api): Add missing x-descriptors field to Kamelet property type 0d741a7 is described below commit 0d741a70e40256a5c99a2de36520e6a3f6cb656c Author: Antonin Stefanutti AuthorDate: Fri Jan 22 09:39:26 2021 +0100 fix(api): Add missing x-descriptors field to Kamelet property type --- config/crd/bases/camel.apache.org_kameletbindings.yaml | 12 config/crd/bases/camel.apache.org_kamelets.yaml | 12 deploy/crd-kamelet-binding.yaml | 12 deploy/crd-kamelet.yaml | 12 .../1.4.0-snapshot/kameletbindings.camel.apache.org.crd.yaml | 12 .../1.4.0-snapshot/kamelets.camel.apache.org.crd.yaml| 12 deploy/resources.go | 8 helm/camel-k/crds/crd-kamelet-binding.yaml | 12 helm/camel-k/crds/crd-kamelet.yaml | 12 pkg/apis/camel/v1alpha1/jsonschema_types.go | 4 +++- pkg/apis/camel/v1alpha1/zz_generated.deepcopy.go | 5 + 11 files changed, 108 insertions(+), 5 deletions(-) diff --git a/config/crd/bases/camel.apache.org_kameletbindings.yaml b/config/crd/bases/camel.apache.org_kameletbindings.yaml index f4a5ba8..70b5acb 100644 --- a/config/crd/bases/camel.apache.org_kameletbindings.yaml +++ b/config/crd/bases/camel.apache.org_kameletbindings.yaml @@ -367,6 +367,12 @@ spec: type: string uniqueItems: type: boolean + x-descriptors: +description: The list of descriptors that determine + which UI components to use on different views +items: + type: string +type: array type: object type: object required: @@ -575,6 +581,12 @@ spec: type: string uniqueItems: type: boolean + x-descriptors: +description: The list of descriptors that determine + which UI components to use on different views +items: + type: string +type: array type: object type: object required: diff --git a/config/crd/bases/camel.apache.org_kamelets.yaml b/config/crd/bases/camel.apache.org_kamelets.yaml index ec9c3d1..377c2b1 100644 --- a/config/crd/bases/camel.apache.org_kamelets.yaml +++ b/config/crd/bases/camel.apache.org_kamelets.yaml @@ -192,6 +192,12 @@ spec: type: string uniqueItems: type: boolean +x-descriptors: + description: The list of descriptors that determine which +UI components to use on different views + items: +type: string + type: array type: object type: object required: @@ -387,6 +393,12 @@ spec: type: string uniqueItems: type: boolean + x-descriptors: +description: The list of descriptors that determine + which UI components to use on different views +items: + type: string +type: array type: object type: object required: diff --git a/deploy/crd-kamelet-binding.yaml b/deploy/crd-kamelet-binding.yaml index f4a5ba8..70b5acb 100644 --- a/deploy/crd-kamelet-binding.yaml +++ b/deploy/crd-kamelet-binding.yaml @@ -367,6 +367,12 @@ spec: type: string uniqueItems: type: boolean + x-descriptors: +description: The
[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 d65450ff6d9793e01ad423f513f971e40d3ed078 Author: Andrea Cosentino AuthorDate: Fri Jan 22 14:36:45 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 44fa1c1..9136128 100644 --- a/camel-dependencies/pom.xml +++ b/camel-dependencies/pom.xml @@ -34,7 +34,7 @@ 1.1.3 2.16.0 -5.16.0 +5.16.1 1.0.2.v20150114 2.12.2 4.1.1.4
[camel] 01/02: Upgrade Activemq to version 5.16.1
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 bf0413a6a6f24b9e26187dc9b4e81cf75acc20d5 Author: Andrea Cosentino AuthorDate: Fri Jan 22 13:21:51 2021 +0100 Upgrade Activemq to version 5.16.1 --- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parent/pom.xml b/parent/pom.xml index 50c95ba..caa9c37 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -42,7 +42,7 @@ 1.1.3 -5.16.0 +5.16.1 2.16.0 1.0.2.v20150114 2.12.2
[camel] branch master updated (ab21765 -> d65450f)
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 ab21765 Avoid catching Throwable because it could also catch Java Errors that shouldn't be handled (#4907) new bf0413a Upgrade Activemq to version 5.16.1 new d65450f 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-k] nicolaferraro opened a new issue #1939: Flaky e2e test (cron-fallback)
nicolaferraro opened a new issue #1939: URL: https://github.com/apache/camel-k/issues/1939 We need to fix this flaky e2e test: ``` --- FAIL: TestRunCronExample (310.61s) --- PASS: TestRunCronExample/cron (127.61s) --- PASS: TestRunCronExample/cron-timer (60.37s) --- FAIL: TestRunCronExample/cron-fallback (91.99s) ``` It happens often, e.g. https://github.com/apache/camel-k/runs/1747588145?check_suite_focus=true, but disappears after running the CI multiple times. 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 opened a new pull request #1938: Backport fix #1936: avoid patching if the target resource contains all expecte…
nicolaferraro opened a new pull request #1938: URL: https://github.com/apache/camel-k/pull/1938 …d fields **Release Note** ```release-note Fixed compatibility bug with Knative 0.20 that prevented deploying services that also produce data ``` 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 #1928: Provide a way to use kamelet ID in binding
nicolaferraro closed issue #1928: URL: https://github.com/apache/camel-k/issues/1928 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 merged pull request #1929: Fix #1928: use "id" property in kamelet binding for adding specific c…
nicolaferraro merged pull request #1929: URL: https://github.com/apache/camel-k/pull/1929 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 edited a comment on issue #1869: './kamel run xxx' and 'make test-integration' pod failures on Ubuntu 16.04 (with minikube)
amitsadaphule edited a comment on issue #1869:
URL: https://github.com/apache/camel-k/issues/1869#issuecomment-765379303
Thanks for the reply @astefanutti ! I'm using minikube and here's how I
setup the registry:
1. Built `gcr.io/google_containers/kube-registry-proxy:0.4` image from
source https://github.com/povilasv/kube-registry-proxy.git
2. Built `registry` binary from source
https://github.com/docker/distribution-library-image.git
3. Built `registry.hub.docker.com/library/registry:2.7.1` image from source
https://github.com/docker/distribution-library-image.git by copying the
`registry` binary built in step #2 to `distribution-library-image` directory
4. Executed `minikube addons enable registry`
Post that I was able to see the registry pods coming up. Here's the pods
status post kamel install/run:
```
# kubectl get pods -A
NAMESPACE NAMEREADY STATUS
RESTARTS AGE
default camel-k-operator-57bbcbd6dc-j5kcv 1/1 Running
0 154m
default sample-5bc495b9cb-rbbzm 0/1 ImagePullBackOff
0 151m
kube-system coredns-f9fd979d6-7678j 1/1 Running
6 10d
kube-system etcd-p006vm87 1/1 Running
12 10d
kube-system kube-apiserver-p006vm87 1/1 Running
14 10d
kube-system kube-controller-manager-p006vm871/1 Running
9 10d
kube-system kube-proxy-q7pfw1/1 Running
6 10d
kube-system kube-scheduler-p006vm87 1/1 Running
6 10d
kube-system registry-8d28l 1/1 Running
3 2d15h
kube-system registry-proxy-q26fb1/1 Running
3 2d15h
```
Also, here's the output of `kubectl get ip camel-k -o yaml`
```
# kubectl get ip camel-k -o yaml
apiVersion: camel.apache.org/v1
kind: IntegrationPlatform
metadata:
creationTimestamp: "2021-01-22T10:11:08Z"
generation: 1
labels:
app: camel-k
managedFields:
- apiVersion: camel.apache.org/v1
fieldsType: FieldsV1
fieldsV1:
f:metadata:
f:labels:
.: {}
f:app: {}
f:spec:
.: {}
f:build:
.: {}
f:maven:
.: {}
f:settings: {}
f:publishStrategy: {}
f:registry:
.: {}
f:address: {}
f:insecure: {}
f:kamelet: {}
f:resources: {}
f:status:
.: {}
f:build:
.: {}
f:baseImage: {}
f:buildStrategy: {}
f:maven:
.: {}
f:localRepository: {}
f:settings:
.: {}
f:configMapKeyRef:
.: {}
f:key: {}
f:name: {}
f:timeout: {}
f:persistentVolumeClaim: {}
f:publishStrategy: {}
f:registry:
.: {}
f:address: {}
f:insecure: {}
f:runtimeVersion: {}
f:timeout: {}
f:cluster: {}
f:kamelet:
.: {}
f:repositories: {}
f:phase: {}
f:resources: {}
f:version: {}
manager: kamel
operation: Update
time: "2021-01-22T10:11:17Z"
name: camel-k
namespace: default
resourceVersion: "703539"
selfLink:
/apis/camel.apache.org/v1/namespaces/default/integrationplatforms/camel-k
uid: 74046037-87a3-4c9f-bd12-40af390713c7
spec:
build:
maven:
settings: {}
publishStrategy: Spectrum
registry:
address: 10.103.184.236
insecure: true
kamelet: {}
resources: {}
status:
build:
baseImage: adoptopenjdk/openjdk11:ubi
buildStrategy: routine
maven:
localRepository: /tmp/artifacts/m2
settings:
configMapKeyRef:
key: settings.xml
name: camel-k-maven-settings
timeout: 3m45s
persistentVolumeClaim: camel-k
publishStrategy: Spectrum
registry:
address: 10.103.184.236
insecure: true
runtimeVersion: 1.6.0
timeout: 5m0s
cluster: Kubernetes
kamelet:
repositories:
- uri: github:apache/camel-kamelets
phase: Ready
version: 1.3.0
```
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
[GitHub] [camel-k] amitsadaphule commented on issue #1869: './kamel run xxx' and 'make test-integration' pod failures on Ubuntu 16.04 (with minikube)
amitsadaphule commented on issue #1869:
URL: https://github.com/apache/camel-k/issues/1869#issuecomment-765379303
Thanks for the reply @astefanutti ! I'm using minikube and here's how I
setup the registry:
1. Built `gcr.io/google_containers/kube-registry-proxy:0.4` image from
source https://github.com/povilasv/kube-registry-proxy.git
2. Built `registry` binary from source
https://github.com/docker/distribution-library-image.git
3. Built `registry.hub.docker.com/library/registry:2.7.1` image from source
https://github.com/docker/distribution-library-image.git by copying the
`registry` binary built in step #2 to `distribution-library-image` directory
4. Executed `minikube addons enable registry`
Post that I was able to see the registry pods coming up:
```
# kubectl get pods -A
NAMESPACE NAMEREADY STATUS
RESTARTS AGE
default camel-k-operator-57bbcbd6dc-j5kcv 1/1 Running
0 154m
default sample-5bc495b9cb-rbbzm 0/1 ImagePullBackOff
0 151m
kube-system coredns-f9fd979d6-7678j 1/1 Running
6 10d
kube-system etcd-p006vm87 1/1 Running
12 10d
kube-system kube-apiserver-p006vm87 1/1 Running
14 10d
kube-system kube-controller-manager-p006vm871/1 Running
9 10d
kube-system kube-proxy-q7pfw1/1 Running
6 10d
kube-system kube-scheduler-p006vm87 1/1 Running
6 10d
kube-system registry-8d28l 1/1 Running
3 2d15h
kube-system registry-proxy-q26fb1/1 Running
3 2d15h
```
Also, here's the output of `kubectl get ip camel-k -o yaml`
```
# kubectl get ip camel-k -o yaml
apiVersion: camel.apache.org/v1
kind: IntegrationPlatform
metadata:
creationTimestamp: "2021-01-22T10:11:08Z"
generation: 1
labels:
app: camel-k
managedFields:
- apiVersion: camel.apache.org/v1
fieldsType: FieldsV1
fieldsV1:
f:metadata:
f:labels:
.: {}
f:app: {}
f:spec:
.: {}
f:build:
.: {}
f:maven:
.: {}
f:settings: {}
f:publishStrategy: {}
f:registry:
.: {}
f:address: {}
f:insecure: {}
f:kamelet: {}
f:resources: {}
f:status:
.: {}
f:build:
.: {}
f:baseImage: {}
f:buildStrategy: {}
f:maven:
.: {}
f:localRepository: {}
f:settings:
.: {}
f:configMapKeyRef:
.: {}
f:key: {}
f:name: {}
f:timeout: {}
f:persistentVolumeClaim: {}
f:publishStrategy: {}
f:registry:
.: {}
f:address: {}
f:insecure: {}
f:runtimeVersion: {}
f:timeout: {}
f:cluster: {}
f:kamelet:
.: {}
f:repositories: {}
f:phase: {}
f:resources: {}
f:version: {}
manager: kamel
operation: Update
time: "2021-01-22T10:11:17Z"
name: camel-k
namespace: default
resourceVersion: "703539"
selfLink:
/apis/camel.apache.org/v1/namespaces/default/integrationplatforms/camel-k
uid: 74046037-87a3-4c9f-bd12-40af390713c7
spec:
build:
maven:
settings: {}
publishStrategy: Spectrum
registry:
address: 10.103.184.236
insecure: true
kamelet: {}
resources: {}
status:
build:
baseImage: adoptopenjdk/openjdk11:ubi
buildStrategy: routine
maven:
localRepository: /tmp/artifacts/m2
settings:
configMapKeyRef:
key: settings.xml
name: camel-k-maven-settings
timeout: 3m45s
persistentVolumeClaim: camel-k
publishStrategy: Spectrum
registry:
address: 10.103.184.236
insecure: true
runtimeVersion: 1.6.0
timeout: 5m0s
cluster: Kubernetes
kamelet:
repositories:
- uri: github:apache/camel-kamelets
phase: Ready
version: 1.3.0
```
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 opened a new pull request #1937: Fix #1936: avoid patching if the target resource contains all expecte…
nicolaferraro opened a new pull request #1937: URL: https://github.com/apache/camel-k/pull/1937 …d fields Fix #1936 **Release Note** ```release-note Fixed compatibility bug with Knative 0.20 that prevented deploying services that also produce data ``` 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 opened a new issue #1936: SinkBinding on KSVC results into ping-pong between operators
nicolaferraro opened a new issue #1936: URL: https://github.com/apache/camel-k/issues/1936 When deploying the `splitter` integration in the example/knative dir with latest Knative: ``` $ oc get pods NAME READY STATUS RESTARTS AGE camel-k-kit-c04qhtf3ifj0h5tu34q0-1-build 0/1 Completed 0 12m camel-k-kit-c04qhtf3ifj0h5tu34q0-builder 0/1 Completed 0 13m camel-k-kit-c04qkbn3ifj0h5tu34qg-1-build 0/1 Completed 0 7m46s camel-k-kit-c04qkbn3ifj0h5tu34qg-builder 0/1 Completed 0 8m16s splitter-2bnb7-deployment-7478cc68d9-l8mmh 1/2 Running 0 31s splitter-2lpvx-deployment-dbdc65bc-dqw9j 0/2 Terminating 0 4m6s splitter-2phsz-deployment-dc59499f7-zv56f0/2 ContainerCreating 0 16s splitter-2w2nz-deployment-59f9c9dc8b-47bbm 1/2 Terminating 0 3m38s splitter-44mp5-deployment-9f48bb698-kgsks0/2 Terminating 0 4m7s splitter-49vf4-deployment-65847b7ff8-q8gqs 1/2 Running 0 45s splitter-4jhgk-deployment-6cbddf5bb-mnpdq2/2 Running 0 56s splitter-4nskm-deployment-7f8bf7bc7-wzh4j0/2 Terminating 0 4m16s splitter-6l625-deployment-7d6496ddc9-9rz4z 1/2 Running 0 33s splitter-8ht9c-deployment-8c57fcdf7-lsg561/2 Running 0 27s splitter-8s7nz-deployment-775db4ccc-5ckpq0/2 Terminating 0 4m8s splitter-95qk4-deployment-867cfbcff7-czhct 0/2 Terminating 0 4m9s splitter-9hngj-deployment-b49b79ff8-fdf491/2 Running 1 33s splitter-9m4bm-deployment-75bd985df8-nnv2z 1/2 Running 2 91s splitter-9nl24-deployment-6fcbc7987f-tbrgz 0/2 Terminating 0 3m44s splitter-bghvk-deployment-567f8b5c97-n9k4k 2/2 Terminating 0 98s splitter-bgx2r-deployment-86dbb9c8bb-wsd2p 1/2 Running 0 31s splitter-bmc4j-deployment-6f689fbbd6-6zbjl 0/2 ContainerCreating 0 9s splitter-bwgnr-deployment-ffd7c69b9-qcqt71/2 Running 2 97s splitter-bxd7w-deployment-59d8b8d9cf-fp7cz 1/2 Running 0 54s splitter-c7tfm-deployment-5f48b7864c-mnfcr 1/2 Running 2 86s splitter-cfttp-deployment-5cfc9f8746-9wp9f 0/2 Terminating 0 4m15s splitter-cgbzn-deployment-c4dd4d85b-f246j1/2 Running 0 28s splitter-chwdx-deployment-59fcf6b9f8-g87f4 0/2 Terminating 0 3m57s splitter-cvk46-deployment-6b6c6b75c-bfn2x1/2 Running 0 55s splitter-gd85f-deployment-946b5c485-9l9951/2 Running 0 19s splitter-gnfxx-deployment-7fbbb7f7c-bcsrd1/2 Running 0 47s splitter-grrk4-deployment-5595dbd945-8mzqt 2/2 Running 0 49s splitter-h8rml-deployment-5789bdd747-sxpxn 2/2 Running 0 94s splitter-hb2ck-deployment-7d8cc6fb8f-mssj9 1/2 Terminating 0 4m splitter-hg7fh-deployment-7dc96d64fd-cwgt8 1/2 Running 0 25s splitter-j48pd-deployment-6d899df47b-4mgm7 1/2 Terminating 0 3m51s splitter-k6cpl-deployment-598df89db5-4jgzv 1/2 Running 1 46s splitter-kwmlq-deployment-85dd46ddb6-qspd2 1/2 Running 0 48s splitter-mkgjh-deployment-d9fc7f75c-hwm5h2/2 Running 0 92s splitter-mqknt-deployment-89b756db5-825fn2/2 Terminating 0 98s splitter-mvpwj-deployment-686c7bdbc-n9bhc0/2 Terminating 0 5m20s splitter-n7r9w-deployment-5fb8b4d697-6pf2p 1/2 Running 0 3m47s splitter-nkk7c-deployment-75d8c4cc74-wp57w 1/2 Running 0 20s splitter-nmt4x-deployment-67bd9f9c5c-g5m9h 0/2 Terminating 0 4m19s splitter-nwj2c-deployment-59d4dc7f9-wt9bt2/2 Running 0 53s splitter-pnphc-deployment-5449857c57-nw8zq 0/2 ContainerCreating 0 15s splitter-qw6f6-deployment-89d9ffbcf-54dcq1/2 Terminating 0 3m46s splitter-rvgdd-deployment-56c996f565-z8nbb 1/2 Running 0 24s splitter-sfjzs-deployment-9c7ddc686-jd29l2/2 Terminating 0 86s splitter-shbth-deployment-75648d495f-4jg6n 0/2 ContainerCreating 0 10s splitter-swkrm-deployment-5455f594f4-dxgml 1/2 Running
[GitHub] [camel-kafka-connector] orpiske merged pull request #914: Added integration tests for AWS2 cloud watch
orpiske merged pull request #914: URL: https://github.com/apache/camel-kafka-connector/pull/914 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/03: Created a base test class for AWS sink tests
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 11ca8b0f84da9047cdca3dfd0131fceff3ea75c9
Author: Otavio Rodolfo Piske
AuthorDate: Fri Jan 22 10:08:47 2021 +0100
Created a base test class for AWS sink tests
---
.../aws/v2/common/CamelSinkAWSTestSupport.java | 70 ++
.../aws/v2/sqs/sink/CamelSinkAWSSQSITCase.java | 62 +--
2 files changed, 86 insertions(+), 46 deletions(-)
diff --git
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/common/CamelSinkAWSTestSupport.java
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/common/CamelSinkAWSTestSupport.java
new file mode 100644
index 000..c42cb36
--- /dev/null
+++
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/common/CamelSinkAWSTestSupport.java
@@ -0,0 +1,70 @@
+/*
+ * 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.common;
+
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+import org.apache.camel.kafkaconnector.common.AbstractKafkaTest;
+import org.apache.camel.kafkaconnector.common.ConnectorPropertyFactory;
+import org.apache.camel.kafkaconnector.common.clients.kafka.KafkaClient;
+import org.apache.camel.kafkaconnector.common.utils.TestUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import static org.junit.jupiter.api.Assertions.fail;
+
+public abstract class CamelSinkAWSTestSupport extends AbstractKafkaTest {
+private static final Logger LOG =
LoggerFactory.getLogger(CamelSinkAWSTestSupport.class);
+
+
+protected void produceMessages(int count) {
+try {
+KafkaClient kafkaClient = new
KafkaClient<>(getKafkaService().getBootstrapServers());
+
+for (int i = 0; i < count; i++) {
+
kafkaClient.produce(TestUtils.getDefaultTestTopic(this.getClass()), "Sink test
message " + i);
+}
+} catch (Throwable t) {
+LOG.error("Unable to publish messages to the broker: {}",
t.getMessage(), t);
+fail(String.format("Unable to publish messages to the broker: %s",
t.getMessage()));
+}
+}
+
+public void runTest(ConnectorPropertyFactory connectorPropertyFactory, int
count) throws Exception {
+connectorPropertyFactory.log();
+
getKafkaConnectService().initializeConnectorBlocking(connectorPropertyFactory,
1);
+
+LOG.debug("Creating the consumer ...");
+ExecutorService service = Executors.newCachedThreadPool();
+
+CountDownLatch latch = new CountDownLatch(1);
+service.submit(() -> consumeMessages(latch));
+
+LOG.debug("Creating the producer and sending messages ...");
+produceMessages(count);
+
+LOG.debug("Waiting for the test to complete");
+verifyMessages(latch);
+}
+
+protected abstract void consumeMessages(CountDownLatch latch);
+
+protected abstract void verifyMessages(CountDownLatch latch) throws
InterruptedException;
+}
diff --git
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/sqs/sink/CamelSinkAWSSQSITCase.java
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/sqs/sink/CamelSinkAWSSQSITCase.java
index 0f770bc..6cc9b79 100644
---
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/sqs/sink/CamelSinkAWSSQSITCase.java
+++
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/sqs/sink/CamelSinkAWSSQSITCase.java
@@ -20,14 +20,11 @@ package org.apache.camel.kafkaconnector.aws.v2.sqs.sink;
import java.util.List;
import java.util.Properties;
import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import org.apache.camel.kafkaconnector.aws.v2.clients.AWSSQSClient;
-import org.apache.camel.kafkaconnector.common.AbstractKafkaTest;
+import
[camel-kafka-connector] 03/03: Added new integration test for AWS 2 Cloud Watch
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit c7a6b0f82acb257905ec844565edfd028ce9cd61
Author: Otavio Rodolfo Piske
AuthorDate: Fri Jan 22 11:23:06 2021 +0100
Added new integration test for AWS 2 Cloud Watch
---
tests/itests-aws-v2/pom.xml| 5 +
.../aws/v2/common/CamelSinkAWSTestSupport.java | 18 ++-
.../aws/v2/cw/sink/CamelAWSCWPropertyFactory.java | 73 ++
.../aws/v2/cw/sink/CamelSinkAWSCWITCase.java | 161 +
.../v2/cw/sink/TestCloudWatchConfiguration.java| 35 +
.../aws/v2/sqs/sink/CamelSinkAWSSQSITCase.java | 21 ++-
6 files changed, 302 insertions(+), 11 deletions(-)
diff --git a/tests/itests-aws-v2/pom.xml b/tests/itests-aws-v2/pom.xml
index cd573f3..caf3c28 100644
--- a/tests/itests-aws-v2/pom.xml
+++ b/tests/itests-aws-v2/pom.xml
@@ -67,6 +67,11 @@
org.apache.camel
camel-aws2-s3
+
+
+org.apache.camel
+camel-aws2-cw
+
diff --git
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/common/CamelSinkAWSTestSupport.java
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/common/CamelSinkAWSTestSupport.java
index c42cb36..a66a474 100644
---
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/common/CamelSinkAWSTestSupport.java
+++
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/common/CamelSinkAWSTestSupport.java
@@ -17,6 +17,7 @@
package org.apache.camel.kafkaconnector.aws.v2.common;
+import java.util.Map;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
@@ -24,7 +25,6 @@ import java.util.concurrent.Executors;
import org.apache.camel.kafkaconnector.common.AbstractKafkaTest;
import org.apache.camel.kafkaconnector.common.ConnectorPropertyFactory;
import org.apache.camel.kafkaconnector.common.clients.kafka.KafkaClient;
-import org.apache.camel.kafkaconnector.common.utils.TestUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -33,13 +33,21 @@ import static org.junit.jupiter.api.Assertions.fail;
public abstract class CamelSinkAWSTestSupport extends AbstractKafkaTest {
private static final Logger LOG =
LoggerFactory.getLogger(CamelSinkAWSTestSupport.class);
+protected abstract Map messageHeaders(String text, int
current);
-protected void produceMessages(int count) {
+protected void produceMessages(String topicName, int count) {
try {
KafkaClient kafkaClient = new
KafkaClient<>(getKafkaService().getBootstrapServers());
for (int i = 0; i < count; i++) {
-
kafkaClient.produce(TestUtils.getDefaultTestTopic(this.getClass()), "Sink test
message " + i);
+String message = "Sink test message " + i;
+Map headers = messageHeaders(message, i);
+
+if (headers == null) {
+kafkaClient.produce(topicName, message);
+} else {
+kafkaClient.produce(topicName, message, headers);
+}
}
} catch (Throwable t) {
LOG.error("Unable to publish messages to the broker: {}",
t.getMessage(), t);
@@ -47,7 +55,7 @@ public abstract class CamelSinkAWSTestSupport extends
AbstractKafkaTest {
}
}
-public void runTest(ConnectorPropertyFactory connectorPropertyFactory, int
count) throws Exception {
+public void runTest(ConnectorPropertyFactory connectorPropertyFactory,
String topic, int count) throws Exception {
connectorPropertyFactory.log();
getKafkaConnectService().initializeConnectorBlocking(connectorPropertyFactory,
1);
@@ -58,7 +66,7 @@ public abstract class CamelSinkAWSTestSupport extends
AbstractKafkaTest {
service.submit(() -> consumeMessages(latch));
LOG.debug("Creating the producer and sending messages ...");
-produceMessages(count);
+produceMessages(topic, count);
LOG.debug("Waiting for the test to complete");
verifyMessages(latch);
diff --git
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/cw/sink/CamelAWSCWPropertyFactory.java
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/cw/sink/CamelAWSCWPropertyFactory.java
new file mode 100644
index 000..cd7f638
--- /dev/null
+++
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/cw/sink/CamelAWSCWPropertyFactory.java
@@ -0,0 +1,73 @@
+/*
+ * 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
[camel-kafka-connector] 02/03: Simplified handling of setting common AWS 2 properties
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 6a783544000a88fef4d68a9bcd4eb9d6736a41c7
Author: Otavio Rodolfo Piske
AuthorDate: Fri Jan 22 11:00:33 2021 +0100
Simplified handling of setting common AWS 2 properties
---
.../aws/v2/common/AWSPropertiesUtils.java | 63 ++
.../source/CamelAWSKinesisPropertyFactory.java | 15 ++
.../v2/s3/source/CamelAWSS3PropertyFactory.java| 15 ++
.../v2/sqs/sink/CamelAWSSQSPropertyFactory.java| 26 +
.../v2/sqs/source/CamelAWSSQSPropertyFactory.java | 25 +
.../common/BasicConnectorPropertyFactory.java | 2 +-
6 files changed, 76 insertions(+), 70 deletions(-)
diff --git
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/common/AWSPropertiesUtils.java
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/common/AWSPropertiesUtils.java
new file mode 100644
index 000..0f559dd
--- /dev/null
+++
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/common/AWSPropertiesUtils.java
@@ -0,0 +1,63 @@
+/*
+ * 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.common;
+
+import java.util.Map;
+import java.util.Properties;
+
+import org.apache.camel.kafkaconnector.common.BasicConnectorPropertyFactory;
+import org.apache.camel.test.infra.aws.common.AWSConfigs;
+import software.amazon.awssdk.regions.Region;
+
+public final class AWSPropertiesUtils {
+
+private AWSPropertiesUtils() {
+
+}
+
+public static void setCommonProperties(Properties amazonConfigs,
Map style,
+ BasicConnectorPropertyFactory
propertyFactory) {
+String accessKeyKey = style.get(AWSConfigs.ACCESS_KEY);
+String secretKeyKey = style.get(AWSConfigs.SECRET_KEY);
+String regionKey = style.get(AWSConfigs.REGION);
+String protocolKey = style.get(AWSConfigs.PROTOCOL);
+String hostKey = style.get(AWSConfigs.AMAZON_AWS_HOST);
+
+propertyFactory.setProperty(accessKeyKey,
+amazonConfigs.getProperty(AWSConfigs.ACCESS_KEY, ""));
+propertyFactory.setProperty(secretKeyKey,
+amazonConfigs.getProperty(AWSConfigs.SECRET_KEY, ""));
+propertyFactory.setProperty(regionKey,
+amazonConfigs.getProperty(AWSConfigs.REGION,
Region.US_EAST_1.toString()));
+
+String protocol = amazonConfigs.getProperty(AWSConfigs.PROTOCOL, "");
+
+if (protocolKey != null && !protocolKey.isEmpty()) {
+if (protocol != null && !protocol.isEmpty()) {
+propertyFactory.setProperty(protocolKey, protocol);
+}
+}
+
+if (hostKey != null && !hostKey.isEmpty()) {
+String amazonAwsHost =
amazonConfigs.getProperty(AWSConfigs.AMAZON_AWS_HOST, "");
+if (amazonAwsHost != null && !amazonAwsHost.isEmpty()) {
+propertyFactory.setProperty(hostKey, amazonAwsHost);
+}
+}
+}
+}
diff --git
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kinesis/source/CamelAWSKinesisPropertyFactory.java
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kinesis/source/CamelAWSKinesisPropertyFactory.java
index 27e8fc3..78ef14d 100644
---
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kinesis/source/CamelAWSKinesisPropertyFactory.java
+++
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kinesis/source/CamelAWSKinesisPropertyFactory.java
@@ -21,10 +21,10 @@ import java.util.HashMap;
import java.util.Map;
import java.util.Properties;
+import org.apache.camel.kafkaconnector.aws.v2.common.AWSPropertiesUtils;
import org.apache.camel.kafkaconnector.common.EndpointUrlBuilder;
import org.apache.camel.kafkaconnector.common.SourceConnectorPropertyFactory;
import org.apache.camel.test.infra.aws.common.AWSConfigs;
-import software.amazon.awssdk.regions.Region;
/**
@@ -53,16 +53,9 @@ final class
[camel-kafka-connector] branch master updated (fb19034 -> c7a6b0f)
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
from fb19034 Camel-Cron connector: We need to add at least camel-quartz as
dependency
new 11ca8b0 Created a base test class for AWS sink tests
new 6a78354 Simplified handling of setting common AWS 2 properties
new c7a6b0f Added new integration test for AWS 2 Cloud Watch
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:
tests/itests-aws-v2/pom.xml| 5 +
.../aws/v2/common/AWSPropertiesUtils.java | 63
.../aws/v2/common/CamelSinkAWSTestSupport.java | 78 ++
.../aws/v2/cw/sink/CamelAWSCWPropertyFactory.java | 73 ++
.../aws/v2/cw/sink/CamelSinkAWSCWITCase.java | 161 +
.../sink/TestCloudWatchConfiguration.java} | 18 +--
.../source/CamelAWSKinesisPropertyFactory.java | 15 +-
.../v2/s3/source/CamelAWSS3PropertyFactory.java| 15 +-
.../v2/sqs/sink/CamelAWSSQSPropertyFactory.java| 26 +---
.../aws/v2/sqs/sink/CamelSinkAWSSQSITCase.java | 77 --
.../v2/sqs/source/CamelAWSSQSPropertyFactory.java | 25 +---
.../common/BasicConnectorPropertyFactory.java | 2 +-
12 files changed, 430 insertions(+), 128 deletions(-)
create mode 100644
tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/common/AWSPropertiesUtils.java
create mode 100644
tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/common/CamelSinkAWSTestSupport.java
create mode 100644
tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/cw/sink/CamelAWSCWPropertyFactory.java
create mode 100644
tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/cw/sink/CamelSinkAWSCWITCase.java
copy
tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/{kinesis/source/TestKinesisConfiguration.java
=> cw/sink/TestCloudWatchConfiguration.java} (64%)
[GitHub] [camel] attrobit commented on a change in pull request #4909: camel-milo: added possibility to read node values via producer.
attrobit commented on a change in pull request #4909: URL: https://github.com/apache/camel/pull/4909#discussion_r562584199 ## File path: components/camel-milo/src/main/java/org/apache/camel/component/milo/client/MiloClientProducer.java ## @@ -35,6 +37,8 @@ private final boolean defaultAwaitWrites; +private static final String HEADER_NODE_IDS = "opcua.nodeIds"; Review comment: opcua is the protocol underneath. But i will remove the prefix. The existing headers has also no prefix. 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 opened a new pull request #2159: IPFS native support
jamesnetherton opened a new pull request #2159: URL: https://github.com/apache/camel-quarkus/pull/2159 Fixes #770 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
