[GitHub] [camel-quarkus] llowinge opened a new issue #2155: Re-think MockBackendUtils class so it is not needed to use it manually
llowinge opened a new issue #2155: URL: https://github.com/apache/camel-quarkus/issues/2155 In ideal situation, developer should not know about any need to call https://github.com/apache/camel-quarkus/blob/master/integration-tests-support/mock-backend/src/main/java/org/apache/camel/quarkus/test/mock/backend/MockBackendUtils.java#L49. @jamesnetherton Has maybe some idea how to achieve. This is just umbrella for this effort. 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] 01/03: chore(deps): update camel-quarkus to v1.6.0
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 commit a5ccbc057c0b29495a6689c876d622f4eb4a2f1a Author: Luca Burgazzoli AuthorDate: Fri Jan 15 14:23:27 2021 +0100 chore(deps): update camel-quarkus to v1.6.0 --- pom.xml | 34 ++ 1 file changed, 30 insertions(+), 4 deletions(-) diff --git a/pom.xml b/pom.xml index 9e54253..12dfbb4 100644 --- a/pom.xml +++ b/pom.xml @@ -41,14 +41,14 @@ 3.7.0 -1.5.0 -20.2.0 -1.10.3.Final +1.6.0 +20.3.0 +1.11.0.Final 0.9.13 3.0.7 -1.3.72 +1.4.20 2.0-M4-groovy-3.0 2.8.9-ea-1 3.1.0 @@ -332,6 +332,19 @@ + apache.snapshots https://repository.apache.org/snapshots/ @@ -346,6 +359,19 @@ + apache.snapshots https://repository.apache.org/snapshots/
[camel-k-runtime] branch master updated (d72f442 -> 1611207)
This is an automated email from the ASF dual-hosted git repository. lburgazzoli pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel-k-runtime.git. from d72f442 Move CloudEvents related code to camel-cloudevents new a5ccbc0 chore(deps): update camel-quarkus to v1.6.0 new 1bb97af chore(deps): add kotlin among dependabot ignored dependencies new 1611207 chore(build): disable native test for camel-k-itests-master as it fails on ci for out of memory with graalvm 20.3 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: .github/dependabot.yml | 1 + .github/workflows/ci-build.yml | 2 +- pom.xml| 34 ++ 3 files changed, 32 insertions(+), 5 deletions(-)
[camel-k-runtime] 03/03: chore(build): disable native test for camel-k-itests-master as it fails on ci for out of memory with graalvm 20.3
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 commit 161120791d77586a48474d11bb67402772413d64 Author: Luca Burgazzoli AuthorDate: Mon Jan 18 18:10:49 2021 +0100 chore(build): disable native test for camel-k-itests-master as it fails on ci for out of memory with graalvm 20.3 --- .github/workflows/ci-build.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/.github/workflows/ci-build.yml b/.github/workflows/ci-build.yml index 684c827..7d72edb 100644 --- a/.github/workflows/ci-build.yml +++ b/.github/workflows/ci-build.yml @@ -96,7 +96,7 @@ jobs: - :camel-k-itests-loader-yaml #- :camel-k-itests-loader-js - :camel-k-itests-loader-polyglot - - :camel-k-itests-master + #- :camel-k-itests-master - :camel-k-itests-runtime - :camel-k-itests-runtime-xml - :camel-k-itests-runtime-yaml
[camel-k-runtime] 02/03: chore(deps): add kotlin among dependabot ignored dependencies
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 commit 1bb97afd53f9c30c30e91e0953ab6269816d1f62 Author: Luca Burgazzoli AuthorDate: Fri Jan 15 14:26:12 2021 +0100 chore(deps): add kotlin among dependabot ignored dependencies --- .github/dependabot.yml | 1 + 1 file changed, 1 insertion(+) diff --git a/.github/dependabot.yml b/.github/dependabot.yml index 9e2c0e2..0c1cd83 100644 --- a/.github/dependabot.yml +++ b/.github/dependabot.yml @@ -32,6 +32,7 @@ updates: - dependency-name: "org.graalvm.js:js" - dependency-name: "com.fasterxml.jackson:*" - dependency-name: "com.puppycrawl.tools:checkstyle" + - dependency-name: "org.jetbrains.kotlin:*" - package-ecosystem: "github-actions" directory: "/" labels:
[GitHub] [camel-k-runtime] lburgazzoli merged pull request #587: update camel-quarkus to v1.6.0
lburgazzoli merged pull request #587: URL: https://github.com/apache/camel-k-runtime/pull/587 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] jamesnetherton commented on issue #2155: Re-think MockBackendUtils class so it is not needed to use it manually
jamesnetherton commented on issue #2155: URL: https://github.com/apache/camel-quarkus/issues/2155#issuecomment-764460311 IMO we should make `MockBackendUtils` as unintrusive as possible. E.g make it so that test implementors don't need to know anything about it, other than to fulfil a contract as to whether it should print the log `Mock backend will be used` message or not. I.e when a set of required environment variables are present or missing. We should also get rid of `CAMEL_QUARKUS_START_MOCK_BACKEND` because it makes little sense when tests require other environment variables to talk to the real service. 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 (3e14385 -> f280304)
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 3e14385 Regen new 5bc19d3 Upgrade Json validator to version 1.0.47 new f280304 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] 01/02: Upgrade Json validator to version 1.0.47
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 5bc19d3c6a4fd2183a893bced71d0ed539eb0e74 Author: Andrea Cosentino AuthorDate: Thu Jan 21 09:15:13 2021 +0100 Upgrade Json validator to version 1.0.47 --- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parent/pom.xml b/parent/pom.xml index bab671d..d92f5e8 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -426,7 +426,7 @@ 3.10.6.Final 4.1.58.Final 2.0.4 - 1.0.45 + 1.0.47 8.9 3.4.3
[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 f280304f11206e66f75fa5ec72e72fa1e476b3a9 Author: Andrea Cosentino AuthorDate: Thu Jan 21 09:16:27 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 dd161d6..62e2cc1 100644 --- a/camel-dependencies/pom.xml +++ b/camel-dependencies/pom.xml @@ -439,7 +439,7 @@ 2.0.4 4.1.58.Final 3.10.6.Final - 1.0.45 + 1.0.47 8.9 3.4.3 1.0.0.RC4
[camel-kafka-connector] branch master updated: Added new daily JDK 14 build on github actions
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 47cac0e Added new daily JDK 14 build on github actions
47cac0e is described below
commit 47cac0ea585322ac8ecd9529d3e095061db29bb6
Author: Otavio Rodolfo Piske
AuthorDate: Thu Jan 21 09:29:23 2021 +0100
Added new daily JDK 14 build on github actions
---
.github/workflows/daily-jdk14-build.yml | 85 +
1 file changed, 85 insertions(+)
diff --git a/.github/workflows/daily-jdk14-build.yml
b/.github/workflows/daily-jdk14-build.yml
new file mode 100644
index 000..38fd1eb
--- /dev/null
+++ b/.github/workflows/daily-jdk14-build.yml
@@ -0,0 +1,85 @@
+#
+# 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.
+#
+
+name: Daily JDK 14 Build
+
+env:
+ MAVEN_ARGS: -V -ntp
+
+on:
+ schedule:
+# Run every day at 2 am
+- cron: '0 2 * * *'
+ workflow_dispatch:
+
+jobs:
+ build:
+runs-on: ubuntu-latest
+strategy:
+ matrix:
+java: [ '14' ]
+steps:
+ - uses: actions/checkout@v1
+ - name: Set up JDK ${{ matrix.java }}
+uses: AdoptOpenJDK/install-jdk@v1
+with:
+ version: ${{ matrix.java }}
+ - name: Cache local Maven repository
+uses: actions/cache@v2
+with:
+ path: ~/.m2/repository
+ key: ${{ runner.os }}-maven-${{ hashFiles('**/pom.xml') }}
+ restore-keys: |
+${{ runner.os }}-maven-
+ # first command builds the source check module,
+ - name: build tools
+run: |
+ ./mvnw ${MAVEN_ARGS} \
+-DskipTests \
+-pl :parent \
+-pl :camel-kafka-connector-aggregator \
+-pl :camel-buildtools \
+clean install
+ # second one source check and install
:camel-kafka-connector-generator-maven-plugin
+ # this is needed to add maven plugin metadata to it,
+ - name: build connector-generator-plugin
+run: |
+ ./mvnw ${MAVEN_ARGS} \
+-Dcheckstyle.failOnViolation=true \
+-Psourcecheck \
+-DskipTests \
+-pl :camel-kafka-connector-model \
+-pl :camel-kafka-connector-generator-maven-plugin \
+clean install
+ # third command source check everything else but
:camel-kafka-connector-generator-maven-plugin
+ - name: build and itests
+run: |
+ ./mvnw ${MAVEN_ARGS} \
+-Dcheckstyle.failOnViolation=true \
+-Psourcecheck \
+-DskipIntegrationTests=false \
+-Dhttp.keepAlive=false \
+-Dmaven.wagon.http.pool=false \
+-Dmaven.wagon.httpconnectionManager.ttlSeconds=120 \
+-pl '!:camel-kafka-connector-generator-maven-plugin' \
+clean test
+ - name: archive logs
+uses: actions/upload-artifact@v2
+if: always()
+with:
+ name: test-logs
+ path: tests/**/target/tests.log
\ No newline at end of file
[GitHub] [camel-kafka-connector] orpiske merged pull request #907: Added new daily JDK 14 build on github actions
orpiske merged pull request #907: URL: https://github.com/apache/camel-kafka-connector/pull/907 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-examples] branch master updated: CAMEL-16056: flight recorder example
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-examples.git
The following commit(s) were added to refs/heads/master by this push:
new ae9b93c CAMEL-16056: flight recorder example
ae9b93c is described below
commit ae9b93c0d92a798d1bb00b436446b1ac326685c4
Author: Claus Ibsen
AuthorDate: Thu Jan 21 09:31:03 2021 +0100
CAMEL-16056: flight recorder example
---
.../src/main/java/org/apache/camel/example/MyApplication.java | 3 ---
.../src/main/resources/application.properties | 1 +
2 files changed, 1 insertion(+), 3 deletions(-)
diff --git
a/examples/camel-example-flight-recorder/src/main/java/org/apache/camel/example/MyApplication.java
b/examples/camel-example-flight-recorder/src/main/java/org/apache/camel/example/MyApplication.java
index 34decfb..496b37d 100644
---
a/examples/camel-example-flight-recorder/src/main/java/org/apache/camel/example/MyApplication.java
+++
b/examples/camel-example-flight-recorder/src/main/java/org/apache/camel/example/MyApplication.java
@@ -27,9 +27,6 @@ public final class MyApplication {
}
public static void main(String[] args) throws Exception {
-//System.out.println(">>> sleep 10 ");
-//Thread.sleep(1);
-
// use Camels Main class
Main main = new Main();
// and add the routes (you can specify multiple classes)
diff --git
a/examples/camel-example-flight-recorder/src/main/resources/application.properties
b/examples/camel-example-flight-recorder/src/main/resources/application.properties
index d2c6005..1e78599 100644
---
a/examples/camel-example-flight-recorder/src/main/resources/application.properties
+++
b/examples/camel-example-flight-recorder/src/main/resources/application.properties
@@ -30,6 +30,7 @@ camel.main.startup-recorder-recording = true
# what JFR profile to use (default or profile) the profile controls what and
how much data to capture and record
#camel.main.startup-recorder-profile = profile
# to keep recording for 60 seconds and will be auto-saved on timeout
+# you can also specify -1 to keep recording until the JVM terminates
# by default the recording is saved when Camel has been started (short lived)
#camel.main.startup-recorder-duration = 60
[GitHub] [camel-k] squakez opened a new pull request #1927: chore(examples): kamelets properties fix
squakez opened a new pull request #1927: URL: https://github.com/apache/camel-k/pull/1927 **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] nicolaferraro merged pull request #1926: Fix saga example
nicolaferraro merged pull request #1926: URL: https://github.com/apache/camel-k/pull/1926 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] 01/02: Use http component instead of undertow since it is not present in camel-quarkus
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
commit 5aecf2bb80592bf77fac64d17e7b2dbac3d3c78c
Author: James Netherton
AuthorDate: Wed Jan 20 16:29:51 2021 +
Use http component instead of undertow since it is not present in
camel-quarkus
---
examples/saga/Flight.java | 3 ++-
examples/saga/Saga.java | 4 ++--
examples/saga/Train.java | 3 ++-
3 files changed, 6 insertions(+), 4 deletions(-)
diff --git a/examples/saga/Flight.java b/examples/saga/Flight.java
index 24d8e0d..cfe8a8a 100644
--- a/examples/saga/Flight.java
+++ b/examples/saga/Flight.java
@@ -37,7 +37,8 @@ public class Flight extends RouteBuilder {
.option("id", header("id"))
.compensation("direct:cancelPurchase")
.log("Buying flight #${header.id}")
-
.to("undertow:http://payment/api/pay?bridgeEndpoint=true&type=flight";)
+.removeHeaders("CamelHttp.*")
+
.to("http://payment/api/pay?httpMethod=POST&type=flight";)
.log("Payment for flight #${header.id} done");
from("direct:cancelPurchase")
diff --git a/examples/saga/Saga.java b/examples/saga/Saga.java
index ca6a386..ccaa78a 100644
--- a/examples/saga/Saga.java
+++ b/examples/saga/Saga.java
@@ -35,8 +35,8 @@ public class Saga extends RouteBuilder {
.setHeader("id", header(Exchange.TIMER_COUNTER))
.setHeader(Exchange.HTTP_METHOD, constant("POST"))
.log("Executing saga #${header.id}")
- .to("undertow:http://train/api/train/buy/seat";)
- .to("undertow:http://flight/api/flight/buy";);
+
.to("http://train/api/train/buy/seat?bridgeEndpoint=true";)
+ .to("http://flight/api/flight/buy?bridgeEndpoint=true";);
}
}
diff --git a/examples/saga/Train.java b/examples/saga/Train.java
index 429df5f..b46704d 100644
--- a/examples/saga/Train.java
+++ b/examples/saga/Train.java
@@ -37,7 +37,8 @@ public class Train extends RouteBuilder {
.option("id", header("id"))
.compensation("direct:cancelPurchase")
.log("Buying train seat #${header.id}")
-
.to("undertow:http://payment/api/pay?bridgeEndpoint=true&type=train";)
+.removeHeaders("CamelHttp.*")
+.to("http://payment/api/pay?httpMethod=POST&type=train";)
.log("Payment for train #${header.id} done");
from("direct:cancelPurchase")
[camel-k] branch master updated (098e835 -> 72cc1dd)
This is an automated email from the ASF dual-hosted git repository. nferraro pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel-k.git. from 098e835 feat(cli): retrieve version from IntegrationPlatform new 5aecf2b Use http component instead of undertow since it is not present in camel-quarkus new 72cc1dd Fix routes-discovery.enabled property name 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: examples/saga/Flight.java | 3 ++- examples/saga/Saga.java| 4 ++-- examples/saga/Train.java | 3 ++- pkg/builder/runtime/quarkus.go | 2 +- 4 files changed, 7 insertions(+), 5 deletions(-)
[camel-k] 02/02: Fix routes-discovery.enabled property name
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
commit 72cc1dd3e165c99c84623e08e2a94ef2e4fbca2a
Author: James Netherton
AuthorDate: Thu Jan 21 07:21:01 2021 +
Fix routes-discovery.enabled property name
---
examples/saga/Flight.java | 2 +-
pkg/builder/runtime/quarkus.go | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/examples/saga/Flight.java b/examples/saga/Flight.java
index cfe8a8a..5aacbd9 100644
--- a/examples/saga/Flight.java
+++ b/examples/saga/Flight.java
@@ -37,7 +37,7 @@ public class Flight extends RouteBuilder {
.option("id", header("id"))
.compensation("direct:cancelPurchase")
.log("Buying flight #${header.id}")
-.removeHeaders("CamelHttp.*")
+ .removeHeaders("CamelHttp.*")
.to("http://payment/api/pay?httpMethod=POST&type=flight";)
.log("Payment for flight #${header.id} done");
diff --git a/pkg/builder/runtime/quarkus.go b/pkg/builder/runtime/quarkus.go
index a98faba..53c1c22 100644
--- a/pkg/builder/runtime/quarkus.go
+++ b/pkg/builder/runtime/quarkus.go
@@ -83,7 +83,7 @@ func GenerateQuarkusProjectCommon(camelQuarkusVersion string,
runtimeVersion str
// this to happen as routes are loaded at runtime and looking for
// routes at build time may try to load camel-k-runtime routes builder
// proxies which in some case may fail
- p.Properties["quarkus.camel.main.routes-discovery.enabled"] = "false"
+ p.Properties["quarkus.camel.routes-discovery.enabled"] = "false"
// disable quarkus banner ...
p.Properties["quarkus.banner.enabled"] = "false"
[camel-k] branch master updated (72cc1dd -> 5b08073)
This is an automated email from the ASF dual-hosted git repository. nferraro pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel-k.git. from 72cc1dd Fix routes-discovery.enabled property name new c9f7ba1 Fix image location extraction. new 5b08073 Fix comment. 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: pkg/cmd/util_containerization.go | 7 +-- pkg/util/docker/docker.go| 13 ++--- 2 files changed, 11 insertions(+), 9 deletions(-)
[camel-k] 02/02: Fix comment.
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
commit 5b08073054a43ee170e48e2e8329826a30984e42
Author: Doru Bercea
AuthorDate: Wed Jan 20 18:09:00 2021 -0500
Fix comment.
---
pkg/util/docker/docker.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pkg/util/docker/docker.go b/pkg/util/docker/docker.go
index 6a777d3..812d8f1 100644
--- a/pkg/util/docker/docker.go
+++ b/pkg/util/docker/docker.go
@@ -153,6 +153,6 @@ func ExtractRegistryName(image string) (string, error) {
return "", errors.New("image path is too short, usage:
registry/imageName or registry/*/imageName")
}
- // Register name is given by the path to the image.
+ // Registry name is given by the path to the image.
return strings.Join(pathComponents[0:len(pathComponents)-1],
containerFileSeparator), nil
}
[camel-k] 01/02: Fix image location extraction.
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
commit c9f7ba1699da2b2b6dbca91e3b039054945545cb
Author: Doru Bercea
AuthorDate: Wed Jan 20 17:35:09 2021 -0500
Fix image location extraction.
---
pkg/cmd/util_containerization.go | 7 +--
pkg/util/docker/docker.go| 13 ++---
2 files changed, 11 insertions(+), 9 deletions(-)
diff --git a/pkg/cmd/util_containerization.go b/pkg/cmd/util_containerization.go
index dcbd97a..f633a0e 100644
--- a/pkg/cmd/util_containerization.go
+++ b/pkg/cmd/util_containerization.go
@@ -87,7 +87,7 @@ func setDockerEnvVars(envVars []string) {
}
}
-func createAndBuildBaseImage(ctx context.Context, containerRegistry string)
error {
+func createAndBuildBaseImage(ctx context.Context) error {
// Create the base image Docker file.
err := docker.CreateBaseImageDockerFile()
if err != nil {
@@ -117,6 +117,9 @@ func createAndBuildIntegrationImage(ctx context.Context,
containerRegistry strin
}
docker.RegistryName = containerRegistry
+
+ // If we build a normal image, i.e. not the base image, we need to parse
+ // the location where images will be pushed.
if !justBaseImage {
registryName, err := docker.ExtractRegistryName(image)
if err != nil {
@@ -127,7 +130,7 @@ func createAndBuildIntegrationImage(ctx context.Context,
containerRegistry strin
}
// Create the Dockerfile and build the base image.
- err := createAndBuildBaseImage(ctx, containerRegistry)
+ err := createAndBuildBaseImage(ctx)
if err != nil {
return err
}
diff --git a/pkg/util/docker/docker.go b/pkg/util/docker/docker.go
index 228332d..6a777d3 100644
--- a/pkg/util/docker/docker.go
+++ b/pkg/util/docker/docker.go
@@ -146,14 +146,13 @@ func ExtractRegistryName(image string) (string, error) {
// There must be at least two components in the path:
// - docker.io/registry/imageName
- // - registry/imageName
+ // - localhost:5000//imageName
+ // - localhost:5000//...//imageName
+ // - localhost:5000/imageName
if len(pathComponents) < 2 {
- return "", errors.New("image path is too short, usage:
docker.io/registry/imageName or registry/imageName")
+ return "", errors.New("image path is too short, usage:
registry/imageName or registry/*/imageName")
}
- // Check if path starts with docker.io if not, add it.
- if pathComponents[0] == "docker.io" {
- return strings.Join(pathComponents[0:2],
containerFileSeparator), nil
- }
- return "docker.io" + containerFileSeparator + pathComponents[1], nil
+ // Register name is given by the path to the image.
+ return strings.Join(pathComponents[0:len(pathComponents)-1],
containerFileSeparator), nil
}
[GitHub] [camel-k] nicolaferraro merged pull request #1925: Fix image location extraction
nicolaferraro merged pull request #1925: URL: https://github.com/apache/camel-k/pull/1925 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] squakez commented on issue #1881: Corrupted binaries attached as resource
squakez commented on issue #1881: URL: https://github.com/apache/camel-k/issues/1881#issuecomment-764486356 I am having a look at this. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] orpiske opened a new pull request #4905: (chores) camel-beanstalk: cleanups
orpiske opened a new pull request #4905: URL: https://github.com/apache/camel/pull/4905 - Make it easier to spot which of the act calls raise would raise the Exception - Remove unnecessary String formatting around logs - Remove unnecessary log guards - [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] oscerd merged pull request #4905: (chores) camel-beanstalk: cleanups
oscerd merged pull request #4905: URL: https://github.com/apache/camel/pull/4905 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) camel-beanstalk: cleanups
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new 1593e07 (chores) camel-beanstalk: cleanups
1593e07 is described below
commit 1593e0738378f31df291a0edd0cda702a5819c9e
Author: Otavio Rodolfo Piske
AuthorDate: Thu Jan 21 09:49:16 2021 +0100
(chores) camel-beanstalk: cleanups
- Make it easier to spot which of the act calls raise would raise the
Exception
- Remove unnecessary String formatting around logs
- Remove unnecessary log guards
---
.../component/beanstalk/BeanstalkConsumer.java | 29 +++---
.../component/beanstalk/BeanstalkProducer.java | 18 --
.../beanstalk/processors/BuryCommand.java | 4 +--
.../beanstalk/processors/DeleteCommand.java| 8 +++---
.../beanstalk/processors/KickCommand.java | 5 ++--
.../component/beanstalk/processors/PutCommand.java | 7 +++---
.../beanstalk/processors/ReleaseCommand.java | 9 +++
.../beanstalk/processors/TouchCommand.java | 8 +++---
8 files changed, 45 insertions(+), 43 deletions(-)
diff --git
a/components/camel-beanstalk/src/main/java/org/apache/camel/component/beanstalk/BeanstalkConsumer.java
b/components/camel-beanstalk/src/main/java/org/apache/camel/component/beanstalk/BeanstalkConsumer.java
index 540c5f2..b652e9e 100644
---
a/components/camel-beanstalk/src/main/java/org/apache/camel/component/beanstalk/BeanstalkConsumer.java
+++
b/components/camel-beanstalk/src/main/java/org/apache/camel/component/beanstalk/BeanstalkConsumer.java
@@ -225,7 +225,7 @@ public class BeanstalkConsumer extends
ScheduledPollConsumer {
try {
executor.submit(new RunCommand(successCommand,
exchange)).get();
} catch (Exception e) {
-LOG.error(String.format("Could not run completion of exchange
%s", exchange), e);
+LOG.error("Could not run completion of exchange {}", exchange,
e);
}
}
@@ -234,9 +234,7 @@ public class BeanstalkConsumer extends
ScheduledPollConsumer {
try {
executor.submit(new RunCommand(failureCommand,
exchange)).get();
} catch (Exception e) {
-LOG.error(
-String.format("%s could not run failure of exchange
%s", failureCommand.getClass().getName(), exchange),
-e);
+LOG.error("{} could not run failure of exchange {}",
failureCommand.getClass().getName(), exchange, e);
}
}
@@ -252,20 +250,23 @@ public class BeanstalkConsumer extends
ScheduledPollConsumer {
@Override
public void run() {
try {
-try {
-command.act(client, exchange);
-} catch (BeanstalkException e) {
-LOG.warn(String.format("Post-processing %s of exchange
%s failed, retrying.",
-command.getClass().getName(), exchange), e);
-resetClient();
-command.act(client, exchange);
-}
+doPostProcess();
} catch (final Exception e) {
-LOG.error(String.format("%s could not post-process
exchange %s", command.getClass().getName(), exchange),
-e);
+LOG.error("{} could not post-process exchange {}",
command.getClass().getName(), exchange, e);
exchange.setException(e);
}
}
+
+private void doPostProcess() throws Exception {
+try {
+command.act(client, exchange);
+} catch (BeanstalkException e) {
+LOG.warn("Post-processing {} of exchange {} failed,
retrying.", command.getClass().getName(),
+exchange, e);
+resetClient();
+command.act(client, exchange);
+}
+}
}
}
}
diff --git
a/components/camel-beanstalk/src/main/java/org/apache/camel/component/beanstalk/BeanstalkProducer.java
b/components/camel-beanstalk/src/main/java/org/apache/camel/component/beanstalk/BeanstalkProducer.java
index 393cff7..25ac782 100644
---
a/components/camel-beanstalk/src/main/java/org/apache/camel/component/beanstalk/BeanstalkProducer.java
+++
b/components/camel-beanstalk/src/main/java/org/apache/camel/component/beanstalk/BeanstalkProducer.java
@@ -109,13 +109,7 @@ public class BeanstalkProducer extends
DefaultAsyncProducer {
@Override
public void run() {
try {
-try {
-command.act(client, exchange);
-} catch (BeanstalkException e) {
[GitHub] [camel-k] astefanutti commented on pull request #1816: Add option to save transitive dependencies into custom location
astefanutti commented on pull request #1816: URL: https://github.com/apache/camel-k/pull/1816#issuecomment-764488173 @doru1004 thanks, it seems you're a lot more capable than me to formalise what's in my mind 😉! 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 #1928: Provide a way to use kamelet ID in binding
nicolaferraro opened a new issue #1928:
URL: https://github.com/apache/camel-k/issues/1928
People can use this syntax to create a specific Kamelet configuration:
```
from("kamelet:mykamelet/myid")...
```
Then they can set properties like `camel.kamelet.mykamelet.myid.xxx=yyy`,
where `xxx` is the Kamelet ID (that internally translates into a route ID at
runtime). Those properties can also be set in auto-loaded secrets (with special
annotations).
But there's no way to use this mechanism in a KameletBinding. I'm thinking
to make an implicit `id` property in all Kamelets (which can be forbidden in
the spec-definition) and can be used to set the endpoint path.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
[camel-spring-boot] branch master updated: Regen
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/master by this push:
new 2a4996c Regen
2a4996c is described below
commit 2a4996ca84958bddcdc4f88204ab5128461402ef
Author: Claus Ibsen
AuthorDate: Thu Jan 21 10:16:16 2021 +0100
Regen
---
.../springboot/catalog/components/activemq.json | 2 ++
.../camel/springboot/catalog/components/amqp.json | 2 ++
.../camel/springboot/catalog/components/jms.json| 2 ++
.../src/main/docs/activemq-starter.adoc | 3 ++-
.../springboot/ActiveMQComponentConfiguration.java | 21 +
.../src/main/docs/amqp-starter.adoc | 3 ++-
.../amqp/springboot/AMQPComponentConfiguration.java | 21 +
.../src/main/docs/jms-starter.adoc | 3 ++-
.../jms/springboot/JmsComponentConfiguration.java | 21 +
docs/modules/ROOT/pages/activemq-starter.adoc | 3 ++-
docs/modules/ROOT/pages/amqp-starter.adoc | 3 ++-
docs/modules/ROOT/pages/jms-starter.adoc| 3 ++-
12 files changed, 81 insertions(+), 6 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/activemq.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/activemq.json
index d9b3819..bd69cc0 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/activemq.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/activemq.json
@@ -33,6 +33,7 @@
"usePooledConnection": { "kind": "property", "displayName": "Use Pooled
Connection", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "defaultValue": true, "description":
"Enables or disables whether a PooledConnectionFactory will be used so that
when messages are sent to ActiveMQ from outside of a message consuming thread,
pooling will be used rather tha [...]
"useSingleConnection": { "kind": "property", "displayName": "Use Single
Connection", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "defaultValue": false, "description":
"Enables or disables whether a Spring SingleConnectionFactory will be used so
that when messages are sent to ActiveMQ from outside of a message consuming
thread, pooling will be used ra [...]
"acknowledgementModeName": { "kind": "property", "displayName":
"Acknowledgement Mode Name", "group": "consumer", "label": "consumer",
"required": false, "type": "string", "javaType": "java.lang.String", "enum": [
"SESSION_TRANSACTED", "CLIENT_ACKNOWLEDGE", "AUTO_ACKNOWLEDGE",
"DUPS_OK_ACKNOWLEDGE" ], "deprecated": false, "autowired": false, "secret":
false, "defaultValue": "AUTO_ACKNOWLEDGE", "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationFiel [...]
+"artemisConsumerPriority": { "kind": "property", "displayName": "Artemis
Consumer Priority", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Consumer priorities allow you to ensure that
high priority consumers receive messages while they are active. N [...]
"asyncConsumer": { "kind": "property", "displayName": "Async Consumer",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Whether the JmsConsumer processes the Exchange
asynchronously. If enabled then the JmsConsumer may picku [...]
"autoStartup": { "kind": "property", "displayName": "Auto Startup",
"group": "consumer", "label": "consumer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.jms.JmsConfiguration", "configurationField":
"configuration", "description": "Specifies whether the consumer container
should auto-startup." },
"cacheLevel": { "kind": "property", "displayName": "Cache Level", "group":
"consumer", "label": "consumer", "required": false, "type": "integer",
"javaType
[camel-examples] branch master updated: CAMEL-16056: flight recorder example
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-examples.git The following commit(s) were added to refs/heads/master by this push: new 5f0d860 CAMEL-16056: flight recorder example 5f0d860 is described below commit 5f0d860e4889355b874c0420f1ed5491fd0d051d Author: Claus Ibsen AuthorDate: Thu Jan 21 10:29:44 2021 +0100 CAMEL-16056: flight recorder example --- .../src/main/resources/application.properties | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/examples/camel-example-flight-recorder/src/main/resources/application.properties b/examples/camel-example-flight-recorder/src/main/resources/application.properties index 1e78599..7e59fdb 100644 --- a/examples/camel-example-flight-recorder/src/main/resources/application.properties +++ b/examples/camel-example-flight-recorder/src/main/resources/application.properties @@ -30,8 +30,8 @@ camel.main.startup-recorder-recording = true # what JFR profile to use (default or profile) the profile controls what and how much data to capture and record #camel.main.startup-recorder-profile = profile # to keep recording for 60 seconds and will be auto-saved on timeout -# you can also specify -1 to keep recording until the JVM terminates -# by default the recording is saved when Camel has been started (short lived) +# you can also use -1 to only record Camel startup and save the recording right after Camel has been started +# this can be used to solely focus on Camel startup performance bottlenecks #camel.main.startup-recorder-duration = 60 # run in lightweight mode to be tiny as possible
[camel-spring-boot] branch master updated: CAMEL-16056: Added camel-jfr for java flight recorder integration
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git The following commit(s) were added to refs/heads/master by this push: new 9c99e3a CAMEL-16056: Added camel-jfr for java flight recorder integration 9c99e3a is described below commit 9c99e3a5ab884c3389e15313c13096810710534c Author: Claus Ibsen AuthorDate: Thu Jan 21 10:32:27 2021 +0100 CAMEL-16056: Added camel-jfr for java flight recorder integration --- core/camel-spring-boot/src/main/docs/spring-boot.adoc| 2 +- .../org/apache/camel/spring/boot/CamelConfigurationProperties.java | 5 +++-- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/core/camel-spring-boot/src/main/docs/spring-boot.adoc b/core/camel-spring-boot/src/main/docs/spring-boot.adoc index 60878db..d90c23be 100644 --- a/core/camel-spring-boot/src/main/docs/spring-boot.adoc +++ b/core/camel-spring-boot/src/main/docs/spring-boot.adoc @@ -202,7 +202,7 @@ The component supports 165 options, which are listed below. | *camel.springboot.shutdown-timeout* | Timeout in seconds to graceful shutdown Camel. | 300 | Integer | *camel.springboot.startup-recorder* | To use startup recorder for capturing execution time during starting Camel. The recorder can be one of: false, logging, java-flight-recorder The default is false. | false | String | *camel.springboot.startup-recorder-dir* | Directory to store the recording. By default the user home directory will be used. Use false to turn off saving recording to disk. | | String -| *camel.springboot.startup-recorder-duration* | How long time to run the startup recorder. Use 0 (default) to stop the recorder after Camel has been started. Use -1 to keep the recorder running until the JVM is being stopped. A positive value is to run the recorder for N seconds. When the recorder is stopped then the recording is auto saved to disk (note: save to disk can be disabled by setting startupRecorderDir to false) | 0 | Long +| *camel.springboot.startup-recorder-duration* | How long time to run the startup recorder. Use 0 (default) to keep the recorder running until the JVM is exited. Use -1 to stop the recorder right after Camel has been started (to only focus on potential Camel startup performance bottlenecks) Use a positive value to keep recording for N seconds. When the recorder is stopped then the recording is auto saved to disk (note: save to disk can be disabled by setting startupRecorderDir to false) [...] | *camel.springboot.startup-recorder-max-depth* | To filter our sub steps at a maximum depth. Use -1 for no maximum. Use 0 for no sub steps. Use 1 for max 1 sub step, and so forth. The default is -1. | -1 | Integer | *camel.springboot.startup-recorder-profile* | To use a specific Java Flight Recorder profile configuration, such as default or profile. The default is default. | default | String | *camel.springboot.startup-recorder-recording* | To enable Java Flight Recorder to start a recording and automatic dump the recording to disk after startup is complete. This requires that camel-jfr is on the classpath. The default is true. | true | Boolean diff --git a/core/camel-spring-boot/src/main/java/org/apache/camel/spring/boot/CamelConfigurationProperties.java b/core/camel-spring-boot/src/main/java/org/apache/camel/spring/boot/CamelConfigurationProperties.java index 2828e49..3d8eb57 100644 --- a/core/camel-spring-boot/src/main/java/org/apache/camel/spring/boot/CamelConfigurationProperties.java +++ b/core/camel-spring-boot/src/main/java/org/apache/camel/spring/boot/CamelConfigurationProperties.java @@ -703,8 +703,9 @@ public class CamelConfigurationProperties extends DefaultConfigurationProperties /** * How long time to run the startup recorder. * - * Use 0 (default) to stop the recorder after Camel has been started. Use -1 to keep the recorder running until - * the JVM is being stopped. A positive value is to run the recorder for N seconds. + * Use 0 (default) to keep the recorder running until the JVM is exited. + * Use -1 to stop the recorder right after Camel has been started (to only focus on potential Camel startup performance bottlenecks) + * Use a positive value to keep recording for N seconds. * * When the recorder is stopped then the recording is auto saved to disk * (note: save to disk can be disabled by setting startupRecorderDir to false)
[GitHub] [camel-quarkus] ppalaga opened a new issue #2156: Consider supporting Quarkus Dev UI in our extensions
ppalaga opened a new issue #2156: URL: https://github.com/apache/camel-quarkus/issues/2156 Since Quarkus 1.11.0.Final, there is Quarkus Dev UI, see https://quarkus.io/guides/dev-ui It allows to quickly visualise all the extensions currently loaded, see their status and go directly to their documentation. The good news is that the docs links work for Camel Quarkus extensions. On top of that, each extension can add: * [Custom useful bits of runtime information in the overview](https://quarkus.io/guides/dev-ui#how-can-i-make-my-extension-support-the-dev-console) * [Full custom pages](https://quarkus.io/guides/dev-ui#adding-full-pages) * [Interactive pages with actions](https://quarkus.io/guides/dev-ui#advanced-usage-adding-actions) I wonder which of the above should we support? See also https://github.com/quarkusio/quarkus/issues/14471 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 merged pull request #2154: Avoid usage of deprecated capabilities string constants
jamesnetherton merged pull request #2154: URL: https://github.com/apache/camel-quarkus/pull/2154 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: Avoid usage of deprecated capabilities string constants
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 3770917 Avoid usage of deprecated capabilities string constants
3770917 is described below
commit 3770917afb695a7cc103fb6d69b5e8012163e67b
Author: James Netherton
AuthorDate: Thu Jan 21 07:46:47 2021 +
Avoid usage of deprecated capabilities string constants
---
.../apache/camel/quarkus/component/jta/deployment/JtaProcessor.java| 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/extensions/jta/deployment/src/main/java/org/apache/camel/quarkus/component/jta/deployment/JtaProcessor.java
b/extensions/jta/deployment/src/main/java/org/apache/camel/quarkus/component/jta/deployment/JtaProcessor.java
index 6e4f757..2a6f389 100644
---
a/extensions/jta/deployment/src/main/java/org/apache/camel/quarkus/component/jta/deployment/JtaProcessor.java
+++
b/extensions/jta/deployment/src/main/java/org/apache/camel/quarkus/component/jta/deployment/JtaProcessor.java
@@ -19,6 +19,7 @@ package org.apache.camel.quarkus.component.jta.deployment;
import com.arjuna.ats.internal.arjuna.utils.SocketProcessId;
import io.quarkus.arc.deployment.AdditionalBeanBuildItem;
import io.quarkus.deployment.Capabilities;
+import io.quarkus.deployment.Capability;
import io.quarkus.deployment.annotations.BuildProducer;
import io.quarkus.deployment.annotations.BuildStep;
import io.quarkus.deployment.builditem.FeatureBuildItem;
@@ -44,7 +45,7 @@ class JtaProcessor {
BuildProducer additionalBeans,
BuildProducer reflectiveClass,
Capabilities capabilities) {
-if (capabilities.isCapabilityPresent(Capabilities.TRANSACTIONS)) {
+if (capabilities.isPresent(Capability.TRANSACTIONS)) {
AdditionalBeanBuildItem.Builder builder =
AdditionalBeanBuildItem.builder();
builder.addBeanClass(RequiredJtaTransactionPolicy.class);
builder.addBeanClass(RequiresNewJtaTransactionPolicy.class);
[GitHub] [camel-quarkus] jamesnetherton commented on issue #2007: Figure out how we could leverage Quarkus Developer Console
jamesnetherton commented on issue #2007: URL: https://github.com/apache/camel-quarkus/issues/2007#issuecomment-764508409 Superseded by #2156. 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 #2007: Figure out how we could leverage Quarkus Developer Console
jamesnetherton closed issue #2007: URL: https://github.com/apache/camel-quarkus/issues/2007 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 (1593e07 -> 9f9ad60)
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel.git. from 1593e07 (chores) camel-beanstalk: cleanups new 2d740d8 camel-core - Optimize as the lambda code causes JVM compiler internally to throw an java.lang.NoSuchMethodError when it compiles the lambda code. JDK mission control reports this. new 9f9ad60 CAMEL-16056: Added camel-jfr for java flight recorder integration 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: .../jfr/FlightRecorderStartupStepRecorder.java | 6 ++-- .../java/org/apache/camel/impl/DefaultModel.java | 35 +++--- .../camel-main-configuration-metadata.json | 2 +- core/camel-main/src/main/docs/main.adoc| 2 +- .../camel/main/DefaultConfigurationProperties.java | 10 --- 5 files changed, 35 insertions(+), 20 deletions(-)
[camel] 01/02: camel-core - Optimize as the lambda code causes JVM compiler internally to throw an java.lang.NoSuchMethodError when it compiles the lambda code. JDK mission control reports this.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 2d740d82ac2eac1b8961aac7a2330bb0463c4bb9
Author: Claus Ibsen
AuthorDate: Thu Jan 21 09:51:19 2021 +0100
camel-core - Optimize as the lambda code causes JVM compiler internally to
throw an java.lang.NoSuchMethodError when it compiles the lambda code. JDK
mission control reports this.
---
.../java/org/apache/camel/impl/DefaultModel.java | 35 +++---
1 file changed, 24 insertions(+), 11 deletions(-)
diff --git
a/core/camel-core-engine/src/main/java/org/apache/camel/impl/DefaultModel.java
b/core/camel-core-engine/src/main/java/org/apache/camel/impl/DefaultModel.java
index 1fc5736..042fe76 100644
---
a/core/camel-core-engine/src/main/java/org/apache/camel/impl/DefaultModel.java
+++
b/core/camel-core-engine/src/main/java/org/apache/camel/impl/DefaultModel.java
@@ -94,18 +94,28 @@ public class DefaultModel implements Model {
if (routeDefinitions == null || routeDefinitions.isEmpty()) {
return;
}
-List list = new ArrayList<>();
-routeDefinitions.forEach(r -> {
-if (routeFilter == null || routeFilter.apply(r)) {
-list.add(r);
+
+List list;
+if (routeFilter == null) {
+list = new ArrayList<>(routeDefinitions);
+} else {
+list = new ArrayList<>();
+for (RouteDefinition r : routeDefinitions) {
+if (routeFilter.apply(r)) {
+list.add(r);
+}
}
-});
+}
removeRouteDefinitions(list);
-list.forEach(r -> {
-modelLifecycleStrategies.forEach(s -> s.onAddRouteDefinition(r));
+
+for (RouteDefinition r : list) {
+for (ModelLifecycleStrategy s : modelLifecycleStrategies) {
+s.onAddRouteDefinition(r);
+}
this.routeDefinitions.add(r);
-});
+}
+
if (shouldStartRoutes()) {
getCamelContext().adapt(ModelCamelContext.class).startRouteDefinitions(list);
}
@@ -174,10 +184,13 @@ public class DefaultModel implements Model {
if (routeTemplateDefinitions == null ||
routeTemplateDefinitions.isEmpty()) {
return;
}
-routeTemplateDefinitions.forEach(r -> {
-modelLifecycleStrategies.forEach(s ->
s.onAddRouteTemplateDefinition(r));
+
+for (RouteTemplateDefinition r : routeTemplateDefinitions) {
+for (ModelLifecycleStrategy s : modelLifecycleStrategies) {
+s.onAddRouteTemplateDefinition(r);
+}
this.routeTemplateDefinitions.add(r);
-});
+}
}
@Override
[camel] 02/02: CAMEL-16056: Added camel-jfr for java flight recorder integration
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 9f9ad60bb15563e78c39368f4a880b1341498bfb
Author: Claus Ibsen
AuthorDate: Thu Jan 21 10:37:50 2021 +0100
CAMEL-16056: Added camel-jfr for java flight recorder integration
---
.../camel/startup/jfr/FlightRecorderStartupStepRecorder.java | 6 +++---
.../resources/META-INF/camel-main-configuration-metadata.json | 2 +-
core/camel-main/src/main/docs/main.adoc| 2 +-
.../org/apache/camel/main/DefaultConfigurationProperties.java | 10 ++
4 files changed, 11 insertions(+), 9 deletions(-)
diff --git
a/components/camel-jfr/src/main/java/org/apache/camel/startup/jfr/FlightRecorderStartupStepRecorder.java
b/components/camel-jfr/src/main/java/org/apache/camel/startup/jfr/FlightRecorderStartupStepRecorder.java
index 3a1370c..40f0f08 100644
---
a/components/camel-jfr/src/main/java/org/apache/camel/startup/jfr/FlightRecorderStartupStepRecorder.java
+++
b/components/camel-jfr/src/main/java/org/apache/camel/startup/jfr/FlightRecorderStartupStepRecorder.java
@@ -53,7 +53,7 @@ public class FlightRecorderStartupStepRecorder extends
DefaultStartupStepRecorde
Configuration config =
Configuration.getConfiguration(getRecordingProfile());
rec = new Recording(config);
rec.setName("Camel Recording");
-if (getStartupRecorderDuration() < 0) {
+if (getStartupRecorderDuration() == 0) {
Path dir = getRecordingDir() != null ?
Paths.get(getRecordingDir()) : Paths.get(System.getenv().get("HOME"));
Path file = Files.createTempFile(dir, "camel-recording",
".jfr");
rec.setDumpOnExit(true);
@@ -88,7 +88,7 @@ public class FlightRecorderStartupStepRecorder extends
DefaultStartupStepRecorde
public void doStop() throws Exception {
super.doStop();
-if (rec != null && getStartupRecorderDuration() >= 0) {
+if (rec != null && getStartupRecorderDuration() != 0) {
dumpRecording();
}
}
@@ -97,7 +97,7 @@ public class FlightRecorderStartupStepRecorder extends
DefaultStartupStepRecorde
if (!"false".equals(getRecordingDir())) {
try {
Path dir = getRecordingDir() != null ?
Paths.get(getRecordingDir()) : Paths.get(System.getenv().get("HOME"));
-Path file = Files.createTempFile(dir, "camel-recording",
".jfr");
+Path file = Files.createTempFile(dir, "camel-recording-",
".jfr");
if (rec.getState().equals(RecordingState.RUNNING)) {
// need to do GC to capture details to the recording
(specially when its short running)
LOG.info("Stopping Java flight recorder");
diff --git
a/core/camel-main/src/generated/resources/META-INF/camel-main-configuration-metadata.json
b/core/camel-main/src/generated/resources/META-INF/camel-main-configuration-metadata.json
index 904371c..7e90a22 100644
---
a/core/camel-main/src/generated/resources/META-INF/camel-main-configuration-metadata.json
+++
b/core/camel-main/src/generated/resources/META-INF/camel-main-configuration-metadata.json
@@ -73,7 +73,7 @@
{ "name": "camel.main.shutdownTimeout", "description": "Timeout in seconds
to graceful shutdown Camel.", "sourceType":
"org.apache.camel.main.DefaultConfigurationProperties", "type": "integer",
"javaType": "int", "defaultValue": 45 },
{ "name": "camel.main.startupRecorder", "description": "To use startup
recorder for capturing execution time during starting Camel. The recorder can
be one of: false, logging, java-flight-recorder The default is false.",
"sourceType": "org.apache.camel.main.DefaultConfigurationProperties", "type":
"string", "javaType": "java.lang.String" },
{ "name": "camel.main.startupRecorderDir", "description": "Directory to
store the recording. By default the user home directory will be used. Use false
to turn off saving recording to disk.", "sourceType":
"org.apache.camel.main.DefaultConfigurationProperties", "type": "string",
"javaType": "java.lang.String" },
-{ "name": "camel.main.startupRecorderDuration", "description": "How long
time to run the startup recorder. Use 0 (default) to stop the recorder after
Camel has been started. Use -1 to keep the recorder running until the JVM is
being stopped. A positive value is to run the recorder for N seconds. When the
recorder is stopped then the recording is auto saved to disk (note: save to
disk can be disabled by setting startupRecorderDir to false)", "sourceType":
"org.apache.camel.main.Defaul [...]
+{ "name": "camel.main.startupRecorderDuration", "description": "How long
time to run the startup recorder. Use 0 (default) to keep the recorder running
until the JVM is exited. Use -1 to stop the recorder right after Camel has been
started (to only
[camel] branch master updated (9f9ad60 -> 43a4fd8)
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel.git. from 9f9ad60 CAMEL-16056: Added camel-jfr for java flight recorder integration new 3760ca7 CAMEL-16056: Added camel-jfr for java flight recorder integration new 43a4fd8 Fixed CS 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: .../jfr/FlightRecorderStartupStepRecorder.java | 73 ++ .../camel/impl/engine/AbstractCamelContext.java| 3 +- 2 files changed, 34 insertions(+), 42 deletions(-)
[camel] 02/02: Fixed CS
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 43a4fd81d23bba7a0292fa07879236c14803b0f0
Author: Claus Ibsen
AuthorDate: Thu Jan 21 11:05:57 2021 +0100
Fixed CS
---
.../camel/startup/jfr/FlightRecorderStartupStepRecorder.java | 12 ++--
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git
a/components/camel-jfr/src/main/java/org/apache/camel/startup/jfr/FlightRecorderStartupStepRecorder.java
b/components/camel-jfr/src/main/java/org/apache/camel/startup/jfr/FlightRecorderStartupStepRecorder.java
index 333a882..f3a4e96 100644
---
a/components/camel-jfr/src/main/java/org/apache/camel/startup/jfr/FlightRecorderStartupStepRecorder.java
+++
b/components/camel-jfr/src/main/java/org/apache/camel/startup/jfr/FlightRecorderStartupStepRecorder.java
@@ -44,6 +44,12 @@ public class FlightRecorderStartupStepRecorder extends
DefaultStartupStepRecorde
private Recording rec;
private FlightRecorderListener frl;
+public FlightRecorderStartupStepRecorder() {
+setEnabled(true);
+// pre-empty enable recording so we have as early as possible
recording started
+setRecording(true);
+}
+
@Override
public void doStart() throws Exception {
super.doStart();
@@ -112,12 +118,6 @@ public class FlightRecorderStartupStepRecorder extends
DefaultStartupStepRecorde
}
}
-public FlightRecorderStartupStepRecorder() {
-setEnabled(true);
-// pre-empty enable recording so we have as early as possible
recording started
-setRecording(true);
-}
-
@Override
public StartupStep createStartupStep(String type, String name, String
description, int id, int parentId, int level) {
return new FlightRecorderStartupStep(name, id, parentId, level, type,
description);
[camel] 01/02: CAMEL-16056: Added camel-jfr for java flight recorder integration
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 3760ca78dab42211c82a9d7d838bff02af9137fe
Author: Claus Ibsen
AuthorDate: Thu Jan 21 11:05:01 2021 +0100
CAMEL-16056: Added camel-jfr for java flight recorder integration
---
.../jfr/FlightRecorderStartupStepRecorder.java | 61 +-
.../camel/impl/engine/AbstractCamelContext.java| 3 +-
2 files changed, 28 insertions(+), 36 deletions(-)
diff --git
a/components/camel-jfr/src/main/java/org/apache/camel/startup/jfr/FlightRecorderStartupStepRecorder.java
b/components/camel-jfr/src/main/java/org/apache/camel/startup/jfr/FlightRecorderStartupStepRecorder.java
index 40f0f08..333a882 100644
---
a/components/camel-jfr/src/main/java/org/apache/camel/startup/jfr/FlightRecorderStartupStepRecorder.java
+++
b/components/camel-jfr/src/main/java/org/apache/camel/startup/jfr/FlightRecorderStartupStepRecorder.java
@@ -53,15 +53,21 @@ public class FlightRecorderStartupStepRecorder extends
DefaultStartupStepRecorde
Configuration config =
Configuration.getConfiguration(getRecordingProfile());
rec = new Recording(config);
rec.setName("Camel Recording");
-if (getStartupRecorderDuration() == 0) {
+
+if (!"false".equals(getRecordingDir())) {
+// recording to disk can be turned off by setting to false
Path dir = getRecordingDir() != null ?
Paths.get(getRecordingDir()) : Paths.get(System.getenv().get("HOME"));
Path file = Files.createTempFile(dir, "camel-recording",
".jfr");
-rec.setDumpOnExit(true);
+// when stopping then the recording is automatic dumped by
flight recorder
rec.setDestination(file);
-LOG.info("Java flight recorder will be saved to file on JVM
exit: {}", file);
}
-if (getStartupRecorderDuration() > 0) {
+if (getStartupRecorderDuration() == 0) {
+if (rec.getDestination() != null) {
+rec.setDumpOnExit(true);
+LOG.info("Java flight recorder will be saved to file on
JVM exit: {}", rec.getDestination());
+}
+} else if (getStartupRecorderDuration() > 0) {
rec.setDuration(Duration.ofSeconds(getStartupRecorderDuration()));
LOG.info("Starting Java flight recorder with profile: {} and
duration: {} seconds", getRecordingProfile(),
getStartupRecorderDuration());
@@ -71,8 +77,8 @@ public class FlightRecorderStartupStepRecorder extends
DefaultStartupStepRecorde
@Override
public void recordingStateChanged(Recording recording) {
if (recording == rec &&
recording.getState().equals(RecordingState.STOPPED)) {
-LOG.info("Stopping Java flight recorder after {}
seconds elapsed", getStartupRecorderDuration());
-dumpRecording();
+LOG.info("Java flight recorder stopped after {}
seconds and saved to file: {}",
+getStartupRecorderDuration(),
rec.getDestination());
}
}
};
@@ -88,37 +94,22 @@ public class FlightRecorderStartupStepRecorder extends
DefaultStartupStepRecorde
public void doStop() throws Exception {
super.doStop();
-if (rec != null && getStartupRecorderDuration() != 0) {
-dumpRecording();
-}
-}
-
-protected void dumpRecording() {
-if (!"false".equals(getRecordingDir())) {
-try {
-Path dir = getRecordingDir() != null ?
Paths.get(getRecordingDir()) : Paths.get(System.getenv().get("HOME"));
-Path file = Files.createTempFile(dir, "camel-recording-",
".jfr");
-if (rec.getState().equals(RecordingState.RUNNING)) {
-// need to do GC to capture details to the recording
(specially when its short running)
-LOG.info("Stopping Java flight recorder");
-System.gc();
-rec.stop();
-}
-if (rec.getState().equals(RecordingState.STOPPED)) {
-rec.dump(file);
-LOG.info("Java flight recorder saved to file: {}", file);
-}
-} catch (Exception e) {
-LOG.warn("Error saving Java flight recorder recording to
file", e);
+if (rec != null) {
+// if < 0 then manual stop the recording
+if (getStartupRecorderDuration() < 0) {
+LOG.debug("Stopping Java flight recorder");
+// do GC before stopping to force flushing data into the
recording
+System.gc
[GitHub] [camel-k] nicolaferraro opened a new pull request #1929: Fix #1928: use "id" property in kamelet binding for adding specific c…
nicolaferraro opened a new pull request #1929: URL: https://github.com/apache/camel-k/pull/1929 …onfiguration **Release Note** ```release-note Kamelet auto-loaded specific configuration secrets can be used in KameletBindings ``` 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] jyterrien commented on issue #2152: Require Java 11 in examples
jyterrien commented on issue #2152: URL: https://github.com/apache/camel-quarkus/issues/2152#issuecomment-764538449 Hi with `11` The bootstrap display `2021-01-21 11:23:47,405 WARN [io.qua.dep.dev.JavaCompilationProvider] (Timer-0) unknown enum constant javax.xml.bind.annotation.XmlAccessType.PROPERTY reason: class file for javax.xml.bind.annotation.XmlAccessType not found, line -1 in H:\camel-quarkus-examples\timer-log-main\src\main\java\org\acme\timer\TimerRoute.java 2021-01-21 11:23:47,405 WARN [io.qua.dep.dev.JavaCompilationProvider] (Timer-0) unknown enum constant javax.xml.bind.annotation.XmlAccessType.NONE, line -1 in H:\camel-quarkus-examples\timer-log-main\src\main\java\org\acme\timer\TimerRoute.java 2021-01-21 11:23:47,406 WARN [io.qua.dep.dev.JavaCompilationProvider] (Timer-0) unknown enum constant javax.xml.bind.annotation.XmlAccessType.FIELD, line -1 in H:\camel-quarkus-examples\timer-log-main\src\main\java\org\acme\timer\TimerRoute.java 2021-01-21 11:23:47,406 WARN [io.qua.dep.dev.JavaCompilationProvider] (Timer-0) unknown enum constant javax.xml.bind.annotation.XmlAccessType.PROPERTY, line -1 in H:\camel-quarkus-examples\timer-log-main\src\main\java\org\acme\timer\TimerRoute.java 2021-01-21 11:23:47,406 WARN [io.qua.dep.dev.JavaCompilationProvider] (Timer-0) unknown enum constant javax.xml.bind.annotation.XmlAccessType.FIELD, line -1 in H:\camel-quarkus-examples\timer-log-main\src\main\java\org\acme\timer\TimerRoute.java 2021-01-21 11:23:47,406 WARN [io.qua.dep.dev.JavaCompilationProvider] (Timer-0) unknown enum constant javax.xml.bind.annotation.XmlAccessType.FIELD, line -1 in H:\camel-quarkus-examples\timer-log-main\src\main\java\org\acme\timer\TimerRoute.java` but XmlAccessType il snot présent in code of this project. I'm think that comme with an dependency Thank JYT 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: Google BigQuery native is since 1.6.0 not 1.5.0
This is an automated email from the ASF dual-hosted git repository. ppalaga pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git The following commit(s) were added to refs/heads/master by this push: new 7d8d55f Google BigQuery native is since 1.6.0 not 1.5.0 7d8d55f is described below commit 7d8d55f44ccb79fe688d3d2e13e818c6756035cf Author: Peter Palaga AuthorDate: Thu Jan 21 11:34:57 2021 +0100 Google BigQuery native is since 1.6.0 not 1.5.0 --- docs/modules/ROOT/pages/reference/extensions/google-bigquery.adoc | 4 ++-- .../ROOT/partials/reference/components/google-bigquery-sql.adoc | 2 +- docs/modules/ROOT/partials/reference/components/google-bigquery.adoc | 2 +- extensions/google-bigquery/runtime/pom.xml| 2 +- 4 files changed, 5 insertions(+), 5 deletions(-) diff --git a/docs/modules/ROOT/pages/reference/extensions/google-bigquery.adoc b/docs/modules/ROOT/pages/reference/extensions/google-bigquery.adoc index c3e4255..ed15bbf 100644 --- a/docs/modules/ROOT/pages/reference/extensions/google-bigquery.adoc +++ b/docs/modules/ROOT/pages/reference/extensions/google-bigquery.adoc @@ -8,10 +8,10 @@ :cq-description: Access Google Cloud BigQuery service using SQL queries or Google Client Services API :cq-deprecated: false :cq-jvm-since: 1.0.0 -:cq-native-since: 1.5.0 +:cq-native-since: 1.6.0 [.badges] -[.badge-key]##JVM since##[.badge-supported]##1.0.0## [.badge-key]##Native since##[.badge-supported]##1.5.0## +[.badge-key]##JVM since##[.badge-supported]##1.0.0## [.badge-key]##Native since##[.badge-supported]##1.6.0## Access Google Cloud BigQuery service using SQL queries or Google Client Services API diff --git a/docs/modules/ROOT/partials/reference/components/google-bigquery-sql.adoc b/docs/modules/ROOT/partials/reference/components/google-bigquery-sql.adoc index 8330f83..7bd1673 100644 --- a/docs/modules/ROOT/partials/reference/components/google-bigquery-sql.adoc +++ b/docs/modules/ROOT/partials/reference/components/google-bigquery-sql.adoc @@ -6,7 +6,7 @@ :cq-status: Stable :cq-deprecated: false :cq-jvm-since: 1.0.0 -:cq-native-since: 1.5.0 +:cq-native-since: 1.6.0 :cq-camel-part-name: google-bigquery-sql :cq-camel-part-title: Google BigQuery Standard SQL :cq-camel-part-description: Access Google Cloud BigQuery service using SQL queries. diff --git a/docs/modules/ROOT/partials/reference/components/google-bigquery.adoc b/docs/modules/ROOT/partials/reference/components/google-bigquery.adoc index fd0ebca..66fce6b 100644 --- a/docs/modules/ROOT/partials/reference/components/google-bigquery.adoc +++ b/docs/modules/ROOT/partials/reference/components/google-bigquery.adoc @@ -6,7 +6,7 @@ :cq-status: Stable :cq-deprecated: false :cq-jvm-since: 1.0.0 -:cq-native-since: 1.5.0 +:cq-native-since: 1.6.0 :cq-camel-part-name: google-bigquery :cq-camel-part-title: Google BigQuery :cq-camel-part-description: Google BigQuery data warehouse for analytics. diff --git a/extensions/google-bigquery/runtime/pom.xml b/extensions/google-bigquery/runtime/pom.xml index fa6e33a..9b63492 100644 --- a/extensions/google-bigquery/runtime/pom.xml +++ b/extensions/google-bigquery/runtime/pom.xml @@ -32,7 +32,7 @@ 1.0.0 -1.5.0 +1.6.0
[GitHub] [camel-website] ppalaga opened a new pull request #531: Blog: Camel Quarkus 1.6.0
ppalaga opened a new pull request #531: URL: https://github.com/apache/camel-website/pull/531 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] jamesnetherton commented on a change in pull request #531: Blog: Camel Quarkus 1.6.0
jamesnetherton commented on a change in pull request #531: URL: https://github.com/apache/camel-website/pull/531#discussion_r561777017 ## File path: content/blog/2021/01/camel-quarkus-release-1.6.0/index.md ## @@ -0,0 +1,86 @@ +--- +title: "Camel Quarkus 1.6.0 Released" +date: 2021-01-18 +authors: ["ppalaga"] +categories: ["Releases", "Camel Quarkus"] +preview: "Camel Quarkus 1.6.0 Released" +summary: "The highlights of Camel Quarkus 1.6.0" +--- + +Original image by https://commons.wikimedia.org/wiki/User:99of9";>Toby Hudson https://creativecommons.org/licenses/by-sa/3.0";>CC BY-SA 3.0 via https://en.wikipedia.org/wiki/Camel_racing#/media/File:CamelRacingCamelCup2009Heat.JPG";>Wikipedia + +We are pleased to announce the release 1.6.0 of Camel Quarkus! Here are the highlights. + +## Java 11 required + +Having deprecated Java 8 [long time ago](https://camel.apache.org/blog/2020/04/Camel-Quarkus-release-1.0.0-M7/) and +following the same requirement by Quarkus, Camel Quarkus now requires Java 11+. + +## Support for more Camel components + +Camel Quarkus brings support for three new Camel bits: Review comment: ```suggestion Camel Quarkus brings support for three new Camel components: ``` This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] ppalaga commented on pull request #531: Blog: Camel Quarkus 1.6.0
ppalaga commented on pull request #531: URL: https://github.com/apache/camel-website/pull/531#issuecomment-764555471 > I wonder if we should add a little note about camel-fop as per [this thread](https://github.com/apache/camel-quarkus/issues/2113#issuecomment-756807434)? +1, let me add a sentence. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] ppalaga commented on a change in pull request #531: Blog: Camel Quarkus 1.6.0
ppalaga commented on a change in pull request #531: URL: https://github.com/apache/camel-website/pull/531#discussion_r561785137 ## File path: content/blog/2021/01/camel-quarkus-release-1.6.0/index.md ## @@ -0,0 +1,86 @@ +--- +title: "Camel Quarkus 1.6.0 Released" +date: 2021-01-18 +authors: ["ppalaga"] +categories: ["Releases", "Camel Quarkus"] +preview: "Camel Quarkus 1.6.0 Released" +summary: "The highlights of Camel Quarkus 1.6.0" +--- + +Original image by https://commons.wikimedia.org/wiki/User:99of9";>Toby Hudson https://creativecommons.org/licenses/by-sa/3.0";>CC BY-SA 3.0 via https://en.wikipedia.org/wiki/Camel_racing#/media/File:CamelRacingCamelCup2009Heat.JPG";>Wikipedia + +We are pleased to announce the release 1.6.0 of Camel Quarkus! Here are the highlights. + +## Java 11 required + +Having deprecated Java 8 [long time ago](https://camel.apache.org/blog/2020/04/Camel-Quarkus-release-1.0.0-M7/) and +following the same requirement by Quarkus, Camel Quarkus now requires Java 11+. + +## Support for more Camel components + +Camel Quarkus brings support for three new Camel bits: Review comment: Some time ago, I started using "bits" when I speak about languages, data formats and "others" in addition to components. Does "bits" sound too strange? I do not mind changing it here, but would still be nice to hear your your native speaker's opinion about "bits" :) This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] ppalaga commented on issue #2113: FOP integration tests fail in native mode with GraalVM 20.3.0
ppalaga commented on issue #2113: URL: https://github.com/apache/camel-quarkus/issues/2113#issuecomment-764557046 Both GraalVM 21.0.0 and 20.3.1 are available now and the issue should not occur anymore. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] ppalaga commented on a change in pull request #531: Blog: Camel Quarkus 1.6.0
ppalaga commented on a change in pull request #531: URL: https://github.com/apache/camel-website/pull/531#discussion_r561789008 ## File path: content/blog/2021/01/camel-quarkus-release-1.6.0/index.md ## @@ -0,0 +1,86 @@ +--- +title: "Camel Quarkus 1.6.0 Released" +date: 2021-01-18 +authors: ["ppalaga"] +categories: ["Releases", "Camel Quarkus"] +preview: "Camel Quarkus 1.6.0 Released" +summary: "The highlights of Camel Quarkus 1.6.0" +--- + +Original image by https://commons.wikimedia.org/wiki/User:99of9";>Toby Hudson https://creativecommons.org/licenses/by-sa/3.0";>CC BY-SA 3.0 via https://en.wikipedia.org/wiki/Camel_racing#/media/File:CamelRacingCamelCup2009Heat.JPG";>Wikipedia + +We are pleased to announce the release 1.6.0 of Camel Quarkus! Here are the highlights. + +## Java 11 required + +Having deprecated Java 8 [long time ago](https://camel.apache.org/blog/2020/04/Camel-Quarkus-release-1.0.0-M7/) and +following the same requirement by Quarkus, Camel Quarkus now requires Java 11+. + +## Support for more Camel components + +Camel Quarkus brings support for three new Camel bits: Review comment: Replaced in 857ef0c This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] ppalaga commented on pull request #531: Blog: Camel Quarkus 1.6.0
ppalaga commented on pull request #531: URL: https://github.com/apache/camel-website/pull/531#issuecomment-764559138 > > I wonder if we should add a little note about camel-fop as per [this thread](https://github.com/apache/camel-quarkus/issues/2113#issuecomment-756807434)? > > +1, let me add a sentence. Added a Known issue section in 857ef0c This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] jamesnetherton commented on a change in pull request #531: Blog: Camel Quarkus 1.6.0
jamesnetherton commented on a change in pull request #531: URL: https://github.com/apache/camel-website/pull/531#discussion_r561790579 ## File path: content/blog/2021/01/camel-quarkus-release-1.6.0/index.md ## @@ -0,0 +1,86 @@ +--- +title: "Camel Quarkus 1.6.0 Released" +date: 2021-01-18 +authors: ["ppalaga"] +categories: ["Releases", "Camel Quarkus"] +preview: "Camel Quarkus 1.6.0 Released" +summary: "The highlights of Camel Quarkus 1.6.0" +--- + +Original image by https://commons.wikimedia.org/wiki/User:99of9";>Toby Hudson https://creativecommons.org/licenses/by-sa/3.0";>CC BY-SA 3.0 via https://en.wikipedia.org/wiki/Camel_racing#/media/File:CamelRacingCamelCup2009Heat.JPG";>Wikipedia + +We are pleased to announce the release 1.6.0 of Camel Quarkus! Here are the highlights. + +## Java 11 required + +Having deprecated Java 8 [long time ago](https://camel.apache.org/blog/2020/04/Camel-Quarkus-release-1.0.0-M7/) and +following the same requirement by Quarkus, Camel Quarkus now requires Java 11+. + +## Support for more Camel components + +Camel Quarkus brings support for three new Camel bits: Review comment: 'bits' is like a casual, catch-all expression that can mean pretty much anything you like. So it doesn't really describe what three new things we have added support for. As ever, I'm pretty relaxed about the language. So it's your choice whether to change it or not. 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: CAMEL-16056: Polished
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new 95f9f77 CAMEL-16056: Polished
95f9f77 is described below
commit 95f9f7732ac6dd7be92566e897b578d81decf4e2
Author: Claus Ibsen
AuthorDate: Thu Jan 21 12:09:57 2021 +0100
CAMEL-16056: Polished
---
.../org/apache/camel/spi/DataFormatResolver.java | 1 +
.../camel/impl/engine/AbstractCamelContext.java| 138 ++---
.../impl/engine/InternalRouteStartupManager.java | 4 +-
.../org/apache/camel/impl/DefaultCamelContext.java | 7 +-
.../org/apache/camel/reifier/RouteReifier.java | 2 +-
5 files changed, 98 insertions(+), 54 deletions(-)
diff --git
a/core/camel-api/src/main/java/org/apache/camel/spi/DataFormatResolver.java
b/core/camel-api/src/main/java/org/apache/camel/spi/DataFormatResolver.java
index 492f247..b2ada30 100644
--- a/core/camel-api/src/main/java/org/apache/camel/spi/DataFormatResolver.java
+++ b/core/camel-api/src/main/java/org/apache/camel/spi/DataFormatResolver.java
@@ -22,6 +22,7 @@ import org.apache.camel.CamelContext;
* Represents a resolver of data formats.
*/
public interface DataFormatResolver {
+
/**
* Creates the given data format given its name.
*
diff --git
a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/AbstractCamelContext.java
b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/AbstractCamelContext.java
index e5fa150..43068ae 100644
---
a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/AbstractCamelContext.java
+++
b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/AbstractCamelContext.java
@@ -581,7 +581,7 @@ public abstract class AbstractCamelContext extends
BaseService
if (component != null && created.get() && autoStart &&
(isStarted() || isStarting())) {
// If the component is looked up after the context is started,
// lets start it up.
-StartupStep step =
startupStepRecorder.beginStep(Component.class, name, "Starting component");
+StartupStep step =
startupStepRecorder.beginStep(Component.class, name, "Starting Component");
startService(component);
startupStepRecorder.endStep(step);
}
@@ -601,7 +601,7 @@ public abstract class AbstractCamelContext extends
BaseService
private Component initComponent(String name, boolean autoCreateComponents)
{
Component component = null;
if (autoCreateComponents) {
-StartupStep step = startupStepRecorder.beginStep(Component.class,
name, "Resolving component");
+StartupStep step = startupStepRecorder.beginStep(Component.class,
name, "Resolving Component");
try {
if (LOG.isDebugEnabled()) {
LOG.debug("Using ComponentResolver: {} to resolve
component with name: {}", getComponentResolver(), name);
@@ -807,7 +807,7 @@ public abstract class AbstractCamelContext extends
BaseService
// only record startup step during startup (not started)
if (!isStarted() && startupStepRecorder.isEnabled()) {
String u = URISupport.sanitizeUri(uri);
-step = startupStepRecorder.beginStep(Endpoint.class, u, "Getting
endpoint");
+step = startupStepRecorder.beginStep(Endpoint.class, u, "Getting
Endpoint");
}
Endpoint answer = doGetEndpoint(uri, null, false, false);
if (step != null) {
@@ -1691,6 +1691,12 @@ public abstract class AbstractCamelContext extends
BaseService
return languages.computeIfAbsent(name, new Function() {
@Override
public Language apply(String s) {
+StartupStep step = null;
+// only record startup step during startup (not started)
+if (!isStarted() && startupStepRecorder.isEnabled()) {
+step = startupStepRecorder.beginStep(Language.class, name,
"Resolving Language");
+}
+
final CamelContext camelContext = getCamelContextReference();
// as first iteration, check if there is a language instance
for the given name
@@ -1723,6 +1729,9 @@ public abstract class AbstractCamelContext extends
BaseService
}
}
+if (step != null) {
+startupStepRecorder.endStep(step);
+}
return language;
}
});
@@ -2539,14 +2548,14 @@ public abstract class AbstractCamelContext extends
BaseService
}
startupStepRecorder.start();
-StartupStep step = startupStepRecorder.beginStep(CamelContext.class,
null, "Building context");
+StartupStep step = startupStepRecorder.beginSt
[GitHub] [camel-website] github-actions[bot] commented on pull request #531: Blog: Camel Quarkus 1.6.0
github-actions[bot] commented on pull request #531: URL: https://github.com/apache/camel-website/pull/531#issuecomment-764563380 🚀 Preview for bd61d706595fa5ac551ac8c1bbc75eb9851a2da8 is available at https://pr-531--camel.netlify.app This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] aldettinger commented on a change in pull request #531: Blog: Camel Quarkus 1.6.0
aldettinger commented on a change in pull request #531: URL: https://github.com/apache/camel-website/pull/531#discussion_r561790751 ## File path: content/blog/2021/01/camel-quarkus-release-1.6.0/index.md ## @@ -0,0 +1,91 @@ +--- +title: "Camel Quarkus 1.6.0 Released" +date: 2021-01-18 +authors: ["ppalaga"] +categories: ["Releases", "Camel Quarkus"] +preview: "Camel Quarkus 1.6.0 Released" +summary: "The highlights of Camel Quarkus 1.6.0" +--- + +Original image by https://commons.wikimedia.org/wiki/User:99of9";>Toby Hudson https://creativecommons.org/licenses/by-sa/3.0";>CC BY-SA 3.0 via https://en.wikipedia.org/wiki/Camel_racing#/media/File:CamelRacingCamelCup2009Heat.JPG";>Wikipedia + +We are pleased to announce the release 1.6.0 of Camel Quarkus! Here are the highlights. + +## Java 11 required + +Having deprecated Java 8 [long time ago](https://camel.apache.org/blog/2020/04/Camel-Quarkus-release-1.0.0-M7/) and +following the same requirement by Quarkus, Camel Quarkus now requires Java 11+. + +## Support for more Camel components + +Camel Quarkus brings support for three new Camel components: + +* [JSONATA](https://camel.apache.org/camel-quarkus/latest/reference/extensions/jsonata.html) +* [Vert.x Kafka](https://camel.apache.org/camel-quarkus/latest/reference/extensions/vertx-kafka.html) +* [Redis](https://camel.apache.org/camel-quarkus/latest/reference/extensions/redis.html) (JVM only) + +Components newly supported in native mode: + +* [Azure Storage Blob Service](https://camel.apache.org/camel-quarkus/latest/reference/extensions/azure-storage-blob.html) +* [Debezium MongoDB Connector](https://camel.apache.org/camel-quarkus/latest/reference/extensions/debezium-mongodb.html) +* [Google BigQuery](https://camel.apache.org/camel-quarkus/latest/reference/extensions/google-bigquery.html) Review comment: The google big query page indicates nativeSince = 1.5.0. Maybe we need to remove from release note ? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] aldettinger commented on a change in pull request #531: Blog: Camel Quarkus 1.6.0
aldettinger commented on a change in pull request #531: URL: https://github.com/apache/camel-website/pull/531#discussion_r561800784 ## File path: content/blog/2021/01/camel-quarkus-release-1.6.0/index.md ## @@ -0,0 +1,91 @@ +--- +title: "Camel Quarkus 1.6.0 Released" +date: 2021-01-18 +authors: ["ppalaga"] +categories: ["Releases", "Camel Quarkus"] +preview: "Camel Quarkus 1.6.0 Released" +summary: "The highlights of Camel Quarkus 1.6.0" +--- + +Original image by https://commons.wikimedia.org/wiki/User:99of9";>Toby Hudson https://creativecommons.org/licenses/by-sa/3.0";>CC BY-SA 3.0 via https://en.wikipedia.org/wiki/Camel_racing#/media/File:CamelRacingCamelCup2009Heat.JPG";>Wikipedia + +We are pleased to announce the release 1.6.0 of Camel Quarkus! Here are the highlights. + +## Java 11 required + +Having deprecated Java 8 [long time ago](https://camel.apache.org/blog/2020/04/Camel-Quarkus-release-1.0.0-M7/) and Review comment: Any reason to link on the camel website directly ? I'm curious whether "/blog/2020/04/Camel-Quarkus-release-1.0.0-M7/" would also work ? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] ppalaga commented on issue #2155: Re-think MockBackendUtils class so it is not needed to use it manually
ppalaga commented on issue #2155: URL: https://github.com/apache/camel-quarkus/issues/2155#issuecomment-764574152 > We should also get rid of `CAMEL_QUARKUS_START_MOCK_BACKEND` because it makes little sense when tests require other environment variables to talk to the real service. It is true that many tests can autodetect based on the defined env vars whether they should start the mock or run against the real backend. In that sense, `CAMEL_QUARKUS_START_MOCK_BACKEND` can really be seen as useless. However, I think `CAMEL_QUARKUS_START_MOCK_BACKEND` is still useful, when it comes to preventing misconfiguration: Say, a new test comes in for which the tester has not set the env vars yet. IMO, in such situation, `CAMEL_QUARKUS_START_MOCK_BACKEND` is the only way how the tester can figure out that has not configured something yet. Yes, it is more work for the test authors, but IMO it pays back by giving more certainty that the tester is testing against the real backend without any silent fallback to mocks. 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 (95f9f77 -> f92b2cb)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git.
from 95f9f77 CAMEL-16056: Polished
add f92b2cb Add unit test based on user forum issue
No new revisions were added by this update.
Summary of changes:
.../processor/OnCompletionFailAndOkTest.java} | 51 --
1 file changed, 29 insertions(+), 22 deletions(-)
copy
core/{camel-management/src/test/java/org/apache/camel/management/ManagedRouteWithOnExceptionTest.java
=>
camel-core/src/test/java/org/apache/camel/processor/OnCompletionFailAndOkTest.java}
(56%)
[GitHub] [camel-website] ppalaga commented on a change in pull request #531: Blog: Camel Quarkus 1.6.0
ppalaga commented on a change in pull request #531: URL: https://github.com/apache/camel-website/pull/531#discussion_r561804258 ## File path: content/blog/2021/01/camel-quarkus-release-1.6.0/index.md ## @@ -0,0 +1,91 @@ +--- +title: "Camel Quarkus 1.6.0 Released" +date: 2021-01-18 +authors: ["ppalaga"] +categories: ["Releases", "Camel Quarkus"] +preview: "Camel Quarkus 1.6.0 Released" +summary: "The highlights of Camel Quarkus 1.6.0" +--- + +Original image by https://commons.wikimedia.org/wiki/User:99of9";>Toby Hudson https://creativecommons.org/licenses/by-sa/3.0";>CC BY-SA 3.0 via https://en.wikipedia.org/wiki/Camel_racing#/media/File:CamelRacingCamelCup2009Heat.JPG";>Wikipedia + +We are pleased to announce the release 1.6.0 of Camel Quarkus! Here are the highlights. + +## Java 11 required + +Having deprecated Java 8 [long time ago](https://camel.apache.org/blog/2020/04/Camel-Quarkus-release-1.0.0-M7/) and Review comment: Let me try This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] github-actions[bot] commented on pull request #531: Blog: Camel Quarkus 1.6.0
github-actions[bot] commented on pull request #531: URL: https://github.com/apache/camel-website/pull/531#issuecomment-764578964 🚀 Preview for 857ef0c78d64d07e8fdc1e64f35e2e8fcd1605e9 is available at https://pr-531--camel.netlify.app This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch master updated: Fixed CS
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new 79d2dd4 Fixed CS
79d2dd4 is described below
commit 79d2dd480a5ae2f1c3ad2b18c0b1722e9cf88a5c
Author: Claus Ibsen
AuthorDate: Thu Jan 21 12:38:44 2021 +0100
Fixed CS
---
.../camel/support/startup/DefaultStartupStepRecorder.java | 14 +++---
1 file changed, 7 insertions(+), 7 deletions(-)
diff --git
a/core/camel-support/src/main/java/org/apache/camel/support/startup/DefaultStartupStepRecorder.java
b/core/camel-support/src/main/java/org/apache/camel/support/startup/DefaultStartupStepRecorder.java
index cb90710..ee21076 100644
---
a/core/camel-support/src/main/java/org/apache/camel/support/startup/DefaultStartupStepRecorder.java
+++
b/core/camel-support/src/main/java/org/apache/camel/support/startup/DefaultStartupStepRecorder.java
@@ -29,9 +29,6 @@ import org.apache.camel.support.service.ServiceSupport;
*/
public class DefaultStartupStepRecorder extends ServiceSupport implements
StartupStepRecorder {
-private final AtomicInteger stepCounter = new AtomicInteger();
-private final Deque currentSteps = new ArrayDeque<>();
-
private static final StartupStep DISABLED_STEP = new StartupStep() {
@Override
public String getType() {
@@ -64,17 +61,20 @@ public class DefaultStartupStepRecorder extends
ServiceSupport implements Startu
}
@Override
-public void endStep() {
-// noop
+public long getBeginTime() {
+return 0;
}
@Override
-public long getBeginTime() {
-return 0;
+public void endStep() {
+// noop
}
};
+private final AtomicInteger stepCounter = new AtomicInteger();
+private final Deque currentSteps = new ArrayDeque<>();
+
private boolean enabled;
private int maxDepth = -1;
private long startupRecorderDuration;
[GitHub] [camel-k] nicolaferraro opened a new issue #1930: Warnings on getting operator versions
nicolaferraro opened a new issue #1930: URL: https://github.com/apache/camel-k/issues/1930 I see these messages in CI: ``` Could not parse (error: Invalid Semantic Version) Warning: you're using Camel K 1.4.0-SNAPSHOT client against a cluster operator ``` Something related to the operator version check? @astefanutti , @squakez This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] github-actions[bot] commented on pull request #531: Blog: Camel Quarkus 1.6.0
github-actions[bot] commented on pull request #531: URL: https://github.com/apache/camel-website/pull/531#issuecomment-764594965 🚀 Preview for e1cb8d9f78a0addaa7fa4bd5e03710b3792e024f is available at https://pr-531--camel.netlify.app This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] jamesnetherton opened a new pull request #1931: Use Quarkus fast-jar package format apache/camel-k-runtime#360
jamesnetherton opened a new pull request #1931: URL: https://github.com/apache/camel-k/pull/1931 Depends on an as-yet uncommitted change to camel-k-runtime (hence draft PR), but this PR provides the means to support the Quarkus fast-jar format. At the moment fast-jar expects a specific directory structure, so I've had to replicate that in the container under `/deployment/dependencies` . Also I assumed it's safe to not use the `generate-dependency-list` mojo since the `quarkus-maven-plugin` already does its own dependency resolution and downloading of artifacts. **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-kafka-connector] oscerd opened a new issue #908: Camel-Cron connector: We need to add at least camel-quartz as dependency
oscerd opened a new issue #908: URL: https://github.com/apache/camel-kafka-connector/issues/908 Otherwise we have `Caused by: org.apache.camel.FailedToCreateRouteException: Failed to create route route1: Route(route1)[From[cron:cron-timer?schedule=0/5+*+*+*+*+?] -... because of Failed to resolve endpoint: cron://cron-timer?schedule=0/5+*+*+*+*+? due to: Cannot find any CamelCronService: please add a valid implementation, such as 'camel-quartz', in order to use the 'camel-cron' 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 commented on issue #908: Camel-Cron connector: We need to add at least camel-quartz as dependency
oscerd commented on issue #908: URL: https://github.com/apache/camel-kafka-connector/issues/908#issuecomment-764614735 And we need quartz dependency 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] apupier commented on issue #1872: [regression] panic: runtime error: invalid memory address or nil pointer dereference with version 1.3.0 when calling without or with - or -- argume
apupier commented on issue #1872: URL: https://github.com/apache/camel-k/issues/1872#issuecomment-764615472 I think that this issue should have the Milestone 1.3.1 set. https://github.com/apache/camel-k/commit/2d0a6f3435e0e3dcac613c0f7cff96ec5b78860d 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] apupier commented on issue #1911: [CLI] Kamel run does not check source file exists
apupier commented on issue #1911: URL: https://github.com/apache/camel-k/issues/1911#issuecomment-764618851 this issue has milestone 1.3.1 set but it is no tpart of 1.3.x branch https://github.com/apache/camel-k/blob/ed0456f0df60f4141be4742d42087d633e13dc26/pkg/cmd/run.go#L383 https://github.com/apache/camel-k/commits/release-1.3.x Is it planned to backport it? (if it is a regression sounds a good idea) or the milestone needs to be updated? 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 #4906: camel-bean: prevent a NPE if parametersExpression is null
orpiske opened a new pull request #4906: URL: https://github.com/apache/camel/pull/4906 - [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-kafka-connector-examples] oscerd opened a new issue #266: Add a Camel Cron Example
oscerd opened a new issue #266: URL: https://github.com/apache/camel-kafka-connector-examples/issues/266 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-kafka-connector-examples] branch cron-example created (now 5751c01)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch cron-example in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git. at 5751c01 Added a Cron source connector example This branch includes the following new commits: new 5751c01 Added a Cron source connector example The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[camel-kafka-connector-examples] 01/01: Added a Cron source connector example
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch cron-example in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git commit 5751c017e3f564c9b0f419747c16b2dc3267ec92 Author: Andrea Cosentino AuthorDate: Thu Jan 21 13:47:23 2021 +0100 Added a Cron source connector example --- cron/cron-source/README.adoc | 107 + .../config/CamelCronSourceConnector.properties | 28 ++ 2 files changed, 135 insertions(+) diff --git a/cron/cron-source/README.adoc b/cron/cron-source/README.adoc new file mode 100644 index 000..fc5e6da --- /dev/null +++ b/cron/cron-source/README.adoc @@ -0,0 +1,107 @@ += Camel-Kafka-connector Cron Source + +This is an example for Camel-Kafka-connector Cron Source + +== Standalone + +=== Running Kafka + +[source] + +$KAFKA_HOME/bin/zookeeper-server-start.sh $KAFKA_HOME/config/zookeeper.properties +$KAFKA_HOME/bin/kafka-server-start.sh $KAFKA_HOME/config/server.properties +$KAFKA_HOME/bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic mytopic + + +=== Download the connector package + +Download the connector package zip and extract the content to a directory. In this example we'll use `/home/oscerd/connectors/` + +[source] + +> cd /home/oscerd/connectors/ +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-cron-kafka-connector/0.7.0/camel-cron-kafka-connector-0.7.0-package.zip +> unzip camel-cron-kafka-connector-0.7.0-package.zip + + +In 0.7.0, you'll need to add also camel-quartz and quartz dependency. + +[source] + +> cd /home/oscerd/connectors/camel-cron-kafka-connector +> wget https://repo1.maven.org/maven2/org/apache/camel/camel-quartz/3.7.0/camel-quartz-3.7.0.jar +> wget https://repo1.maven.org/maven2/org/quartz-scheduler/quartz/2.3.2/quartz-2.3.2.jar + + +We are now ready + +=== Configuring Kafka Connect + +You'll need to set up the `plugin.path` property in your kafka + +Open the `$KAFKA_HOME/config/connect-standalone.properties` and set the `plugin.path` property to your choosen location: + +[source] + +... +plugin.path=/home/oscerd/connectors +... + + +=== Setup the connectors + +Open the Cron configuration file at `$EXAMPLES/cron/cron-source/config/CamelCronSourceConnector.properties` + +[source] + +name=CamelCronSourceConnector +connector.class=org.apache.camel.kafkaconnector.cron.CamelCronSourceConnector +tasks.max=1 + +key.converter=org.apache.kafka.connect.storage.StringConverter +value.converter=org.apache.kafka.connect.storage.StringConverter + +topics=cron-topic + +camel.source.endpoint.schedule=0/5+*+*+*+*+? +camel.source.path.name=cron-timer + + +In this case we are using local unix socket. + +For the containerId you'll need to use the value of the running debian container. + +=== Running the example + +Run the kafka connect with the Cron Source connector: + +[source] + +$KAFKA_HOME/bin/connect-standalone.sh $KAFKA_HOME/config/connect-standalone.properties $EXAMPLES/cron/cron-source/config/CamelCronSourceConnector.properties + + +We'll get multiple message with statistics + +On a different terminal run the kafkacat consumer + +[source] + +./kafkacat -b localhost:9092 -t mytopic -f 'Headers: %h: Message value: %s\n' +% Auto-selecting Consumer mode (use -P or -C to override) +Headers: CamelHeader.fireTime=2021-01-21T13:15:30.255Z,CamelHeader.jobRunTime=9,CamelHeader.nextFireTime=2021-01-21T13:15:35.000Z,CamelHeader.refireCount=0,CamelHeader.scheduledFireTime=2021-01-21T13:15:30.000Z,CamelHeader.triggerGroup=Camel_camel-1,CamelHeader.triggerName=cron-timer,CamelProperty.CamelToEndpoint=direct://end?pollingConsumerBlockTimeout=0&pollingConsumerBlockWhenFull=true&pollingConsumerQueueSize=1000: Message value: +Headers: CamelHeader.fireTime=2021-01-21T13:15:35.001Z,CamelHeader.jobRunTime=1,CamelHeader.nextFireTime=2021-01-21T13:15:40.000Z,CamelHeader.previousFireTime=2021-01-21T13:15:30.000Z,CamelHeader.refireCount=0,CamelHeader.scheduledFireTime=2021-01-21T13:15:35.000Z,CamelHeader.triggerGroup=Camel_camel-1,CamelHeader.triggerName=cron-timer,CamelProperty.CamelToEndpoint=direct://end?pollingConsumerBlockTimeout=0&pollingConsumerBlockWhenFull=true&pollingConsumerQueueSize=1000: Message value: +Headers: CamelHeader.fireTime=2021-01-21T13:15:40.002Z,CamelHeader.jobRunTime=0,CamelHeader.nextFireTime=2021-01-21T13:15:45.000Z,CamelHeader.previousFireTime=2021-01-21T13:15:35.000Z,CamelHeader.refireCount=0,CamelHeader.scheduledFireTime=2021-01-21T13:15:40.000Z,CamelHeader.triggerGroup=Camel_camel-1,CamelHeader.triggerName=cron-timer,CamelProperty.CamelToEndpoint=direct://end?pollingConsumerBlockTimeout=0&pollingConsumerBlockWhenFull=true&pollingConsumerQueueSize=1000: Message value: +Headers: CamelHeader.fireTime=2021-01-21T13:15:45.002Z,CamelHeader.jobRunTime=1,CamelHeader.nextFireTime=202
[GitHub] [camel-kafka-connector-examples] oscerd closed issue #266: Add a Camel Cron Example
oscerd closed issue #266: URL: https://github.com/apache/camel-kafka-connector-examples/issues/266 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-kafka-connector-examples] branch master updated: Added a Cron source connector example
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git The following commit(s) were added to refs/heads/master by this push: new 737ed40 Added a Cron source connector example 737ed40 is described below commit 737ed40cba540d44100b4af8d4722eba733443c1 Author: Andrea Cosentino AuthorDate: Thu Jan 21 13:47:23 2021 +0100 Added a Cron source connector example --- cron/cron-source/README.adoc | 107 + .../config/CamelCronSourceConnector.properties | 28 ++ 2 files changed, 135 insertions(+) diff --git a/cron/cron-source/README.adoc b/cron/cron-source/README.adoc new file mode 100644 index 000..fc5e6da --- /dev/null +++ b/cron/cron-source/README.adoc @@ -0,0 +1,107 @@ += Camel-Kafka-connector Cron Source + +This is an example for Camel-Kafka-connector Cron Source + +== Standalone + +=== Running Kafka + +[source] + +$KAFKA_HOME/bin/zookeeper-server-start.sh $KAFKA_HOME/config/zookeeper.properties +$KAFKA_HOME/bin/kafka-server-start.sh $KAFKA_HOME/config/server.properties +$KAFKA_HOME/bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic mytopic + + +=== Download the connector package + +Download the connector package zip and extract the content to a directory. In this example we'll use `/home/oscerd/connectors/` + +[source] + +> cd /home/oscerd/connectors/ +> wget https://repo1.maven.org/maven2/org/apache/camel/kafkaconnector/camel-cron-kafka-connector/0.7.0/camel-cron-kafka-connector-0.7.0-package.zip +> unzip camel-cron-kafka-connector-0.7.0-package.zip + + +In 0.7.0, you'll need to add also camel-quartz and quartz dependency. + +[source] + +> cd /home/oscerd/connectors/camel-cron-kafka-connector +> wget https://repo1.maven.org/maven2/org/apache/camel/camel-quartz/3.7.0/camel-quartz-3.7.0.jar +> wget https://repo1.maven.org/maven2/org/quartz-scheduler/quartz/2.3.2/quartz-2.3.2.jar + + +We are now ready + +=== Configuring Kafka Connect + +You'll need to set up the `plugin.path` property in your kafka + +Open the `$KAFKA_HOME/config/connect-standalone.properties` and set the `plugin.path` property to your choosen location: + +[source] + +... +plugin.path=/home/oscerd/connectors +... + + +=== Setup the connectors + +Open the Cron configuration file at `$EXAMPLES/cron/cron-source/config/CamelCronSourceConnector.properties` + +[source] + +name=CamelCronSourceConnector +connector.class=org.apache.camel.kafkaconnector.cron.CamelCronSourceConnector +tasks.max=1 + +key.converter=org.apache.kafka.connect.storage.StringConverter +value.converter=org.apache.kafka.connect.storage.StringConverter + +topics=cron-topic + +camel.source.endpoint.schedule=0/5+*+*+*+*+? +camel.source.path.name=cron-timer + + +In this case we are using local unix socket. + +For the containerId you'll need to use the value of the running debian container. + +=== Running the example + +Run the kafka connect with the Cron Source connector: + +[source] + +$KAFKA_HOME/bin/connect-standalone.sh $KAFKA_HOME/config/connect-standalone.properties $EXAMPLES/cron/cron-source/config/CamelCronSourceConnector.properties + + +We'll get multiple message with statistics + +On a different terminal run the kafkacat consumer + +[source] + +./kafkacat -b localhost:9092 -t mytopic -f 'Headers: %h: Message value: %s\n' +% Auto-selecting Consumer mode (use -P or -C to override) +Headers: CamelHeader.fireTime=2021-01-21T13:15:30.255Z,CamelHeader.jobRunTime=9,CamelHeader.nextFireTime=2021-01-21T13:15:35.000Z,CamelHeader.refireCount=0,CamelHeader.scheduledFireTime=2021-01-21T13:15:30.000Z,CamelHeader.triggerGroup=Camel_camel-1,CamelHeader.triggerName=cron-timer,CamelProperty.CamelToEndpoint=direct://end?pollingConsumerBlockTimeout=0&pollingConsumerBlockWhenFull=true&pollingConsumerQueueSize=1000: Message value: +Headers: CamelHeader.fireTime=2021-01-21T13:15:35.001Z,CamelHeader.jobRunTime=1,CamelHeader.nextFireTime=2021-01-21T13:15:40.000Z,CamelHeader.previousFireTime=2021-01-21T13:15:30.000Z,CamelHeader.refireCount=0,CamelHeader.scheduledFireTime=2021-01-21T13:15:35.000Z,CamelHeader.triggerGroup=Camel_camel-1,CamelHeader.triggerName=cron-timer,CamelProperty.CamelToEndpoint=direct://end?pollingConsumerBlockTimeout=0&pollingConsumerBlockWhenFull=true&pollingConsumerQueueSize=1000: Message value: +Headers: CamelHeader.fireTime=2021-01-21T13:15:40.002Z,CamelHeader.jobRunTime=0,CamelHeader.nextFireTime=2021-01-21T13:15:45.000Z,CamelHeader.previousFireTime=2021-01-21T13:15:35.000Z,CamelHeader.refireCount=0,CamelHeader.scheduledFireTime=2021-01-21T13:15:40.000Z,CamelHeader.triggerGroup=Camel_camel-1,CamelHeader.triggerName=cron-timer,CamelProperty.CamelToEndpoint=direct://end?pollingConsumerBlockTimeout=0&pollingConsumerBlockWhenFull=true&pollingCo
[GitHub] [camel-kafka-connector-examples] oscerd opened a new pull request #267: Added a Cron source connector example
oscerd opened a new pull request #267: URL: https://github.com/apache/camel-kafka-connector-examples/pull/267 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector-examples] oscerd merged pull request #267: Added a Cron source connector example
oscerd merged pull request #267: URL: https://github.com/apache/camel-kafka-connector-examples/pull/267 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] apupier commented on pull request #1924: Fix modeline for inspect.
apupier commented on pull request #1924: URL: https://github.com/apache/camel-k/pull/1924#issuecomment-764621254 any ideas why it is failing? https://github.com/apache/camel-k/pull/1924/checks?check_run_id=1735814158#step:9:2538 ``` --- PASS: TestIntegrationUpgrade (71.05s) FAIL FAIL github.com/apache/camel-k/e2e/common1235.005s FAIL Error: Makefile:149: recipe for target 'test-integration' failed make: *** [test-integration] Error 1 Error: Process completed with exit code 2. ``` https://github.com/apache/camel-k/pull/1924/checks?check_run_id=1735814158#step:9:2127 ``` Error: dump.go:147: > 2021-01-20 16:29:32,520 ERROR [io.qua.run.Application] (main) Failed to start application (with profile prod): org.apache.camel.NoSuchEndpointException: No endpoint could be found for: cron://tab?schedule=0/1+*+*+*+*+?, please check your classpath contains the needed Camel component jar. ``` This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-kafka-connector-examples] branch cron-example-list created (now f4843bd)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch cron-example-list in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git. at f4843bd Added Cron to examples list No new revisions were added by this update.
[camel-kafka-connector-examples] branch master updated: Added Cron to examples list
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git The following commit(s) were added to refs/heads/master by this push: new eb13979 Added Cron to examples list eb13979 is described below commit eb13979d60cf3223ba5a79f9bb0e7aaedcf45a28 Author: Andrea Cosentino AuthorDate: Thu Jan 21 13:53:59 2021 +0100 Added Cron to examples list --- README.adoc | 1 + 1 file changed, 1 insertion(+) diff --git a/README.adoc b/README.adoc index b8941ba..ce4d11d 100644 --- a/README.adoc +++ b/README.adoc @@ -15,6 +15,7 @@ List of existing examples: - Braintree sink example - Couchbase sink example - CQL source and sink examples +- Cron source example - Docker source and sink examples - Exec sink example - File source and sink examples
[GitHub] [camel-kafka-connector-examples] oscerd opened a new pull request #268: Added Cron to examples list
oscerd opened a new pull request #268: URL: https://github.com/apache/camel-kafka-connector-examples/pull/268 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector-examples] oscerd merged pull request #268: Added Cron to examples list
oscerd merged pull request #268: URL: https://github.com/apache/camel-kafka-connector-examples/pull/268 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 cron-deps created (now 4bb25ae)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch cron-deps in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at 4bb25ae Camel-Cron connector: We need to add at least camel-quartz as dependency This branch includes the following new commits: new 4bb25ae Camel-Cron connector: We need to add at least camel-quartz as dependency The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[camel-kafka-connector] 01/01: Camel-Cron connector: We need to add at least camel-quartz as dependency
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch cron-deps in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 4bb25aeb2d08421a93f76d81f841f07d3ca41382 Author: Andrea Cosentino AuthorDate: Thu Jan 21 13:59:04 2021 +0100 Camel-Cron connector: We need to add at least camel-quartz as dependency --- connectors/camel-cron-kafka-connector/pom.xml | 4 1 file changed, 4 insertions(+) diff --git a/connectors/camel-cron-kafka-connector/pom.xml b/connectors/camel-cron-kafka-connector/pom.xml index 4c325ce..cf8500f 100644 --- a/connectors/camel-cron-kafka-connector/pom.xml +++ b/connectors/camel-cron-kafka-connector/pom.xml @@ -44,6 +44,10 @@ org.apache.camel camel-cron + + org.apache.camel + camel-quartz + org.apache.camel.kafkaconnector
[GitHub] [camel-kafka-connector] oscerd opened a new pull request #909: Camel-Cron connector: We need to add at least camel-quartz as dependency
oscerd opened a new pull request #909: URL: https://github.com/apache/camel-kafka-connector/pull/909 Fixes #908 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] aldettinger commented on a change in pull request #531: Blog: Camel Quarkus 1.6.0
aldettinger commented on a change in pull request #531: URL: https://github.com/apache/camel-website/pull/531#discussion_r561866710 ## File path: content/blog/2021/01/camel-quarkus-release-1.6.0/index.md ## @@ -0,0 +1,91 @@ +--- +title: "Camel Quarkus 1.6.0 Released" +date: 2021-01-18 +authors: ["ppalaga"] +categories: ["Releases", "Camel Quarkus"] +preview: "Camel Quarkus 1.6.0 Released" +summary: "The highlights of Camel Quarkus 1.6.0" +--- + +Original image by https://commons.wikimedia.org/wiki/User:99of9";>Toby Hudson https://creativecommons.org/licenses/by-sa/3.0";>CC BY-SA 3.0 via https://en.wikipedia.org/wiki/Camel_racing#/media/File:CamelRacingCamelCup2009Heat.JPG";>Wikipedia + +We are pleased to announce the release 1.6.0 of Camel Quarkus! Here are the highlights. + +## Java 11 required + +Having deprecated Java 8 [long time ago](https://camel.apache.org/blog/2020/04/Camel-Quarkus-release-1.0.0-M7/) and Review comment: yes it does :+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-website] aldettinger commented on a change in pull request #531: Blog: Camel Quarkus 1.6.0
aldettinger commented on a change in pull request #531: URL: https://github.com/apache/camel-website/pull/531#discussion_r561868063 ## File path: content/blog/2021/01/camel-quarkus-release-1.6.0/index.md ## @@ -0,0 +1,91 @@ +--- +title: "Camel Quarkus 1.6.0 Released" +date: 2021-01-18 +authors: ["ppalaga"] +categories: ["Releases", "Camel Quarkus"] +preview: "Camel Quarkus 1.6.0 Released" +summary: "The highlights of Camel Quarkus 1.6.0" +--- + +Original image by https://commons.wikimedia.org/wiki/User:99of9";>Toby Hudson https://creativecommons.org/licenses/by-sa/3.0";>CC BY-SA 3.0 via https://en.wikipedia.org/wiki/Camel_racing#/media/File:CamelRacingCamelCup2009Heat.JPG";>Wikipedia + +We are pleased to announce the release 1.6.0 of Camel Quarkus! Here are the highlights. + +## Java 11 required + +Having deprecated Java 8 [long time ago](https://camel.apache.org/blog/2020/04/Camel-Quarkus-release-1.0.0-M7/) and +following the same requirement by Quarkus, Camel Quarkus now requires Java 11+. + +## Support for more Camel components + +Camel Quarkus brings support for three new Camel components: + +* [JSONATA](https://camel.apache.org/camel-quarkus/latest/reference/extensions/jsonata.html) +* [Vert.x Kafka](https://camel.apache.org/camel-quarkus/latest/reference/extensions/vertx-kafka.html) +* [Redis](https://camel.apache.org/camel-quarkus/latest/reference/extensions/redis.html) (JVM only) + +Components newly supported in native mode: + +* [Azure Storage Blob Service](https://camel.apache.org/camel-quarkus/latest/reference/extensions/azure-storage-blob.html) +* [Debezium MongoDB Connector](https://camel.apache.org/camel-quarkus/latest/reference/extensions/debezium-mongodb.html) +* [Google BigQuery](https://camel.apache.org/camel-quarkus/latest/reference/extensions/google-bigquery.html) Review comment: Ah ok, the jvmSince was not correct. It is fixed in this [commit](https://github.com/apache/camel-quarkus/commit/7d8d55f44ccb79fe688d3d2e13e818c6756035cf). 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 #1924: Fix modeline for inspect.
astefanutti commented on pull request #1924: URL: https://github.com/apache/camel-k/pull/1924#issuecomment-764633428 @apupier there is a flaky e2e that fails from time to time, and that we need to investigate. I've relaunched the failing job. 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 #1931: Use Quarkus fast-jar package format apache/camel-k-runtime#360
astefanutti commented on pull request #1931: URL: https://github.com/apache/camel-k/pull/1931#issuecomment-764637620 Very nice! It may impact #1816. 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 #1816: Add option to save transitive dependencies into custom location
astefanutti commented on pull request #1816: URL: https://github.com/apache/camel-k/pull/1816#issuecomment-764637916 @doru1004 may be worth you having a look at #1816. 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 pull request #1816: Add option to save transitive dependencies into custom location
astefanutti edited a comment on pull request #1816: URL: https://github.com/apache/camel-k/pull/1816#issuecomment-764637916 @doru1004 may be worth you having a look at #1931. 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 (79d2dd4 -> 5cb42db)
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel.git. from 79d2dd4 Fixed CS new 622f031 CAMEL-16066: camel-core - Add static methods for language expressions in Builder to use for Lambda DSL new 5cb42db CAMEL-16066: Lambda DSL you can use expressions via the this instance 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: .../java/org/apache/camel/builder/Builder.java | 105 - .../org/apache/camel/builder/BuilderSupport.java | 25 ++--- .../camel/processor/LambdaRouteBuilderTest.java| 18 .../interceptor/AdviceWithLambdaTest.java | 15 +++ 4 files changed, 143 insertions(+), 20 deletions(-)
[camel] 02/02: CAMEL-16066: Lambda DSL you can use expressions via the this instance
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 5cb42db2eb8438a505cae0804fd9f47cc9195a70
Author: Claus Ibsen
AuthorDate: Thu Jan 21 14:28:11 2021 +0100
CAMEL-16066: Lambda DSL you can use expressions via the this instance
---
.../apache/camel/processor/LambdaRouteBuilderTest.java | 18 ++
.../processor/interceptor/AdviceWithLambdaTest.java| 15 +++
2 files changed, 33 insertions(+)
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/LambdaRouteBuilderTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/LambdaRouteBuilderTest.java
index adae3a6..66bf0bc 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/LambdaRouteBuilderTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/LambdaRouteBuilderTest.java
@@ -72,4 +72,22 @@ public class LambdaRouteBuilderTest extends
ContextTestSupport {
assertMockEndpointsSatisfied();
}
+@Test
+public void testLambdaSimple() throws Exception {
+assertEquals(0, context.getRoutesSize());
+
+RouteBuilder.addRoutes(context, rb ->
rb.from("direct:start").transform(rb.simple("Hello
${body}")).to("mock:result"));
+
+context.start();
+
+assertEquals(1, context.getRoutesSize());
+
+MockEndpoint mock = getMockEndpoint("mock:result");
+mock.expectedBodiesReceived("Hello World");
+
+template.sendBody("direct:start", "World");
+
+assertMockEndpointsSatisfied();
+}
+
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/interceptor/AdviceWithLambdaTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/interceptor/AdviceWithLambdaTest.java
index e63d752..d61d5ce 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/interceptor/AdviceWithLambdaTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/interceptor/AdviceWithLambdaTest.java
@@ -54,6 +54,21 @@ public class AdviceWithLambdaTest extends ContextTestSupport
{
// END SNIPPET: e1
@Test
+public void testAdvisedSimple() throws Exception {
+AdviceWith.adviceWith(context, null, a -> {
+
a.interceptSendToEndpoint("mock:foo").skipSendToOriginalEndpoint().transform(a.simple("Hello
${body}")).to("log:foo").to("mock:advised");
+});
+
+getMockEndpoint("mock:foo").expectedMessageCount(0);
+getMockEndpoint("mock:advised").expectedBodiesReceived("Hello World");
+getMockEndpoint("mock:result").expectedBodiesReceived("Hello World");
+
+template.sendBody("direct:start", "World");
+
+assertMockEndpointsSatisfied();
+}
+
+@Test
public void testAdvisedNoLog() throws Exception {
AdviceWith.adviceWith(context, null, false, a -> {
a.weaveByToUri("mock:result").remove();
[camel] 01/02: CAMEL-16066: camel-core - Add static methods for language expressions in Builder to use for Lambda DSL
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 622f031e0bacf9bcd96116fe1b6e28639749cfbf
Author: Claus Ibsen
AuthorDate: Thu Jan 21 14:20:44 2021 +0100
CAMEL-16066: camel-core - Add static methods for language expressions in
Builder to use for Lambda DSL
---
.../java/org/apache/camel/builder/Builder.java | 105 -
.../org/apache/camel/builder/BuilderSupport.java | 25 ++---
2 files changed, 110 insertions(+), 20 deletions(-)
diff --git
a/core/camel-core-model/src/main/java/org/apache/camel/builder/Builder.java
b/core/camel-core-model/src/main/java/org/apache/camel/builder/Builder.java
index 32efe96..e1c5cc0 100644
--- a/core/camel-core-model/src/main/java/org/apache/camel/builder/Builder.java
+++ b/core/camel-core-model/src/main/java/org/apache/camel/builder/Builder.java
@@ -17,9 +17,12 @@
package org.apache.camel.builder;
import org.apache.camel.Expression;
+import org.apache.camel.model.language.CSimpleExpression;
import org.apache.camel.model.language.ConstantExpression;
import org.apache.camel.model.language.ExchangePropertyExpression;
import org.apache.camel.model.language.HeaderExpression;
+import org.apache.camel.model.language.JoorExpression;
+import org.apache.camel.model.language.JsonPathExpression;
import org.apache.camel.model.language.LanguageExpression;
import org.apache.camel.model.language.MethodCallExpression;
import org.apache.camel.model.language.SimpleExpression;
@@ -49,9 +52,11 @@ public final class Builder {
*
* @param beanOrBeanRef either an instanceof a bean or a reference to
bean to lookup in the Registry
* @return the builder
+ * @deprecated use {@link #method(Object)}
*/
+@Deprecated
public static ValueBuilder bean(final Object beanOrBeanRef) {
-return bean(beanOrBeanRef, null);
+return method(beanOrBeanRef, null);
}
/**
@@ -62,8 +67,48 @@ public final class Builder {
* @param beanOrBeanRef either an instanceof a bean or a reference to
bean to lookup in the Registry
* @param methodthe method name
* @return the builder
+ * @deprecated use {@link #method(Class, String)} (Object, String)}
*/
+@Deprecated
public static ValueBuilder bean(Object beanOrBeanRef, String method) {
+return method(beanOrBeanRef, method);
+}
+
+/**
+ * Returns a http://camel.apache.org/bean-language.html";>bean
expression value builder
+ *
+ * @param beanType the bean class which will be invoked
+ * @param method name of method to invoke
+ * @return the builder
+ * @deprecated use {@link #method(Class, String)}
+ */
+@Deprecated
+public static ValueBuilder bean(Class beanType, String method) {
+return method(beanType, method);
+}
+
+/**
+ * Returns a http://camel.apache.org/bean-language.html";>method
call expression value builder.
+ *
+ * This method accepts dual parameters. Either an bean instance or a
reference to a bean (String).
+ *
+ * @param beanOrBeanRef either an instanceof a bean or a reference to
bean to lookup in the Registry
+ * @return the builder
+ */
+public static ValueBuilder method(final Object beanOrBeanRef) {
+return method(beanOrBeanRef, null);
+}
+
+/**
+ * Returns a http://camel.apache.org/bean-language.html";>method
call expression value builder.
+ *
+ * This method accepts dual parameters. Either an bean instance or a
reference to a bean (String).
+ *
+ * @param beanOrBeanRef either an instanceof a bean or a reference to
bean to lookup in the Registry
+ * @param methodthe method name
+ * @return the builder
+ */
+public static ValueBuilder method(Object beanOrBeanRef, String method) {
Expression exp;
if (beanOrBeanRef instanceof String) {
exp = new MethodCallExpression((String) beanOrBeanRef, method);
@@ -74,13 +119,13 @@ public final class Builder {
}
/**
- * Returns a http://camel.apache.org/bean-language.html";>bean
expression value builder
+ * Returns a http://camel.apache.org/bean-language.html";>method
call expression value builder
*
* @param beanType the bean class which will be invoked
* @param method name of method to invoke
* @return the builder
*/
-public static ValueBuilder bean(Class beanType, String method) {
+public static ValueBuilder method(Class beanType, String method) {
Expression exp = new MethodCallExpression(beanType, method);
return new ValueBuilder(exp);
}
@@ -107,6 +152,23 @@ public final class Builder {
}
/**
+ * Returns a csimple expression
+ */
+public static ValueBuilder csimple(St
[GitHub] [camel-website] ppalaga commented on a change in pull request #531: Blog: Camel Quarkus 1.6.0
ppalaga commented on a change in pull request #531: URL: https://github.com/apache/camel-website/pull/531#discussion_r561879993 ## File path: content/blog/2021/01/camel-quarkus-release-1.6.0/index.md ## @@ -0,0 +1,91 @@ +--- +title: "Camel Quarkus 1.6.0 Released" +date: 2021-01-18 +authors: ["ppalaga"] +categories: ["Releases", "Camel Quarkus"] +preview: "Camel Quarkus 1.6.0 Released" +summary: "The highlights of Camel Quarkus 1.6.0" +--- + +Original image by https://commons.wikimedia.org/wiki/User:99of9";>Toby Hudson https://creativecommons.org/licenses/by-sa/3.0";>CC BY-SA 3.0 via https://en.wikipedia.org/wiki/Camel_racing#/media/File:CamelRacingCamelCup2009Heat.JPG";>Wikipedia + +We are pleased to announce the release 1.6.0 of Camel Quarkus! Here are the highlights. + +## Java 11 required + +Having deprecated Java 8 [long time ago](https://camel.apache.org/blog/2020/04/Camel-Quarkus-release-1.0.0-M7/) and +following the same requirement by Quarkus, Camel Quarkus now requires Java 11+. + +## Support for more Camel components + +Camel Quarkus brings support for three new Camel components: + +* [JSONATA](https://camel.apache.org/camel-quarkus/latest/reference/extensions/jsonata.html) +* [Vert.x Kafka](https://camel.apache.org/camel-quarkus/latest/reference/extensions/vertx-kafka.html) +* [Redis](https://camel.apache.org/camel-quarkus/latest/reference/extensions/redis.html) (JVM only) + +Components newly supported in native mode: + +* [Azure Storage Blob Service](https://camel.apache.org/camel-quarkus/latest/reference/extensions/azure-storage-blob.html) +* [Debezium MongoDB Connector](https://camel.apache.org/camel-quarkus/latest/reference/extensions/debezium-mongodb.html) +* [Google BigQuery](https://camel.apache.org/camel-quarkus/latest/reference/extensions/google-bigquery.html) Review comment: Yes, exactly. 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] squakez commented on issue #1930: Warnings on getting operator versions
squakez commented on issue #1930: URL: https://github.com/apache/camel-k/issues/1930#issuecomment-764645473 Most likely yes. The way it works, every "online" command try to get the cluster operator version. It matches against the client, and if major.minor differs return the warning. 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] squakez commented on issue #1911: [CLI] Kamel run does not check source file exists
squakez commented on issue #1911: URL: https://github.com/apache/camel-k/issues/1911#issuecomment-764647147 Yeah, I will take care of backporting to 1.3 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
[camel-kafka-connector] branch master updated: Camel-Cron connector: We need to add at least camel-quartz as dependency
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/master by this push: new fb19034 Camel-Cron connector: We need to add at least camel-quartz as dependency fb19034 is described below commit fb190344625f8a279a0f3926063b2bde4e678ac2 Author: Andrea Cosentino AuthorDate: Thu Jan 21 13:59:04 2021 +0100 Camel-Cron connector: We need to add at least camel-quartz as dependency --- connectors/camel-cron-kafka-connector/pom.xml | 4 1 file changed, 4 insertions(+) diff --git a/connectors/camel-cron-kafka-connector/pom.xml b/connectors/camel-cron-kafka-connector/pom.xml index 4c325ce..cf8500f 100644 --- a/connectors/camel-cron-kafka-connector/pom.xml +++ b/connectors/camel-cron-kafka-connector/pom.xml @@ -44,6 +44,10 @@ org.apache.camel camel-cron + + org.apache.camel + camel-quartz + org.apache.camel.kafkaconnector
[GitHub] [camel-kafka-connector] oscerd closed issue #908: Camel-Cron connector: We need to add at least camel-quartz as dependency
oscerd closed issue #908: URL: https://github.com/apache/camel-kafka-connector/issues/908 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] oscerd merged pull request #909: Camel-Cron connector: We need to add at least camel-quartz as dependency
oscerd merged pull request #909: URL: https://github.com/apache/camel-kafka-connector/pull/909 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
