[GitHub] [camel-quarkus] jamesnetherton commented on pull request #3198: Fix #3157 to make sure the brokers option is configured in native mode
jamesnetherton commented on pull request #3198: URL: https://github.com/apache/camel-quarkus/pull/3198#issuecomment-946405823 Just noticed that the `functional-extension-tests-and-docs` build is failing with an error probably related to this change. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-quarkus] branch quarkus-main updated (59ba155 -> fcd8df0)
This is an automated email from the ASF dual-hosted git repository. jamesnetherton pushed a change to branch quarkus-main in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git. discard 59ba155 Upgrade Quarkus to 2.5.0.CR1 add 64e5736 Remove quarkiverse-google-cloud-services dependencies add 56a28d3 Updated CHANGELOG.md new fcd8df0 Upgrade Quarkus to 2.5.0.CR1 This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (59ba155) \ N -- N -- N refs/heads/quarkus-main (fcd8df0) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: CHANGELOG.md | 2 + .../reference/extensions/google-bigquery.adoc | 5 -- .../pages/reference/extensions/google-storage.adoc | 15 - extensions/google-bigquery/deployment/pom.xml | 4 -- .../deployment/GoogleBigqueryProcessor.java| 7 -- extensions/google-bigquery/runtime/pom.xml | 4 +- .../runtime/src/main/doc/usage.adoc| 5 -- .../GoogleBigQueryConnectionFactoryProducer.java | 40 extensions/google-pubsub/deployment/pom.xml| 4 +- extensions/google-pubsub/runtime/pom.xml | 8 ++- extensions/google-storage/deployment/pom.xml | 5 -- .../storage/deployment/GoogleStorageProcessor.java | 7 -- extensions/google-storage/runtime/pom.xml | 15 ++--- .../runtime/src/main/doc/configuration.adoc| 11 .../google/storage/GoogleStorageEnforcer.java | 35 -- integration-tests/google-bigquery/README.adoc | 5 +- .../google/bigquery/it/GoogleBigqueryResource.java | 21 +++--- integration-tests/google-storage/README.adoc | 10 +-- .../google/storage/it/GoogleStorageResource.java | 25 +++- .../src/main/resources/application.properties | 17 - pom.xml| 3 +- poms/bom/pom.xml | 75 +- 22 files changed, 100 insertions(+), 223 deletions(-) delete mode 100644 extensions/google-bigquery/runtime/src/main/java/org/apache/camel/quarkus/component/google/bigquery/GoogleBigQueryConnectionFactoryProducer.java delete mode 100644 extensions/google-storage/runtime/src/main/doc/configuration.adoc delete mode 100644 extensions/google-storage/runtime/src/main/java/org/apache/camel/quarkus/component/google/storage/GoogleStorageEnforcer.java delete mode 100644 integration-tests/google-storage/src/main/resources/application.properties
[camel-quarkus] 01/01: Upgrade Quarkus to 2.5.0.CR1
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch quarkus-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit fcd8df0c8969582736f230c37f8b32bdbcb4ac49
Author: James Netherton
AuthorDate: Thu Oct 14 07:49:19 2021 +0100
Upgrade Quarkus to 2.5.0.CR1
---
docs/antora.yml | 2 +-
.../camel/quarkus/core/deployment/CamelContextCustomizerTest.java | 2 +-
pom.xml | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/docs/antora.yml b/docs/antora.yml
index 1c231a7..426beae 100644
--- a/docs/antora.yml
+++ b/docs/antora.yml
@@ -25,4 +25,4 @@ asciidoc:
cq-camel-components: 3.12.x@components # replace
${camel.docs.components.xref}
min-maven-version: 3.6.2 # replace ${min-maven-version}
target-maven-version: 3.8.1 # replace ${target-maven-version}
-quarkus-version: 2.4.0.CR1 # replace ${quarkus.version}
+quarkus-version: 999-SNAPSHOT # replace ${quarkus.version}
diff --git
a/extensions-core/core/deployment/src/test/java/org/apache/camel/quarkus/core/deployment/CamelContextCustomizerTest.java
b/extensions-core/core/deployment/src/test/java/org/apache/camel/quarkus/core/deployment/CamelContextCustomizerTest.java
index d059d74..69f04c3 100644
---
a/extensions-core/core/deployment/src/test/java/org/apache/camel/quarkus/core/deployment/CamelContextCustomizerTest.java
+++
b/extensions-core/core/deployment/src/test/java/org/apache/camel/quarkus/core/deployment/CamelContextCustomizerTest.java
@@ -53,7 +53,7 @@ public class CamelContextCustomizerTest {
public void execute(BuildContext context) {
String methodName = "execute";
BytecodeRecorderImpl bri = new
BytecodeRecorderImpl(true, getClass().getSimpleName(), methodName,
-Integer.toString(methodName.hashCode()), true);
+Integer.toString(methodName.hashCode()), true,
s -> null);
RuntimeValue value = bri
.newInstance(RestConfigurationCustomizer.class.getName());
context.produce(new
CamelContextCustomizerBuildItem(value));
diff --git a/pom.xml b/pom.xml
index 7a3aa0b..c04e3a9 100644
--- a/pom.xml
+++ b/pom.xml
@@ -50,7 +50,7 @@
8.9.1.Final
0.3.0
2.0.0
-2.4.0.CR1
+999-SNAPSHOT
2.0.0
0.28.0
[camel] branch main updated (478e4ff -> df11636)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel.git. from 478e4ff Use latest localstack image 0.12.19.1 new 560163b Upgrade Box Java to version 2.57.0 new df11636 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 Box Java to version 2.57.0
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git commit 560163b1e39107879d0adeba840b7220019e9719 Author: Andrea Cosentino AuthorDate: Tue Oct 19 07:55:59 2021 +0200 Upgrade Box Java to version 2.57.0 --- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parent/pom.xml b/parent/pom.xml index 975419e..4bcc079 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -89,7 +89,7 @@ 2.1.0 1.4.6 1.69 -2.56.0 +2.57.0 3.12.0 5.13.3 3.2.0
[camel] 02/02: Sync deps
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git commit df1163628bcb6e48db4258b3d9f834d24c25f266 Author: Andrea Cosentino AuthorDate: Tue Oct 19 07:58:12 2021 +0200 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 aa7e12b..9f17991 100644 --- a/camel-dependencies/pom.xml +++ b/camel-dependencies/pom.xml @@ -75,7 +75,7 @@ 2.1.0 1.4.6 1.69 -2.56.0 +2.57.0 3.12.0 5.13.3 3.2.0
[camel] branch main updated: Use latest localstack image 0.12.19.1
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 478e4ff Use latest localstack image 0.12.19.1
478e4ff is described below
commit 478e4ffa38c186f110e1de1f23f3c9ee7dadf9c1
Author: Andrea Cosentino
AuthorDate: Tue Oct 19 07:46:32 2021 +0200
Use latest localstack image 0.12.19.1
---
.../java/org/apache/camel/test/infra/aws2/services/AWSContainer.java| 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/test-infra/camel-test-infra-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSContainer.java
b/test-infra/camel-test-infra-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSContainer.java
index a208741..5b84502 100644
---
a/test-infra/camel-test-infra-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSContainer.java
+++
b/test-infra/camel-test-infra-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSContainer.java
@@ -36,7 +36,7 @@ import
software.amazon.awssdk.auth.credentials.AwsCredentialsProvider;
behave as in runtime.
*/
public class AWSContainer extends GenericContainer {
-public static final String LOCALSTACK_CONTAINER =
"localstack/localstack:0.12.18";
+public static final String LOCALSTACK_CONTAINER =
"localstack/localstack:0.12.19.1";
private static final Logger LOG =
LoggerFactory.getLogger(AWSLocalContainerService.class);
private static final int SERVICE_PORT = 4566;
[camel] 02/02: Sync deps and fix formatting
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git commit f175b6f4f13992d87e9a3b8c04f9ead1f4b9a2a7 Author: Andrea Cosentino AuthorDate: Tue Oct 19 07:40:40 2021 +0200 Sync deps and fix formatting --- 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 9fab37b..aa7e12b 100644 --- a/camel-dependencies/pom.xml +++ b/camel-dependencies/pom.xml @@ -66,7 +66,7 @@ 1.10.2 1.10.2 4.1.0 -2.17.61 +2.17.62 2.6.1 1.2.14 2.11.3
[camel] branch main updated (896c08d -> f175b6f)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel.git. from 896c08d CAMEL-17102: camel-core - EventNotifier for CamelContextInitializing/Initiazed should fire even if the notifier has not been fully started. new e1b284e Upgrade AWS SDK v2 to version 2.17.62 new f175b6f Sync deps and fix formatting 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 AWS SDK v2 to version 2.17.62
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git commit e1b284e8a091937e9eeab0c86194bf67cc4738c9 Author: Andrea Cosentino AuthorDate: Tue Oct 19 06:31:22 2021 +0200 Upgrade AWS SDK v2 to version 2.17.62 --- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parent/pom.xml b/parent/pom.xml index d928eb0..975419e 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -80,7 +80,7 @@ 1.10.2 1.10.2 4.1.0 -2.17.61 +2.17.62 2.6.1 1.2.14 1.0.3
[camel] 01/03: Regen
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 2e8676861ef5488fdea285d3c2011254e4e54cc8
Author: Claus Ibsen
AuthorDate: Mon Oct 18 16:36:24 2021 +0200
Regen
---
.../src/test/java/org/apache/camel/processor/SplitterMapTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/SplitterMapTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/SplitterMapTest.java
index d6fe903..6dcdb21 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/SplitterMapTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/SplitterMapTest.java
@@ -49,7 +49,7 @@ public class SplitterMapTest extends ContextTestSupport {
@Override
public void configure() throws Exception {
from("direct:start")
-.split(body())
+.split(body())
.setHeader("myKey").simple("${body.key}")
.setBody(simple("${body.value}"))
.to("mock:line");
[camel] branch main updated (b979c10 -> 896c08d)
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel.git. from b979c10 (chores) camel-activemq: cleaned up tests to avoid Thread.sleep calls new 2e86768 Regen new d7f29e9 CAMEL-17102: camel-core - EventNotifier for CamelContextInitializing/Initiazed should fire even if the notifier has not been fully started. new 896c08d CAMEL-17102: camel-core - EventNotifier for CamelContextInitializing/Initiazed should fire even if the notifier has not been fully started. 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: .../camel/cdi/test/CamelEventNotifierTest.java | 15 +++ .../java/org/apache/camel/spi/EventNotifier.java | 4 + .../camel/impl/event/EventNotifierEventsTest.java | 132 +++-- .../EventNotifierFailureHandledEventsTest.java | 114 +- ...ntNotifierIgnoreCamelContextInitEventsTest.java | 113 ++ .../event/EventNotifierRedeliveryEventsTest.java | 2 +- .../event/MultipleEventNotifierEventsTest.java | 102 .../impl/event/SimpleEventNotifierEventsTest.java | 116 +- .../apache/camel/processor/SplitterMapTest.java| 2 +- .../camel/management/RemoveEventNotifierTest.java | 4 +- .../java/org/apache/camel/support/EventHelper.java | 25 ++-- .../camel/support/SimpleEventNotifierSupport.java | 11 ++ .../ROOT/pages/camel-3x-upgrade-guide-3_13.adoc| 6 + 13 files changed, 411 insertions(+), 235 deletions(-) create mode 100644 core/camel-core/src/test/java/org/apache/camel/impl/event/EventNotifierIgnoreCamelContextInitEventsTest.java
[camel] 03/03: CAMEL-17102: camel-core - EventNotifier for CamelContextInitializing/Initiazed should fire even if the notifier has not been fully started.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 896c08d99912ddbed796d10fd1ac5d5fe66c6b49
Author: Claus Ibsen
AuthorDate: Tue Oct 19 07:38:22 2021 +0200
CAMEL-17102: camel-core - EventNotifier for
CamelContextInitializing/Initiazed should fire even if the notifier has not
been fully started.
---
.../org/apache/camel/cdi/test/CamelEventNotifierTest.java | 15 +++
1 file changed, 15 insertions(+)
diff --git
a/components/camel-cdi/src/test/java/org/apache/camel/cdi/test/CamelEventNotifierTest.java
b/components/camel-cdi/src/test/java/org/apache/camel/cdi/test/CamelEventNotifierTest.java
index 2f29f62..b6d80bc 100644
---
a/components/camel-cdi/src/test/java/org/apache/camel/cdi/test/CamelEventNotifierTest.java
+++
b/components/camel-cdi/src/test/java/org/apache/camel/cdi/test/CamelEventNotifierTest.java
@@ -31,6 +31,7 @@ import org.apache.camel.cdi.CdiCamelExtension;
import org.apache.camel.cdi.Uri;
import org.apache.camel.cdi.bean.SimpleCamelRoute;
import org.apache.camel.component.mock.MockEndpoint;
+import org.apache.camel.spi.CamelEvent;
import org.apache.camel.spi.CamelEvent.CamelContextStartedEvent;
import org.apache.camel.spi.CamelEvent.CamelContextStartingEvent;
import org.apache.camel.spi.CamelEvent.CamelContextStoppedEvent;
@@ -69,6 +70,14 @@ public class CamelEventNotifierTest {
@ApplicationScoped
private List firedEvents = new ArrayList<>();
+private void onCamelContextStartingEvent(@Observes
CamelEvent.CamelContextInitializingEvent event, List events) {
+events.add(CamelEvent.CamelContextInitializingEvent.class);
+}
+
+private void onCamelContextStartingEvent(@Observes
CamelEvent.CamelContextInitializedEvent event, List events) {
+events.add(CamelEvent.CamelContextInitializedEvent.class);
+}
+
private void onCamelContextStartingEvent(@Observes
CamelContextStartingEvent event, List events) {
events.add(CamelContextStartingEvent.class);
}
@@ -105,6 +114,8 @@ public class CamelEventNotifierTest {
public void startedCamelContext(List events) {
assertThat("Events fired are incorrect!", events,
contains(
+CamelEvent.CamelContextInitializingEvent.class,
+CamelEvent.CamelContextInitializedEvent.class,
CamelContextStartingEvent.class,
CamelContextStartedEvent.class));
}
@@ -121,6 +132,8 @@ public class CamelEventNotifierTest {
assertThat("Events fired are incorrect!", events,
contains(
+CamelEvent.CamelContextInitializingEvent.class,
+CamelEvent.CamelContextInitializedEvent.class,
CamelContextStartingEvent.class,
CamelContextStartedEvent.class,
ExchangeSendingEvent.class,
@@ -138,6 +151,8 @@ public class CamelEventNotifierTest {
assertThat("Events fired are incorrect!", events,
contains(
+CamelEvent.CamelContextInitializingEvent.class,
+CamelEvent.CamelContextInitializedEvent.class,
CamelContextStartingEvent.class,
CamelContextStartedEvent.class,
ExchangeSendingEvent.class,
[camel] 02/03: CAMEL-17102: camel-core - EventNotifier for CamelContextInitializing/Initiazed should fire even if the notifier has not been fully started.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit d7f29e9c39be08280ae46ac4682444a7e1c8a854
Author: Claus Ibsen
AuthorDate: Tue Oct 19 07:34:39 2021 +0200
CAMEL-17102: camel-core - EventNotifier for
CamelContextInitializing/Initiazed should fire even if the notifier has not
been fully started.
---
.../java/org/apache/camel/spi/EventNotifier.java | 4 +
.../camel/impl/event/EventNotifierEventsTest.java | 132 +++--
.../EventNotifierFailureHandledEventsTest.java | 114 +-
...ntNotifierIgnoreCamelContextInitEventsTest.java | 113 ++
.../event/EventNotifierRedeliveryEventsTest.java | 2 +-
.../event/MultipleEventNotifierEventsTest.java | 102
.../impl/event/SimpleEventNotifierEventsTest.java | 116 +-
.../camel/management/RemoveEventNotifierTest.java | 4 +-
.../java/org/apache/camel/support/EventHelper.java | 25 ++--
.../camel/support/SimpleEventNotifierSupport.java | 11 ++
.../ROOT/pages/camel-3x-upgrade-guide-3_13.adoc| 6 +
11 files changed, 395 insertions(+), 234 deletions(-)
diff --git
a/core/camel-api/src/main/java/org/apache/camel/spi/EventNotifier.java
b/core/camel-api/src/main/java/org/apache/camel/spi/EventNotifier.java
index 8abdd4d..4312d01 100644
--- a/core/camel-api/src/main/java/org/apache/camel/spi/EventNotifier.java
+++ b/core/camel-api/src/main/java/org/apache/camel/spi/EventNotifier.java
@@ -48,6 +48,10 @@ public interface EventNotifier {
*/
boolean isDisabled();
+boolean isIgnoreCamelContextInitEvents();
+
+void setIgnoreCamelContextInitEvents(boolean ignoreCamelContextInitEvents);
+
boolean isIgnoreCamelContextEvents();
void setIgnoreCamelContextEvents(boolean ignoreCamelContextEvents);
diff --git
a/core/camel-core/src/test/java/org/apache/camel/impl/event/EventNotifierEventsTest.java
b/core/camel-core/src/test/java/org/apache/camel/impl/event/EventNotifierEventsTest.java
index 1878eff..98bd0f0 100644
---
a/core/camel-core/src/test/java/org/apache/camel/impl/event/EventNotifierEventsTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/impl/event/EventNotifierEventsTest.java
@@ -79,40 +79,42 @@ public class EventNotifierEventsTest {
mock.assertIsSatisfied();
-assertEquals(18, events.size());
-assertIsInstanceOf(CamelContextStartingEvent.class, events.get(0));
-assertIsInstanceOf(CamelContextRoutesStartingEvent.class,
events.get(1));
-assertIsInstanceOf(RouteAddedEvent.class, events.get(2));
-assertIsInstanceOf(RouteAddedEvent.class, events.get(3));
-assertIsInstanceOf(RouteStartingEvent.class, events.get(4));
-assertIsInstanceOf(RouteStartedEvent.class, events.get(5));
+assertEquals(20, events.size());
+assertIsInstanceOf(CamelEvent.CamelContextInitializingEvent.class,
events.get(0));
+assertIsInstanceOf(CamelEvent.CamelContextInitializedEvent.class,
events.get(1));
+assertIsInstanceOf(CamelContextStartingEvent.class, events.get(2));
+assertIsInstanceOf(CamelContextRoutesStartingEvent.class,
events.get(3));
+assertIsInstanceOf(RouteAddedEvent.class, events.get(4));
+assertIsInstanceOf(RouteAddedEvent.class, events.get(5));
assertIsInstanceOf(RouteStartingEvent.class, events.get(6));
assertIsInstanceOf(RouteStartedEvent.class, events.get(7));
-assertIsInstanceOf(CamelContextRoutesStartedEvent.class,
events.get(8));
-assertIsInstanceOf(CamelContextStartedEvent.class, events.get(9));
-assertIsInstanceOf(ExchangeCreatedEvent.class, events.get(11));
-assertIsInstanceOf(ExchangeSendingEvent.class, events.get(12));
-assertIsInstanceOf(ExchangeSentEvent.class, events.get(13));
+assertIsInstanceOf(RouteStartingEvent.class, events.get(8));
+assertIsInstanceOf(RouteStartedEvent.class, events.get(9));
+assertIsInstanceOf(CamelContextRoutesStartedEvent.class,
events.get(10));
+assertIsInstanceOf(CamelContextStartedEvent.class, events.get(11));
+assertIsInstanceOf(ExchangeCreatedEvent.class, events.get(13));
assertIsInstanceOf(ExchangeSendingEvent.class, events.get(14));
assertIsInstanceOf(ExchangeSentEvent.class, events.get(15));
-assertIsInstanceOf(ExchangeCompletedEvent.class, events.get(16));
+assertIsInstanceOf(ExchangeSendingEvent.class, events.get(16));
+assertIsInstanceOf(ExchangeSentEvent.class, events.get(17));
+assertIsInstanceOf(ExchangeCompletedEvent.class, events.get(18));
// this is the sent using the produce template to start the test
assertIsInstanceOf(ExchangeSentEvent.class, events.get(17));
context.stop();
-assertEquals(28, events.size());
-assertIsInstanceOf(CamelCon
[GitHub] [camel-quarkus] zbendhiba closed pull request #3196: Don't merge please - WIP - Dummy test
zbendhiba closed pull request #3196: URL: https://github.com/apache/camel-quarkus/pull/3196 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] oscerd commented on issue #1272: Using kinesis sink with STS assumeRole credentials?
oscerd commented on issue #1272: URL: https://github.com/apache/camel-kafka-connector/issues/1272#issuecomment-946364589 You can use the credential provider chain of all the AWS Client, by enabling the defaultCredentialProvider option and adding the correct jars in an extended connector. There is no way of doing the assumeRole operation while building the client, the option to specify an instance of the Kinesis client is only related to a single instance (through constructor) but since the client is using builder, it's not possible to do that through options. If you need to do assumeRole operation before doing anything else, my suggestion is using plain camel with Kafka, instead of using camel-kafka-connector. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] oscerd commented on issue #1263: UseDefaultCredentials Provider doesn't recognize web identity token file
oscerd commented on issue #1263: URL: https://github.com/apache/camel-kafka-connector/issues/1263#issuecomment-946360426 I don't think you can do in that way, you need to build a tar.gz connector self-containing STS jar in the same folder, so in the plugin path you'll have a directory for S3 Source connector containining all the connector JARs plus the STS jar. In the way you're doing I don't think the folder will be the same. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] github-actions[bot] commented on issue #2927: [CI] - Camel Main Branch Build Failure
github-actions[bot] commented on issue #2927: URL: https://github.com/apache/camel-quarkus/issues/2927#issuecomment-946355992 The [camel-main](https://github.com/apache/camel-quarkus/tree/camel-main) branch build has failed: * Build ID: 1356988296-440-d7456a50-e1ab-424c-9ee1-ac34df8b5260 * Camel Quarkus Commit: 79aae7400925020c0e2b28b154a118ffe76b11e6 * Camel Main Commit: 64e573611bfb67c83b0603709d104b5470949906 * Link to build: https://github.com/apache/camel-quarkus/actions/runs/1356988296 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-spring-boot] oscerd merged pull request #390: [Github Actions] Periodic Sync Camel Spring Boot Main Branch
oscerd merged pull request #390: URL: https://github.com/apache/camel-spring-boot/pull/390 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-spring-boot] branch main updated: [create-pull-request] automated change
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git The following commit(s) were added to refs/heads/main by this push: new cbba727 [create-pull-request] automated change cbba727 is described below commit cbba727fe7f89307e3b03c1450c20c237f61f302 Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Tue Oct 19 00:59:47 2021 + [create-pull-request] automated change --- tooling/camel-spring-boot-dependencies/pom.xml | 56 +- 1 file changed, 28 insertions(+), 28 deletions(-) diff --git a/tooling/camel-spring-boot-dependencies/pom.xml b/tooling/camel-spring-boot-dependencies/pom.xml index 5a7de7c..4c44f5d 100644 --- a/tooling/camel-spring-boot-dependencies/pom.xml +++ b/tooling/camel-spring-boot-dependencies/pom.xml @@ -4440,142 +4440,142 @@ org.apache.cxf.services.sts cxf-services-sts-core -3.4.4 +3.4.5 org.apache.cxf.services.ws-discovery cxf-services-ws-discovery-api -3.4.4 +3.4.5 org.apache.cxf cxf-core -3.4.4 +3.4.5 org.apache.cxf cxf-rt-bindings-soap -3.4.4 +3.4.5 org.apache.cxf cxf-rt-bindings-xml -3.4.4 +3.4.5 org.apache.cxf cxf-rt-databinding-jaxb -3.4.4 +3.4.5 org.apache.cxf cxf-rt-features-clustering -3.4.4 +3.4.5 org.apache.cxf cxf-rt-features-logging -3.4.4 +3.4.5 org.apache.cxf cxf-rt-frontend-jaxrs -3.4.4 +3.4.5 org.apache.cxf cxf-rt-frontend-jaxws -3.4.4 +3.4.5 org.apache.cxf cxf-rt-frontend-simple -3.4.4 +3.4.5 org.apache.cxf cxf-rt-management -3.4.4 +3.4.5 org.apache.cxf cxf-rt-rs-client -3.4.4 +3.4.5 org.apache.cxf cxf-rt-rs-extension-providers -3.4.4 +3.4.5 org.apache.cxf cxf-rt-rs-security-oauth2 -3.4.4 +3.4.5 org.apache.cxf cxf-rt-rs-service-description-swagger -3.4.4 +3.4.5 org.apache.cxf cxf-rt-transports-http -3.4.4 +3.4.5 org.apache.cxf cxf-rt-transports-http-jetty -3.4.4 +3.4.5 org.apache.cxf cxf-rt-transports-jms -3.4.4 +3.4.5 org.apache.cxf cxf-rt-transports-local -3.4.4 +3.4.5 org.apache.cxf cxf-rt-ws-addr -3.4.4 +3.4.5 org.apache.cxf cxf-rt-ws-mex -3.4.4 +3.4.5 org.apache.cxf cxf-rt-ws-policy -3.4.4 +3.4.5 org.apache.cxf cxf-rt-ws-rm -3.4.4 +3.4.5 org.apache.cxf cxf-rt-ws-security -3.4.4 +3.4.5 org.apache.cxf cxf-rt-ws-security-oauth2 -3.4.4 +3.4.5 org.apache.cxf cxf-rt-wsdl -3.4.4 +3.4.5 org.apache.cxf cxf-testutils -3.4.4 +3.4.5 org.apache.ftpserver
[GitHub] [camel-k] tadayosi opened a new pull request #2700: CI test dump improvements
tadayosi opened a new pull request #2700: URL: https://github.com/apache/camel-k/pull/2700 - Make CI dump services and routes (for OpenShift) on test failures - Remove lenghty `managedFields` from dump for log readability **Release Note** ```release-note NONE ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-quarkus] branch main updated: Updated CHANGELOG.md
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git The following commit(s) were added to refs/heads/main by this push: new 56a28d3 Updated CHANGELOG.md 56a28d3 is described below commit 56a28d33a99128e379c42085f7211b2279a67fd1 Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Tue Oct 19 03:11:05 2021 + Updated CHANGELOG.md --- CHANGELOG.md | 2 ++ 1 file changed, 2 insertions(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index ea046ed..c1883f6 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -22,6 +22,7 @@ - Unify package names for the for the test in camel-quarkus-examples [\#3152](https://github.com/apache/camel-quarkus/issues/3152) - Register camel \<--\> CDI event bridges only when observers for the events are detected [\#3149](https://github.com/apache/camel-quarkus/issues/3149) - Docs xref check failures [\#3143](https://github.com/apache/camel-quarkus/issues/3143) +- Google-Storage Extension: Cannot set serviceAccountKey because of Quarkiverse extension [\#3131](https://github.com/apache/camel-quarkus/issues/3131) - \[Camel 3.12\] enable autoCreate CI integration tests [\#3097](https://github.com/apache/camel-quarkus/issues/3097) - \[Camel 3.11.2, 3.12.0\] Consider usage of `IgnoreSplitPackageBuildItem` [\#2997](https://github.com/apache/camel-quarkus/issues/2997) - \[Camel 3.12\] Subclasses of ServiceCallConfiguration should not need to be registered for reflection [\#2955](https://github.com/apache/camel-quarkus/issues/2955) @@ -31,6 +32,7 @@ **Merged pull requests:** +- Remove quarkiverse-google-cloud-services dependencies [\#3188](https://github.com/apache/camel-quarkus/pull/3188) ([jamesnetherton](https://github.com/jamesnetherton)) - Fixes \#3184: Add requires attribute to playbook [\#3187](https://github.com/apache/camel-quarkus/pull/3187) ([djencks](https://github.com/djencks)) - Aws2-lambda: Add event source mapping test \#2749 [\#3186](https://github.com/apache/camel-quarkus/pull/3186) ([aldettinger](https://github.com/aldettinger)) - Improve the User guide [\#3185](https://github.com/apache/camel-quarkus/pull/3185) ([ppalaga](https://github.com/ppalaga))
[GitHub] [camel] zhfeng commented on pull request #6300: CAMEL-17105: Use isRollbackOnlyLast flag in TransactionErrorHandler
zhfeng commented on pull request #6300: URL: https://github.com/apache/camel/pull/6300#issuecomment-946319806 @Braidner can you squash your commits into one ? And if we change to use ``` ``` in error-handler, is there any different behavior ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] zhfeng commented on issue #3157: URL to the Kafka brokers must be configured with the brokers option in native mode
zhfeng commented on issue #3157: URL: https://github.com/apache/camel-quarkus/issues/3157#issuecomment-946317221 It's too late to registe the ```CamelBeanBuildItem``` in native mode due to the KafkaDevSerivce is avaiable in TEST mode. It's just running before the application starts. So we only need to pass ```camel.component.kafka.brokers=PLAINTEXT://localhost:31318``` option to the native application. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] zhfeng opened a new pull request #3198: Fix #3157 to make sure the brokers option is configured in native mode
zhfeng opened a new pull request #3198: URL: https://github.com/apache/camel-quarkus/pull/3198 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] jamesnetherton opened a new issue #2926: [CI] - Quarkus Main Branch Build Failure
jamesnetherton opened a new issue #2926: URL: https://github.com/apache/camel-quarkus/issues/2926 This is a placeholder issue used by the [nightly sync workflow](https://github.com/apache/camel-quarkus/actions/workflows/quarkus-master-cron.yaml) for the [`quarkus-main`](https://github.com/apache/camel-quarkus/tree/quarkus-main) branch. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] github-actions[bot] commented on issue #2926: [CI] - Quarkus Main Branch Build Failure
github-actions[bot] commented on issue #2926: URL: https://github.com/apache/camel-quarkus/issues/2926#issuecomment-946310064 The [quarkus-main](https://github.com/apache/camel-quarkus/tree/quarkus-main) branch build has failed: * Build ID: 1357302528-544-620b3f55-6dd0-4802-9cb7-276517b671ae * Camel Quarkus Commit: 59ba1550777b3c0b438194a66049d936670ccdcb * Quarkus Main Commit: Unknown * Link to build: https://github.com/apache/camel-quarkus/actions/runs/1357302528 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-spring-boot] github-actions[bot] opened a new pull request #390: [Github Actions] Periodic Sync Camel Spring Boot Main Branch
github-actions[bot] opened a new pull request #390: URL: https://github.com/apache/camel-spring-boot/pull/390 Periodic Sync of Camel Spring Boot Main Branch with main Camel Main. see https://github.com/apache/camel-spring-boot/blob/main/.github/workflows/automatic-sync-main.yml -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-spring-boot] branch automatic-periodic-sync updated (16e9965 -> befa4d2)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch automatic-periodic-sync in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git. omit 16e9965 [create-pull-request] automated change add af1025f [create-pull-request] automated change add befa4d2 [create-pull-request] automated change This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (16e9965) \ N -- N -- N refs/heads/automatic-periodic-sync (befa4d2) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: tooling/camel-spring-boot-dependencies/pom.xml | 56 +- 1 file changed, 28 insertions(+), 28 deletions(-)
[GitHub] [camel-quarkus] ppalaga opened a new pull request #3197: Documentation and metadata improvements
ppalaga opened a new pull request #3197: URL: https://github.com/apache/camel-quarkus/pull/3197 Fix #3195 Fix #3194 Fix #3193 Fix #3192 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] oscerd commented on pull request #6292: CAMEL-17096: Add async commit support in camel-kafka component
oscerd commented on pull request #6292: URL: https://github.com/apache/camel/pull/6292#issuecomment-946151396 It's not related to your PR. It is coming from another commit. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] ludovic-boutros commented on pull request #6292: CAMEL-17096: Add async commit support in camel-kafka component
ludovic-boutros commented on pull request #6292: URL: https://github.com/apache/camel/pull/6292#issuecomment-946144771 Checks are failing here but are passing on my machine. An idea why @orpiske @oscerd @davsclaus ? Same on the other PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-website] branch asf-site updated (1106edc -> 7501484)
This is an automated email from the ASF dual-hosted git repository. git-site-role pushed a change to branch asf-site in repository https://gitbox.apache.org/repos/asf/camel-website.git. discard 1106edc Website updated to 5c1474cef7ca9926c38c7a59cc0132d5809544d2 discard 194d7fe Website updated to 325e929157412b27394080f4d4dba3d821476ddf new 8100325 Website updated to 325e929157412b27394080f4d4dba3d821476ddf new 7501484 Website updated to 5c1474cef7ca9926c38c7a59cc0132d5809544d2 This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (1106edc) \ N -- N -- N refs/heads/asf-site (7501484) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: sitemap-camel-k.xml | 390 +-- sitemap-camel-kafka-connector.xml | 2176 +++ sitemap-camel-kamelets.xml| 272 +- sitemap-camel-karaf.xml | 56 +- sitemap-camel-quarkus.xml | 1376 - sitemap-camel-spring-boot.xml | 46 +- sitemap-components.xml| 5538 ++--- sitemap-manual.xml| 380 +-- 8 files changed, 5117 insertions(+), 5117 deletions(-)
[GitHub] [camel] ludovic-boutros commented on pull request #6292: CAMEL-17096: Add async commit support in camel-kafka component
ludovic-boutros commented on pull request #6292: URL: https://github.com/apache/camel/pull/6292#issuecomment-946128180 Okay, thank you for the reviews. I've made the requested changes. I've used separated classes and let `commitSync` function as deprecated in order to prevent hard breaking change. Let me know if it's done the way you thought. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] djencks commented on issue #3191: Publish docs for the last stable release
djencks commented on issue #3191: URL: https://github.com/apache/camel-quarkus/issues/3191#issuecomment-946124416 There are some complications: references to 2.0.0 from camel-k, both latest and 1.4. I think that: - camel-quarkus main (latest) refers to unreleased code and should therefore be marked prerelease for Antora - there is no meaningful tie between camel-k and camel-quarkus so all references can go to the latest released version of camel-quarkus. I'll proceed from this basis. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-website] branch asf-site updated (c071012 -> 1106edc)
This is an automated email from the ASF dual-hosted git repository. git-site-role pushed a change to branch asf-site in repository https://gitbox.apache.org/repos/asf/camel-website.git. discard c071012 Website updated to e5cb1d5b93f0d23877bd0a7083fcfed7eaaf7b63 discard 845bc33 Website updated to 325e929157412b27394080f4d4dba3d821476ddf new 194d7fe Website updated to 325e929157412b27394080f4d4dba3d821476ddf new 1106edc Website updated to 5c1474cef7ca9926c38c7a59cc0132d5809544d2 This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (c071012) \ N -- N -- N refs/heads/asf-site (1106edc) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../reference/extensions/google-bigquery.html |2 +- .../reference/extensions/google-storage.html |2 +- components/3.11.x/eips/setOutHeader-eip.html |2 +- components/3.12.x/eips/setOutHeader-eip.html |2 +- components/3.7.x/eips/setOutHeader-eip.html|2 +- components/latest/eips/scatter-gather.html | 18 +- components/latest/eips/script-eip.html | 30 +- components/latest/eips/selective-consumer.html | 19 +- components/latest/eips/service-activator.html |4 +- components/latest/eips/serviceCall-eip.html| 93 +- components/latest/eips/setHeader-eip.html | 40 +- components/latest/eips/setOutHeader-eip.html | 15 - manual/latest/camel-3x-upgrade-guide-3_13.html |2 +- sitemap-camel-k.xml| 390 +- sitemap-camel-kafka-connector.xml | 2176 sitemap-camel-kamelets.xml | 272 +- sitemap-camel-karaf.xml| 56 +- sitemap-camel-quarkus.xml | 1376 ++--- sitemap-camel-spring-boot.xml | 46 +- sitemap-components.xml | 5542 ++-- sitemap-manual.xml | 380 +- 21 files changed, 5216 insertions(+), 5253 deletions(-) delete mode 100644 components/latest/eips/setOutHeader-eip.html
[GitHub] [camel-quarkus] zbendhiba commented on pull request #3196: Don't merge please - WIP - Dummy test
zbendhiba commented on pull request #3196: URL: https://github.com/apache/camel-quarkus/pull/3196#issuecomment-946105428 I want to check if CI fails. No need to review -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] zbendhiba opened a new pull request #3196: Don't merge please - WIP - Dummy test
zbendhiba opened a new pull request #3196: URL: https://github.com/apache/camel-quarkus/pull/3196 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] zregvart merged pull request #647: [Blog] VS Code Camel Language support 0.1.0 announcement
zregvart merged pull request #647: URL: https://github.com/apache/camel-website/pull/647 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-website] branch main updated: [Blog] VS Code Camel Language support 0.1.0 announcement
This is an automated email from the ASF dual-hosted git repository. zregvart pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-website.git The following commit(s) were added to refs/heads/main by this push: new 5c1474c [Blog] VS Code Camel Language support 0.1.0 announcement 5c1474c is described below commit 5c1474cef7ca9926c38c7a59cc0132d5809544d2 Author: Aurélien Pupier AuthorDate: Mon Oct 18 17:15:14 2021 +0200 [Blog] VS Code Camel Language support 0.1.0 announcement Signed-off-by: Aurélien Pupier --- .../choiceFolding.gif | Bin 0 -> 56688 bytes .../completionChannelConnectedMode.png | Bin 0 -> 69479 bytes .../completionNamespace.png| Bin 0 -> 122155 bytes .../index.md | 46 + 4 files changed, 46 insertions(+) diff --git a/content/blog/2021/10/vscode-camel-language-support-release-0.1.0/choiceFolding.gif b/content/blog/2021/10/vscode-camel-language-support-release-0.1.0/choiceFolding.gif new file mode 100644 index 000..b7cb8dc Binary files /dev/null and b/content/blog/2021/10/vscode-camel-language-support-release-0.1.0/choiceFolding.gif differ diff --git a/content/blog/2021/10/vscode-camel-language-support-release-0.1.0/completionChannelConnectedMode.png b/content/blog/2021/10/vscode-camel-language-support-release-0.1.0/completionChannelConnectedMode.png new file mode 100644 index 000..0fe1505 Binary files /dev/null and b/content/blog/2021/10/vscode-camel-language-support-release-0.1.0/completionChannelConnectedMode.png differ diff --git a/content/blog/2021/10/vscode-camel-language-support-release-0.1.0/completionNamespace.png b/content/blog/2021/10/vscode-camel-language-support-release-0.1.0/completionNamespace.png new file mode 100644 index 000..26fec68 Binary files /dev/null and b/content/blog/2021/10/vscode-camel-language-support-release-0.1.0/completionNamespace.png differ diff --git a/content/blog/2021/10/vscode-camel-language-support-release-0.1.0/index.md b/content/blog/2021/10/vscode-camel-language-support-release-0.1.0/index.md new file mode 100644 index 000..13c42c0 --- /dev/null +++ b/content/blog/2021/10/vscode-camel-language-support-release-0.1.0/index.md @@ -0,0 +1,46 @@ +--- +title: "New release of VS Code Language Support for Apache Camel 0.1.0" +date: 2021-10-19 +authors: [apupier] +categories: ["Releases","Tooling"] +preview: "New release of VS Code Language Support for Apache Camel 0.1.0: Java 8 drop, catalog upgrades and connected mode completion for Kubernetes and Knative Camel URI." +--- + +A new release of [VS Code Language Support for Apache Camel](https://marketplace.visualstudio.com/items?itemName=redhat.vscode-apache-camel) 0.1.0 is available. It includes upgrade of Camel catalogs, removal of Java 8 as runtime for embedded Language Server, connected mode completion for Kubernetes and Knative and folding of choice in Java. + +# Removal of Java 8 as runtime for embedded Language Server + +The removal of Java 8 as runtime for embedded Language Server allowed the upgrade of Camel Quarkus Catalog and some test dependencies. Java 8 is planned to be dropped in several of current dependencies, [including Camel](/blog/2021/09/eol-java8/). It is time to move forward. + +Java 8 is still usable for the Camel projects themselves that support it. It will impact only the tooling provided through the Camel Language Server. + +# Connected-mode for completion of Knative and Kubernetes components + +When a kubernetes connection is configured, either via command-line interface or by VS Code Kubernetes extension, the completion is looking up in the Kubernetes instance for the following cases: +* namespace attribute value on _kubernetes-*_ components + +* endpoint, channel and event component path values on _knative_ component + + +# Camel catalogs version upgrades + +The default Camel catalog has been upgraded from 3.11.1 to 3.12.0. + +The Kamelet catalog has been upgraded from 0.3.0 to 0.4.0. + +The Camel Quarkus catalog has been upgraded from 2.0.0 to 2.3.0. + +The Camel kafka connector catalog has been upgraded from 0.10.1 to 0.11.0. + +# Folding of Camel routes in Java editor + +In previous release, it was possible to [fold a Camel route](/blog/2021/09/vscode-camel-language-support-release-0.0.35#folding-of-camel-routes-in-java-editor). It is now possible to fold each choice of Camel routes in the java editor. + + + +# What's next? + +Provide your feedback and ideas! +You can start discussions on [Zulip camel-tooling channel](https://camel.zulipchat.com/#narrow/stream/258729-camel-tooling). +You can create and vote for issues on github [Camel
[camel-k] branch main updated (a1e5530 -> 7d34fd6)
This is an automated email from the ASF dual-hosted git repository. astefanutti pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel-k.git. from a1e5530 fix: Round meta.Time fields to second precision as they are marshalled in RFC3339 format add 7d34fd6 fix(ci): broken stale action No new revisions were added by this update. Summary of changes: .github/stale.yml| 12 .github/workflows/stale.yaml | 28 +--- 2 files changed, 13 insertions(+), 27 deletions(-) delete mode 100644 .github/stale.yml
[GitHub] [camel-k] astefanutti merged pull request #2699: fix(ci): broken stale action
astefanutti merged pull request #2699: URL: https://github.com/apache/camel-k/pull/2699 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] astefanutti closed issue #2698: Stale bot action failing
astefanutti closed issue #2698: URL: https://github.com/apache/camel-k/issues/2698 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] zbendhiba commented on issue #2578: [camel 3.13] Atlasmap : use jandex index for atlasmap bean discovery
zbendhiba commented on issue #2578: URL: https://github.com/apache/camel-quarkus/issues/2578#issuecomment-946016030 the jandex files are available in Camel 3.13 but there is a blocker : https://github.com/apache/camel-quarkus/issues/3189 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] arjun180 commented on issue #1263: UseDefaultCredentials Provider doesn't recognize web identity token file
arjun180 commented on issue #1263: URL: https://github.com/apache/camel-kafka-connector/issues/1263#issuecomment-946013913 Hi @oscerd - Sorry for the delay. I added the STS jar. Now my Kafka-connect yaml looks like : ``` apiVersion: kafka.strimzi.io/v1beta2 kind: KafkaConnect metadata: namespace : my-kafka name: my-connect-cluster annotations: strimzi.io/use-connector-resources: "true" spec: template: serviceAccount: metadata: annotations: eks.amazonaws.com/role-arn:arn:aws:iam:::role/my-kafka-sa replicas: 1 bootstrapServers: my-kafka-dev.com:9093 tls: trustedCertificates: - secretName: my-kafka-secret certificate: my_server_com.crt authentication: type: oauth tokenEndpointUri: clientId: clientSecret: key: secret secretName: my-oauth-secret scope: kafka config: group.id: my-connect-cluster-cluster offset.storage.topic: my-connect-cluster-offsets config.storage.topic: my-connect-cluster-configs status.storage.topic: my-connect-cluster-status key.converter: org.apache.kafka.connect.json.JsonConverter value.converter: org.apache.kafka.connect.json.JsonConverter key.converter.schemas.enable: true value.converter.schemas.enable: true config.storage.replication.factor: 1 offset.storage.replication.factor: 1 status.storage.replication.factor: 1 build: output: type: docker image: my-kafka-connect:latest pushSecret: plugins: - name: aws2-s3-kafka-connect artifacts: - type: tgz url: https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-aws2-s3-kafka-connector/0.10.1/camel-aws2-s3-kafka-connector-0.10.1-package.tar.gz - type : jar url : https://repo1.maven.org/maven2/software/amazon/awssdk/sts/2.17.51/sts-2.17.51.jar ``` After this I added the AWS s3 source connector with the same configs as above. I got a ``` Caused by: software.amazon.awssdk.core.exception.SdkClientException: Unable to load credentials from any of the providers in the chain AwsCredentialsProviderChain(credentialsProviders=[SystemPropertyCredentialsProvider(), EnvironmentVariableCredentialsProvider(), WebIdentityTokenCredentialsProvider(), ProfileCredentialsProvider(), ContainerCredentialsProvider(), InstanceProfileCredentialsProvider()]) : [SystemPropertyCredentialsProvider(): Unable to load credentials from system settings. Access key must be specified either via environment variable (AWS_ACCESS_KEY_ID) or system property (aws.accessKeyId)., EnvironmentVariableCredentialsProvider(): Unable to load credentials from system settings. Access key must be specified either via environment variable (AWS_ACCESS_KEY_ID) or system property (aws.accessKeyId)., WebIdentityTokenCredentialsProvider(): To use web identity tokens, the 'sts' service module must be on the class path., ProfileCredentialsProvider(): Profile file containe d no credentials for profile 'default': ProfileFile(profiles=[]), ContainerCredentialsProvider(): Cannot fetch credentials from container - neither AWS_CONTAINER_CREDENTIALS_FULL_URI or AWS_CONTAINER_CREDENTIALS_RELATIVE_URI environment variables are set., InstanceProfileCredentialsProvider(): Unable to load credentials from service endpoint.] at software.amazon.awssdk.core.exception.SdkClientException$BuilderImpl.build(SdkClientException.java:98) at software.amazon.awssdk.auth.credentials.AwsCredentialsProviderChain.resolveCredentials(AwsCredentialsProviderChain.java:112) at software.amazon.awssdk.auth.credentials.internal.LazyAwsCredentialsProvider.resolveCredentials(LazyAwsCredentialsProvider.java:45) at software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider.resolveCredentials(DefaultCredentialsProvider.java:104) at software.amazon.awssdk.awscore.client.handler.AwsClientHandlerUtils.createExecutionContext(AwsClientHandlerUtils.java:79) at software.amazon.awssdk.awscore.client.handler.AwsSyncClientHandler.createExecutionContext(AwsSyncClientHandler.java:68) at software.amazon.awssdk.core.internal.handler.BaseSyncClientHandler.lambda$execute$1(BaseSyncClientHandler.java:97) at software.amazon.awssdk.core.internal.handler.BaseSyncClientHandler.measureApiCallSuccess(BaseSyncClientHandler.java:167) at software.amazon.awssdk.core.internal.handler.BaseSyncClientHandler.execute(BaseSyncClientHandler.java:94) at software.amazon.awssdk.core.client.handler.SdkSyncClientHandler.execute(SdkSyncClientHandler.java:45) at software.amazon.awssdk.awscore.client.handler.AwsSyncClientHandler.execute(AwsSyncClientHandler.java:55) at software.amazon.awssdk.services.s3.De
[GitHub] [camel-k] astefanutti edited a comment on issue #2697: panic: runtime error: invalid memory address or nil pointer dereference when running a simple integration
astefanutti edited a comment on issue #2697: URL: https://github.com/apache/camel-k/issues/2697#issuecomment-946006376 @clabautdidier could you provide the output of `kamel dump -n camel-k-didier`, and also of `oc get is -n camel-k-didier --all -o yaml` and `oc get buildconfigs.build.openshift.io -n camel-k-didier --all -o yaml`? For some reasons, the creation of the S2I BuildConfig resource returns `nil` which leads to the operator panic. Could you also confirm your cluster is OpenShift 4.8 as you mentioned 1.8? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] astefanutti commented on issue #2697: panic: runtime error: invalid memory address or nil pointer dereference when running a simple integration
astefanutti commented on issue #2697: URL: https://github.com/apache/camel-k/issues/2697#issuecomment-946006376 @clabautdidier could you provide the output of `kamel dump -n camel-k-didier`, and also of `oc get is -n camel-k-didier --all` and `oc get buildconfigs.build.openshift.io -n camel-k-didier --all`? For some reasons, the creation of the S2I BuildConfig resource returns `nil` which leads to the operator panic. Could you also confirm your cluster is OpenShift 4.8 as you mentioned 1.8? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] zbendhiba edited a comment on issue #3189: [camel-main]atlasmap integration tests failed in native mode caused by atlasmap version bump(from 2.2.3 to 2.3.x)
zbendhiba edited a comment on issue #3189: URL: https://github.com/apache/camel-quarkus/issues/3189#issuecomment-94562 **Current status :** Not done with this one. At the first step, I looked at ClassLoader, but notthing war broken there. I had to add some conf locally to get some logs. Since atlasmap 2.3.x, there is only one of the modules that is loaded. This line of code https://github.com/atlasmap/atlasmap/blob/883cff34cdce946d3cf097a01f1f188a2cd51dcf/lib/core/src/main/java/io/atlasmap/core/DefaultAtlasContextFactory.java#L324 finds only one single module compared to previous version. (on native mode only) So since upgrade of this version of atlasmap, this camel-quarkus configuration does not work as expected : https://github.com/apache/camel-quarkus/blob/64e573611bfb67c83b0603709d104b5470949906/extensions/atlasmap/deployment/src/main/java/org/apache/camel/quarkus/component/atlasmap/deployment/AtlasmapProcessor.java#L78 It seems that it takes only the first _META-INF/services/atlas/module/atlas.module_ file. Meaning I had at first shot only the Java module loaded, then I excluded this one from the extension, then it has charged only the Json module, and so on ... I'm still investigating on what could have generated this. Putting this here, in case someone has found this bug before. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] zbendhiba commented on issue #3189: [camel-main]atlasmap integration tests failed in native mode caused by atlasmap version bump(from 2.2.3 to 2.3.x)
zbendhiba commented on issue #3189: URL: https://github.com/apache/camel-quarkus/issues/3189#issuecomment-94562 **Current status :** Not done with this one. At the first step, I looked at ClassLoader, but notthing war broken there. I had to add some conf locally to get some logs. Since atlasmap 2.3.x, there is only one of the modules that is loaded. This line of code https://github.com/atlasmap/atlasmap/blob/883cff34cdce946d3cf097a01f1f188a2cd51dcf/lib/core/src/main/java/io/atlasmap/core/DefaultAtlasContextFactory.java#L324 finds only one single module compared to previous version. (on native mode only) So since upgrade of this version of atlasmap, this camel-quarkus configuration does not work anymore : https://github.com/apache/camel-quarkus/blob/64e573611bfb67c83b0603709d104b5470949906/extensions/atlasmap/deployment/src/main/java/org/apache/camel/quarkus/component/atlasmap/deployment/AtlasmapProcessor.java#L78 Itseems that it takes only the first META-INF/services/atlas/module/atlas.module file. Meaning I had at first shot only the Java module loaded, then I exluded this one from the extension, then it has loaded just the Json module ... I'm still investigating on what could have generated this. Putting this here, in case someone has found this bug before. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] oscerd commented on issue #2697: panic: runtime error: invalid memory address or nil pointer dereference when running a simple integration
oscerd commented on issue #2697: URL: https://github.com/apache/camel-k/issues/2697#issuecomment-945963056 I personally never faced something like that error before. Can you try with the original kamelet from the catalog? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] orpiske opened a new pull request #6299: (chores) camel-ftp: replace some Thread.sleep calls with awaitility
orpiske opened a new pull request #6299: URL: https://github.com/apache/camel/pull/6299 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kamelets] nicolaferraro opened a new pull request #546: Create an MQTT sink
nicolaferraro opened a new pull request #546: URL: https://github.com/apache/camel-kamelets/pull/546 Fix #544 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] clabautdidier commented on issue #2697: panic: runtime error: invalid memory address or nil pointer dereference when running a simple integration
clabautdidier commented on issue #2697: URL: https://github.com/apache/camel-k/issues/2697#issuecomment-945947521 I realise that, I was just trying to create a custom Kamelet. But my real question is: how can I find out exactly what is going wrong? The operator log says "build success" and then it crashes. There is no error message besides something about memory, but I don't see why that small bit of code would lead to too much memory usage. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] github-actions[bot] commented on pull request #647: [Blog] VS Code Camel Language support 0.1.0 announcement
github-actions[bot] commented on pull request #647: URL: https://github.com/apache/camel-website/pull/647#issuecomment-945946802 🚀 Preview is available at https://pr-647--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. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] oscerd commented on issue #2697: panic: runtime error: invalid memory address or nil pointer dereference when running a simple integration
oscerd commented on issue #2697: URL: https://github.com/apache/camel-k/issues/2697#issuecomment-945945205 But why are you using a kamelet not in the catalog? Is there a specific reason? There are kafka-source and kafka-not-secured-source to use ootb -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] clabautdidier commented on issue #2697: panic: runtime error: invalid memory address or nil pointer dereference when running a simple integration
clabautdidier commented on issue #2697: URL: https://github.com/apache/camel-k/issues/2697#issuecomment-945941541 The crashing doesn't just happen in this case, also when I create a Knative channel and create a Groovy script that writes to that, the operator crashes 5 times and then puts the kit in error. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] clabautdidier commented on issue #2697: panic: runtime error: invalid memory address or nil pointer dereference when running a simple integration
clabautdidier commented on issue #2697: URL: https://github.com/apache/camel-k/issues/2697#issuecomment-945940045 Hi Pascuale, It says: > error: the server doesn't have a resource type "kafka-source-kamelet" This is the file I tryied to `oc apply -f ...` ``` apiVersion: camel.apache.org/v1alpha1 kind: Kamelet metadata: name: kafka-source-kamelet annotations: camel.apache.org/kamelet.support.level: "Preview" camel.apache.org/catalog.version: "main-SNAPSHOT" camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PD94bWwgdmVyc2lvbj0iMS4wIiBlbmNvZGluZz0idXRmLTgiPz4NCjwhLS0gR2VuZXJhdG9yOiBBZG9iZSBJbGx1c3RyYXRvciAxOS4wLjAsIFNWRyBFeHBvcnQgUGx1Zy1JbiAuIFNWRyBWZXJzaW9uOiA2LjAwIEJ1aWxkIDApICAtLT4NCjxzdmcgdmVyc2lvbj0iMS4xIiBpZD0iTGF5ZXJfMSIgeG1sbnM9Imh0dHA6Ly93d3cudzMub3JnLzIwMDAvc3ZnIiB4bWxuczp4bGluaz0iaHR0cDovL3d3dy53My5vcmcvMTk5OS94bGluayIgeD0iMHB4IiB5PSIwcHgiDQoJIHZpZXdCb3g9IjAgMCA1MDAgNTAwIiBzdHlsZT0iZW5hYmxlLWJhY2tncm91bmQ6bmV3IDAgMCA1MDAgNTAwOyIgeG1sOnNwYWNlPSJwcmVzZXJ2ZSI+DQo8ZyBpZD0iWE1MSURfMV8iPg0KCTxwYXRoIGlkPSJYTUxJRF85XyIgZD0iTTMxNC44LDI2OS43Yy0xNC4yLDAtMjcsNi4zLTM1LjcsMTYuMkwyNTYuOCwyNzBjMi40LTYuNSwzLjctMTMuNiwzLjctMjAuOWMwLTcuMi0xLjMtMTQuMS0zLjYtMjAuNg0KCQlsMjIuMy0xNS43YzguNyw5LjksMjEuNCwxNi4xLDM1LjYsMTYuMWMyNi4yLDAsNDcuNi0yMS4zLDQ3LjYtNDcuNnMtMjEuMy00Ny42LTQ3LjYtNDcuNnMtNDcuNiwyMS4zLTQ3LjYsNDcuNg0KCQljMCw0LjcsMC43LDkuMiwyLDEzLjVsLTIyLjMsMTUuN2MtOS4zLTExLjYtMjIuOC0xOS42LTM4LjEtMjIuMXYtMjYuOWMyMS42LTQuNSwzNy44LTIzLjcsMzcuO C00Ni42YzAtMjYuMi0yMS4zLTQ3LjYtNDcuNi00Ny42DQoJCWMtMjYuMiwwLTQ3LjYsMjEuMy00Ny42LDQ3LjZjMCwyMi42LDE1LjgsNDEuNSwzNi45LDQ2LjN2MjcuM2MtMjguOCw1LjEtNTAuOCwzMC4yLTUwLjgsNjAuNWMwLDMwLjQsMjIuMiw1NS43LDUxLjIsNjAuNXYyOC44DQoJCWMtMjEuMyw0LjctMzcuNCwyMy43LTM3LjQsNDYuNGMwLDI2LjIsMjEuMyw0Ny42LDQ3LjYsNDcuNmMyNi4yLDAsNDcuNi0yMS4zLDQ3LjYtNDcuNmMwLTIyLjctMTYtNDEuOC0zNy40LTQ2LjR2LTI4LjgNCgkJYzE1LTIuNSwyOC4yLTEwLjQsMzcuNC0yMS44bDIyLjUsMTUuOWMtMS4yLDQuMy0xLjksOC43LTEuOSwxMy40YzAsMjYuMiwyMS4zLDQ3LjYsNDcuNiw0Ny42czQ3LjYtMjEuMyw0Ny42LTQ3LjYNCgkJQzM2Mi40LDI5MSwzNDEuMSwyNjkuNywzMTQuOCwyNjkuN3ogTTMxNC44LDE1OC40YzEyLjcsMCwyMy4xLDEwLjQsMjMuMSwyMy4xYzAsMTIuNy0xMC4zLDIzLjEtMjMuMSwyMy4xcy0yMy4xLTEwLjQtMjMuMS0yMy4xDQoJCUMyOTEuOCwxNjguOCwzMDIuMSwxNTguNCwzMTQuOCwxNTguNHogTTE3NiwxMTUuMWMwLTEyLjcsMTAuMy0yMy4xLDIzLjEtMjMuMWMxMi43LDAsMjMuMSwxMC40LDIzLjEsMjMuMQ0KCQljMCwxMi43LTEwLjMsMjMuMS0yMy4xLDIzLjFDMTg2LjMsMTM4LjIsMTc2LDEyNy44LDE3NiwxMTUuMXogTTIyMi4xLDM4NC45YzAsMTIuNy0xMC4zLDIzLjEtMjMuMSwyMy4xDQoJCWMtMTIuNywwLTIzLjEtMT AuNC0yMy4xLTIzLjFjMC0xMi43LDEwLjMtMjMuMSwyMy4xLTIzLjFDMjExLjgsMzYxLjgsMjIyLjEsMzcyLjIsMjIyLjEsMzg0Ljl6IE0xOTkuMSwyODEuMw0KCQljLTE3LjcsMC0zMi4yLTE0LjQtMzIuMi0zMi4yYzAtMTcuNywxNC40LTMyLjIsMzIuMi0zMi4yYzE3LjcsMCwzMi4yLDE0LjQsMzIuMiwzMi4yQzIzMS4yLDI2Ni45LDIxNi44LDI4MS4zLDE5OS4xLDI4MS4zeg0KCQkgTTMxNC44LDM0MC4zYy0xMi43LDAtMjMuMS0xMC40LTIzLjEtMjMuMWMwLTEyLjcsMTAuMy0yMy4xLDIzLjEtMjMuMXMyMy4xLDEwLjQsMjMuMSwyMy4xQzMzNy45LDMzMCwzMjcuNSwzNDAuMywzMTQuOCwzNDAuM3oiLz4NCjwvZz4NCjwvc3ZnPg0K" camel.apache.org/provider: "Apache Software Foundation" camel.apache.org/kamelet.group: "Kafka" labels: camel.apache.org/kamelet.type: "source" spec: definition: title: "Demo Kafka Kamelet Source" description: |- Receives data from Kafka source. required: - topic - bootstrapServers type: object properties: topic: title: Topic Names description: Comma separated list of Kafka topic names type: string bootstrapServers: title: Brokers description: Comma separated list of Kafka Broker URLs type: string securityProtocol: title: Security Protocol description: Protocol used to communicate with brokers. SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported type: string default: SASL_SSL saslMechanism: title: SASL Mechanism description: The Simple Authentication and Security Layer (SASL) Mechanism used. type: string default: PLAIN user: title: Username description: Username to authenticate to Kafka type: string password: title: Password description: Password to authenticate to kafka type: string format: password x-descriptors: - urn:alm:descriptor:com.tectonic.ui:password autoCommitEnable: title: Auto Commit Enable description: If true, periodically commit to ZooKeeper the offset of messages already fetched by the consumer type: boolean default: true x-descriptors: - 'urn:alm:descriptor:com.tectonic.ui:checkbox' allowManualCommit: title: Allow Manual Commit description: Whether to allow doing manual commits type: boolean default: f
[GitHub] [camel-website] apupier opened a new pull request #647: [Blog] VS Code Camel Language support 0.1.0 announcement
apupier opened a new pull request #647: URL: https://github.com/apache/camel-website/pull/647 Signed-off-by: Aurélien Pupier -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch regen_bot updated (8baecff -> 281656e)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from 8baecff CAMEL-16861: Cleanup and update EIP docs add 281656e (chores) camel-ribbon: use dynamic ports to prevent test failures No new revisions were added by this update. Summary of changes: .../cloud/RibbonServiceCallRegistryRouteTest.java | 13 ++-- .../cloud/RibbonServiceCallRouteDslTest.java | 20 +++ .../cloud/RibbonServiceCallRouteMetadataTest.java | 12 +++ .../ribbon/cloud/RibbonServiceCallRouteTest.java | 23 ++ .../cloud/RibbonServiceCallUpdateRouteTest.java| 23 -- 5 files changed, 55 insertions(+), 36 deletions(-)
[camel] branch main updated: (chores) camel-activemq: cleaned up tests to avoid Thread.sleep calls
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new b979c10 (chores) camel-activemq: cleaned up tests to avoid
Thread.sleep calls
b979c10 is described below
commit b979c10cdcdd64be6f653550d1ddafc2deda9ad3
Author: Otavio Rodolfo Piske
AuthorDate: Mon Oct 18 15:22:33 2021 +0200
(chores) camel-activemq: cleaned up tests to avoid Thread.sleep calls
---
.../camel/component/activemq/AMQ2611Test.java | 25 ++--
...ample.java => AdvisoryConsumerExampleTest.java} | 8 ++
.../component/activemq/ObjectMessageTest.java | 33 ++
.../component/activemq/PoisonJMSPayloadTest.java | 20 +
4 files changed, 67 insertions(+), 19 deletions(-)
diff --git
a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AMQ2611Test.java
b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AMQ2611Test.java
index 9d30a40..c791826 100644
---
a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AMQ2611Test.java
+++
b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AMQ2611Test.java
@@ -16,12 +16,16 @@
*/
package org.apache.camel.component.activemq;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+
import org.apache.camel.Body;
import org.apache.camel.CamelContext;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.activemq.support.ActiveMQSupport;
import org.apache.camel.impl.DefaultCamelContext;
+import org.apache.camel.support.LifecycleStrategySupport;
import org.apache.camel.test.infra.activemq.services.ActiveMQEmbeddedService;
import
org.apache.camel.test.infra.activemq.services.ActiveMQEmbeddedServiceBuilder;
import org.junit.jupiter.api.Test;
@@ -42,6 +46,8 @@ public class AMQ2611Test implements ActiveMQSupport {
.build();
private CamelContext camelContext;
+private CountDownLatch startedLatch = new CountDownLatch(1);
+private CountDownLatch stoppedLatch = new CountDownLatch(1);
public static class Consumer {
public void consume(@Body String message) {
@@ -60,6 +66,21 @@ public class AMQ2611Test implements ActiveMQSupport {
from(queueEndpointName).bean(Consumer.class, "consume");
}
});
+
+camelContext.addLifecycleStrategy(new LifecycleStrategySupport() {
+@Override
+public void onContextStarted(CamelContext context) {
+super.onContextStarted(context);
+startedLatch.countDown();
+}
+
+@Override
+public void onContextStopped(CamelContext context) {
+super.onContextStopped(context);
+stoppedLatch.countDown();
+}
+});
+
camelContext.start();
final ProducerTemplate producerTemplate =
camelContext.createProducerTemplate();
producerTemplate.sendBody(queueEndpointName, "message");
@@ -77,9 +98,9 @@ public class AMQ2611Test implements ActiveMQSupport {
int i = 0;
while (i++ < 5) {
createCamelContext();
-Thread.sleep(1000);
+startedLatch.await(1, TimeUnit.SECONDS);
destroyCamelContext();
-Thread.sleep(1000);
+stoppedLatch.await(1, TimeUnit.SECONDS);
assertEquals(0, service.getConnectionCount());
}
} catch (Exception e) {
diff --git
a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AdvisoryConsumerExample.java
b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AdvisoryConsumerExampleTest.java
similarity index 96%
rename from
components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AdvisoryConsumerExample.java
rename to
components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AdvisoryConsumerExampleTest.java
index 99aa6b5..311cc42 100644
---
a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AdvisoryConsumerExample.java
+++
b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AdvisoryConsumerExampleTest.java
@@ -35,16 +35,14 @@ import static
org.junit.jupiter.api.Assertions.assertDoesNotThrow;
/**
*
*/
-public class AdvisoryConsumerExample extends ActiveMQTestSupport {
-private static final Logger LOG =
LoggerFactory.getLogger(AdvisoryConsumerExample.class);
+public class AdvisoryConsumerExampleTest extends ActiveMQTestSupport {
+private static final Logger LOG =
LoggerFactory.getLogger(AdvisoryConsumerExampleTest.class);
-@Test()
+@Test
public void testWorks() throw
[GitHub] [camel] orpiske merged pull request #6297: (chores) camel-activemq: cleaned up tests to avoid Thread.sleep calls
orpiske merged pull request #6297: URL: https://github.com/apache/camel/pull/6297 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] orpiske commented on a change in pull request #6292: CAMEL-17096: Add async commit support in camel-kafka component
orpiske commented on a change in pull request #6292:
URL: https://github.com/apache/camel/pull/6292#discussion_r730930389
##
File path:
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/DefaultKafkaManualCommit.java
##
@@ -70,6 +83,26 @@ protected void commitOffset(StateRepository
offsetRepository, To
}
}
+protected void commitAsyncOffset(
+StateRepository offsetRepository, TopicPartition
partition, long recordOffset) {
+if (recordOffset != -1) {
Review comment:
You could probably use `KafkaRecordProcessor.START_OFFSET` here instead
of -1.
Obs.: I know we are using -1 on other parts of this code, but it's on my
cleanup TODO to fix it.
##
File path:
components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java
##
@@ -0,0 +1,142 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.kafka.integration;
+
+import java.util.Collections;
+import java.util.Properties;
+
+import org.apache.camel.Endpoint;
+import org.apache.camel.EndpointInject;
+import org.apache.camel.Exchange;
+import org.apache.camel.builder.AggregationStrategies;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.kafka.KafkaConstants;
+import org.apache.camel.component.kafka.KafkaManualCommit;
+import org.apache.camel.component.mock.MockEndpoint;
+import org.apache.kafka.clients.producer.ProducerRecord;
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.RepeatedTest;
+
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+
+public class KafkaConsumerAsyncManualCommitIT extends
BaseEmbeddedKafkaTestSupport {
+
+public static final String TOPIC = "testManualCommitTest";
+
+@EndpointInject("kafka:" + TOPIC
++
"?groupId=group1&sessionTimeoutMs=3&autoCommitEnable=false"
++ "&allowManualCommit=true&autoOffsetReset=earliest")
+private Endpoint from;
+
+@EndpointInject("mock:result")
+private MockEndpoint to;
+
+@EndpointInject("mock:resultBar")
+private MockEndpoint toBar;
+
+private org.apache.kafka.clients.producer.KafkaProducer
producer;
+
+@BeforeEach
+public void before() {
+Properties props = getDefaultProperties();
+producer = new
org.apache.kafka.clients.producer.KafkaProducer<>(props);
+}
+
+@AfterEach
+public void after() {
+if (producer != null) {
+producer.close();
+}
+// clean all test topics
+kafkaAdminClient.deleteTopics(Collections.singletonList(TOPIC));
+}
+
+@Override
+protected RouteBuilder createRouteBuilder() throws Exception {
+return new RouteBuilder() {
+
+@Override
+public void configure() throws Exception {
+from(from).routeId("foo").to("direct:aggregate");
+// With sync manual commit, this would throw a concurrent
modification exception
+// It can be usesd in aggregator with completion
timeout/interval for instance
+// WARN: records from one partition must be processed by one
unique thread
+from("direct:aggregate").routeId("aggregate").to(to)
+.aggregate()
+.constant(true)
+.completionTimeout(1)
+
.aggregationStrategy(AggregationStrategies.groupedExchange())
+.split().body()
+.process(e -> {
+KafkaManualCommit manual =
e.getMessage().getBody(Exchange.class)
+
.getMessage().getHeader(KafkaConstants.MANUAL_COMMIT, KafkaManualCommit.class);
+assertNotNull(manual);
+if
(e.getMessage().getBody(String.class).equals("message-0")) {
+// Delay the commit of the first message
+Thread.sleep(2000);
Review comment:
I think it would be better to avoid the `Threa
[camel] 01/03: CAMEL-17101: Split EIP should support splitting a java.util.Map into a Set - so it works out of the box, and what you would assume Camel can do.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit cf2410bf8a5fa898ef9dfb8e4c58c6498da72403
Author: Claus Ibsen
AuthorDate: Mon Oct 18 15:21:42 2021 +0200
CAMEL-17101: Split EIP should support splitting a java.util.Map into a
Set - so it works out of the box, and what you would assume Camel
can do.
---
.../apache/camel/processor/SplitterMapTest.java| 59 ++
.../org/apache/camel/support/ObjectHelper.java | 4 ++
2 files changed, 63 insertions(+)
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/SplitterMapTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/SplitterMapTest.java
new file mode 100644
index 000..d6fe903
--- /dev/null
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/SplitterMapTest.java
@@ -0,0 +1,59 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.processor;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+import org.apache.camel.ContextTestSupport;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.mock.MockEndpoint;
+import org.junit.jupiter.api.Test;
+
+public class SplitterMapTest extends ContextTestSupport {
+
+@Test
+public void testSplitMap() throws Exception {
+MockEndpoint mock = getMockEndpoint("mock:line");
+mock.message(0).body().isEqualTo("Hello World");
+mock.message(0).header("myKey").isEqualTo("123");
+mock.message(1).body().isEqualTo("Bye World");
+mock.message(1).header("myKey").isEqualTo("789");
+
+Map map = new LinkedHashMap<>();
+map.put("123", "Hello World");
+map.put("789", "Bye World");
+
+template.sendBody("direct:start", map);
+
+assertMockEndpointsSatisfied();
+}
+
+@Override
+protected RouteBuilder createRouteBuilder() throws Exception {
+return new RouteBuilder() {
+@Override
+public void configure() throws Exception {
+from("direct:start")
+.split(body())
+.setHeader("myKey").simple("${body.key}")
+.setBody(simple("${body.value}"))
+.to("mock:line");
+}
+};
+}
+}
diff --git
a/core/camel-support/src/main/java/org/apache/camel/support/ObjectHelper.java
b/core/camel-support/src/main/java/org/apache/camel/support/ObjectHelper.java
index c4f982b..11dc820 100644
---
a/core/camel-support/src/main/java/org/apache/camel/support/ObjectHelper.java
+++
b/core/camel-support/src/main/java/org/apache/camel/support/ObjectHelper.java
@@ -24,6 +24,7 @@ import java.util.Collection;
import java.util.Collections;
import java.util.Iterator;
import java.util.Locale;
+import java.util.Map;
import java.util.NoSuchElementException;
import java.util.concurrent.Callable;
import java.util.regex.Pattern;
@@ -694,6 +695,9 @@ public final class ObjectHelper {
};
} else if (value instanceof Iterable) {
return (Iterable) value;
+} else if (value instanceof Map) {
+Map map = (Map) value;
+return map.entrySet();
} else if (value.getClass().isArray()) {
if
(org.apache.camel.util.ObjectHelper.isPrimitiveArrayType(value.getClass())) {
final Object array = value;
[camel] 03/03: CAMEL-17101: Split EIP should support splitting a java.util.Map into a Set - so it works out of the box, and what you would assume Camel can do.
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git commit 20c6cd1a7ed6bd353cf51a2842187aa6d388e1c3 Author: Claus Ibsen AuthorDate: Mon Oct 18 15:37:16 2021 +0200 CAMEL-17101: Split EIP should support splitting a java.util.Map into a Set - so it works out of the box, and what you would assume Camel can do. --- docs/user-manual/modules/ROOT/pages/camel-3x-upgrade-guide-3_13.adoc | 5 + 1 file changed, 5 insertions(+) diff --git a/docs/user-manual/modules/ROOT/pages/camel-3x-upgrade-guide-3_13.adoc b/docs/user-manual/modules/ROOT/pages/camel-3x-upgrade-guide-3_13.adoc index 8908124..27d224a 100644 --- a/docs/user-manual/modules/ROOT/pages/camel-3x-upgrade-guide-3_13.adoc +++ b/docs/user-manual/modules/ROOT/pages/camel-3x-upgrade-guide-3_13.adoc @@ -12,6 +12,11 @@ Added method `getStartedEventNotifiers` to `org.apache.camel.spi.ManagementStrat Added method `scheduleQueue` to `org.apache.camel.spi.ReactiveExecutor`. +=== Split EIP + +The Split EIP now supports splitting message bodies that are of type `java.util.Map`, which +now splits that into a `Set` - eg a set of each map entry as key/value pairs. + === SimpleBuilder The `org.apache.camel.builder.SimpleBuilder` has been deprecated. This builder
[camel] branch main updated (281656e -> 20c6cd1)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git.
from 281656e (chores) camel-ribbon: use dynamic ports to prevent test
failures
new cf2410b CAMEL-17101: Split EIP should support splitting a
java.util.Map into a Set - so it works out of the box, and what you
would assume Camel can do.
new 2fc2127 Polished
new 20c6cd1 CAMEL-17101: Split EIP should support splitting a
java.util.Map into a Set - so it works out of the box, and what you
would assume Camel can do.
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:
...erRegexpGroupTest.java => SplitterMapTest.java} | 27 +++---
.../org/apache/camel/support/ObjectHelper.java | 11 -
.../ROOT/pages/camel-3x-upgrade-guide-3_13.adoc| 5
3 files changed, 29 insertions(+), 14 deletions(-)
copy
core/camel-core/src/test/java/org/apache/camel/processor/{SplitTokenizerRegexpGroupTest.java
=> SplitterMapTest.java} (62%)
[camel] 02/03: Polished
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 2fc21275d62dd88972ad3d4bad9725a0ca49dd9f
Author: Claus Ibsen
AuthorDate: Mon Oct 18 15:35:22 2021 +0200
Polished
---
.../src/main/java/org/apache/camel/support/ObjectHelper.java | 7 +--
1 file changed, 1 insertion(+), 6 deletions(-)
diff --git
a/core/camel-support/src/main/java/org/apache/camel/support/ObjectHelper.java
b/core/camel-support/src/main/java/org/apache/camel/support/ObjectHelper.java
index 11dc820..3d21f38 100644
---
a/core/camel-support/src/main/java/org/apache/camel/support/ObjectHelper.java
+++
b/core/camel-support/src/main/java/org/apache/camel/support/ObjectHelper.java
@@ -687,12 +687,7 @@ public final class ObjectHelper {
return Collections.emptyList();
} else if (value instanceof Iterator) {
final Iterator iterator = (Iterator) value;
-return new Iterable() {
-@Override
-public Iterator iterator() {
-return iterator;
-}
-};
+return (Iterable) () -> iterator;
} else if (value instanceof Iterable) {
return (Iterable) value;
} else if (value instanceof Map) {
[camel] branch regen_bot updated (8f82205 -> 8baecff)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from 8f82205 Restore RemoteProducerIT test add ba3f24e CAMEL-16861: Cleanup and update EIP docs add 8baecff CAMEL-16861: Cleanup and update EIP docs No new revisions were added by this update. Summary of changes: .../docs/modules/eips/pages/setHeader-eip.adoc | 83 -- .../docs/modules/eips/pages/setOutHeader-eip.adoc | 48 - 2 files changed, 63 insertions(+), 68 deletions(-) delete mode 100644 core/camel-core-engine/src/main/docs/modules/eips/pages/setOutHeader-eip.adoc
[GitHub] [camel] davsclaus commented on a change in pull request #6292: CAMEL-17096: Add async commit support in camel-kafka component
davsclaus commented on a change in pull request #6292:
URL: https://github.com/apache/camel/pull/6292#discussion_r730922524
##
File path:
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/DefaultKafkaManualCommit.java
##
@@ -70,6 +83,26 @@ protected void commitOffset(StateRepository
offsetRepository, To
}
}
+protected void commitAsyncOffset(
+StateRepository offsetRepository, TopicPartition
partition, long recordOffset) {
+if (recordOffset != -1) {
+if (offsetRepository != null) {
+offsetRepository.setState(serializeOffsetKey(partition),
serializeOffsetValue(recordOffset));
+} else {
+LOG.debug("CommitAsync {} from topic {} with offset: {}",
threadId, topicName, recordOffset);
+consumer.commitAsync(Collections.singletonMap(partition, new
OffsetAndMetadata(recordOffset + 1)),
+(offsets, exception) -> {
+if (exception != null) {
+LOG.error("Error during async commit: ",
exception);
+} else {
+LOG.info("CommitAsync done for {} from topic
{} with offset: {}", threadId, topicName,
Review comment:
Reduce logging noise as INFO is too verbose, use DEBUG or TRACE
##
File path:
components/camel-kafka/src/main/java/org/apache/camel/component/kafka/DefaultKafkaManualCommit.java
##
@@ -70,6 +83,26 @@ protected void commitOffset(StateRepository
offsetRepository, To
}
}
+protected void commitAsyncOffset(
+StateRepository offsetRepository, TopicPartition
partition, long recordOffset) {
+if (recordOffset != -1) {
+if (offsetRepository != null) {
+offsetRepository.setState(serializeOffsetKey(partition),
serializeOffsetValue(recordOffset));
+} else {
+LOG.debug("CommitAsync {} from topic {} with offset: {}",
threadId, topicName, recordOffset);
+consumer.commitAsync(Collections.singletonMap(partition, new
OffsetAndMetadata(recordOffset + 1)),
+(offsets, exception) -> {
+if (exception != null) {
+LOG.error("Error during async commit: ",
exception);
Review comment:
You can maybe add more details to this error message about topic, offset
etc
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
[camel] branch regen_bot updated (972fa46 -> 8f82205)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch regen_bot
in repository https://gitbox.apache.org/repos/asf/camel.git.
omit 972fa46 Regen for commit f4dd63e9182d29c794d5248c6ecda6f9ab1be74b
add 8f82205 Restore RemoteProducerIT test
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (972fa46)
\
N -- N -- N refs/heads/regen_bot (8f82205)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../remote/InfinispanRemoteProducerIT.java}| 31 +-
.../sql/stored/template/generated/SSPTParser.java | 833 ++---
.../template/generated/SSPTParserConstants.java| 110 +-
.../template/generated/SSPTParserTokenManager.java | 1222 ++--
.../services/InfinispanLocalContainerService.java |3 +
.../src/test/resources/infinispan.xml | 72 ++
6 files changed, 1181 insertions(+), 1090 deletions(-)
copy
components/camel-infinispan/{camel-infinispan-embedded/src/test/java/org/apache/camel/component/infinispan/embedded/InfinispanEmbeddedProducerTest.java
=>
camel-infinispan/src/test/java/org/apache/camel/component/infinispan/remote/InfinispanRemoteProducerIT.java}
(79%)
create mode 100644
test-infra/camel-test-infra-infinispan/src/test/resources/infinispan.xml
[GitHub] [camel] oscerd commented on pull request #6292: CAMEL-17096: Add async commit support in camel-kafka component
oscerd commented on pull request #6292: URL: https://github.com/apache/camel/pull/6292#issuecomment-945768737 Makes sense, I think it would be cleaner. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] orpiske commented on pull request #6292: CAMEL-17096: Add async commit support in camel-kafka component
orpiske commented on pull request #6292: URL: https://github.com/apache/camel/pull/6292#issuecomment-945767772 I'm wondering whether it wouldn't better - from a maintenance perspective - to have the async commit in a separated class. We would need to adjust the KafkaManualCommit to rename the `commitSync` to `commit` but I think it could lead to a solution that is easier to maintain (*IMHO*). What do you think @davsclaus, @oscerd and others? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] djencks commented on issue #3191: Publish docs for the last stable release
djencks commented on issue #3191: URL: https://github.com/apache/camel-quarkus/issues/3191#issuecomment-945766712 I'll be pushing some changes to the website and most contributing projects in the next day or two and can easily include this. I wouldn't expect it to cause me a problem if you'd rather do this first. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] oscerd closed pull request #6298: Generated sources regen
oscerd closed pull request #6298: URL: https://github.com/apache/camel/pull/6298 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch regen_bot updated (ece95cc -> 972fa46)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from ece95cc Regen for commit 77db8477b20baeb949f83f877082e06a944c24bc add f4dd63e CAMEL-16861: Cleanup and update EIP docs add 972fa46 Regen for commit f4dd63e9182d29c794d5248c6ecda6f9ab1be74b No new revisions were added by this update. Summary of changes: .../sql/stored/template/generated/SSPTParser.java | 833 +++-- .../template/generated/SSPTParserConstants.java| 110 +- .../template/generated/SSPTParserTokenManager.java | 1222 ++-- .../docs/modules/eips/pages/service-activator.adoc | 22 +- .../docs/modules/eips/pages/serviceCall-eip.adoc | 189 ++- 5 files changed, 1173 insertions(+), 1203 deletions(-)
[GitHub] [camel] github-actions[bot] opened a new pull request #6298: Generated sources regen
github-actions[bot] opened a new pull request #6298: URL: https://github.com/apache/camel/pull/6298 Regen bot :robot: found some uncommited changes after running build on :camel: main. Please do not delete `regen_bot` branch after merge/rebase. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] orpiske merged pull request #6296: (chores) camel-ribbon: use dynamic ports to prevent test failures
orpiske merged pull request #6296: URL: https://github.com/apache/camel/pull/6296 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch main updated: (chores) camel-ribbon: use dynamic ports to prevent test failures
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 281656e (chores) camel-ribbon: use dynamic ports to prevent test
failures
281656e is described below
commit 281656e0ce33789ddbf9cc5cd362cac0e1b82b9f
Author: Otavio Rodolfo Piske
AuthorDate: Mon Oct 18 13:34:13 2021 +0200
(chores) camel-ribbon: use dynamic ports to prevent test failures
---
.../cloud/RibbonServiceCallRegistryRouteTest.java | 13 ++--
.../cloud/RibbonServiceCallRouteDslTest.java | 20 +++
.../cloud/RibbonServiceCallRouteMetadataTest.java | 12 +++
.../ribbon/cloud/RibbonServiceCallRouteTest.java | 23 ++
.../cloud/RibbonServiceCallUpdateRouteTest.java| 23 --
5 files changed, 55 insertions(+), 36 deletions(-)
diff --git
a/components/camel-ribbon/src/test/java/org/apache/camel/component/ribbon/cloud/RibbonServiceCallRegistryRouteTest.java
b/components/camel-ribbon/src/test/java/org/apache/camel/component/ribbon/cloud/RibbonServiceCallRegistryRouteTest.java
index 2c8c65b..e96a3e8 100644
---
a/components/camel-ribbon/src/test/java/org/apache/camel/component/ribbon/cloud/RibbonServiceCallRegistryRouteTest.java
+++
b/components/camel-ribbon/src/test/java/org/apache/camel/component/ribbon/cloud/RibbonServiceCallRegistryRouteTest.java
@@ -23,6 +23,7 @@ import org.apache.camel.impl.cloud.StaticServiceDiscovery;
import org.apache.camel.model.cloud.ServiceCallConfigurationDefinition;
public class RibbonServiceCallRegistryRouteTest extends
RibbonServiceCallRouteTest {
+
@Override
protected RoutesBuilder createRouteBuilder() throws Exception {
return new RouteBuilder() {
@@ -30,8 +31,8 @@ public class RibbonServiceCallRegistryRouteTest extends
RibbonServiceCallRouteTe
public void configure() throws Exception {
// setup a static ribbon server list with these 2 servers to
start with
StaticServiceDiscovery servers = new StaticServiceDiscovery();
-servers.addServer("myService@localhost:9090");
-servers.addServer("myService@localhost:9091");
+servers.addServer("myService@localhost:" + PORT1);
+servers.addServer("myService@localhost:" + PORT2);
RibbonConfiguration configuration = new RibbonConfiguration();
RibbonServiceLoadBalancer loadBalancer = new
RibbonServiceLoadBalancer(configuration);
@@ -50,11 +51,11 @@ public class RibbonServiceCallRegistryRouteTest extends
RibbonServiceCallRouteTe
.component("http")
.end()
.to("mock:result");
-from("jetty:http://localhost:9090";)
-.to("mock:9090")
+fromF("jetty:http://localhost:%d";, PORT1)
+.to("mock:" + ROUTE_1_ID)
.transform().constant("9090");
-from("jetty:http://localhost:9091";)
-.to("mock:9091")
+fromF("jetty:http://localhost:%d";, PORT2)
+.to("mock:" + ROUTE_2_ID)
.transform().constant("9091");
}
};
diff --git
a/components/camel-ribbon/src/test/java/org/apache/camel/component/ribbon/cloud/RibbonServiceCallRouteDslTest.java
b/components/camel-ribbon/src/test/java/org/apache/camel/component/ribbon/cloud/RibbonServiceCallRouteDslTest.java
index 3acd72a..6fe78d9 100644
---
a/components/camel-ribbon/src/test/java/org/apache/camel/component/ribbon/cloud/RibbonServiceCallRouteDslTest.java
+++
b/components/camel-ribbon/src/test/java/org/apache/camel/component/ribbon/cloud/RibbonServiceCallRouteDslTest.java
@@ -18,16 +18,20 @@ package org.apache.camel.component.ribbon.cloud;
import org.apache.camel.RoutesBuilder;
import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.test.AvailablePortFinder;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.assertEquals;
public class RibbonServiceCallRouteDslTest extends CamelTestSupport {
+private static final int PORT1 = AvailablePortFinder.getNextAvailable();
+private static final int PORT2 = AvailablePortFinder.getNextAvailable();
+
@Test
public void testServiceCall() throws Exception {
-getMockEndpoint("mock:9090").expectedMessageCount(1);
-getMockEndpoint("mock:9091").expectedMessageCount(1);
+getMockEndpoint("mock:" + PORT1).expectedMessageCount(1);
+getMockEndpoint("mock:" + PORT2).expectedMessageCount(1);
getMockEndpoint("mock:result").expectedMessageCount(2);
String out = template.requestBody("direct:start", null, String.c
[GitHub] [camel] orpiske opened a new pull request #6297: (chores) camel-activemq: cleaned up tests to avoid Thread.sleep calls
orpiske opened a new pull request #6297: URL: https://github.com/apache/camel/pull/6297 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-performance-tests] oscerd merged pull request #45: Minio Kafka: Set Localhost as ip for the minio instance
oscerd merged pull request #45: URL: https://github.com/apache/camel-performance-tests/pull/45 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-performance-tests] branch main updated: Minio Kafka: Set Localhost as ip for the minio instance
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git The following commit(s) were added to refs/heads/main by this push: new 1c379f0 Minio Kafka: Set Localhost as ip for the minio instance 1c379f0 is described below commit 1c379f0da78cd21c6d914ec9af84cc51132976c1 Author: Andrea Cosentino AuthorDate: Mon Oct 18 15:02:38 2021 +0200 Minio Kafka: Set Localhost as ip for the minio instance --- profiling/minio-kafka/data/sources/routes.yaml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/profiling/minio-kafka/data/sources/routes.yaml b/profiling/minio-kafka/data/sources/routes.yaml index fac72ed..1e2d6fe 100644 --- a/profiling/minio-kafka/data/sources/routes.yaml +++ b/profiling/minio-kafka/data/sources/routes.yaml @@ -22,7 +22,7 @@ bucketName: "ckc" accessKey: "minio" secretKey: "miniostorage" -endpoint: "http://192.168.1.19:9000"; +endpoint: "http://localhost:9000"; steps: - to: uri: "kamelet:kafka-not-secured-sink"
[camel-performance-tests] branch minio-kafka-2 created (now 8b932a6)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch minio-kafka-2 in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git. at 8b932a6 Minio Kafka: Set Localhost as ip for the minio instance This branch includes the following new commits: new 8b932a6 Minio Kafka: Set Localhost as ip for the minio instance 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-performance-tests] 01/01: Minio Kafka: Set Localhost as ip for the minio instance
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch minio-kafka-2 in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit 8b932a6e387ea47ac18cef0913a1a71f636b7bab Author: Andrea Cosentino AuthorDate: Mon Oct 18 15:02:38 2021 +0200 Minio Kafka: Set Localhost as ip for the minio instance --- profiling/minio-kafka/data/sources/routes.yaml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/profiling/minio-kafka/data/sources/routes.yaml b/profiling/minio-kafka/data/sources/routes.yaml index fac72ed..1e2d6fe 100644 --- a/profiling/minio-kafka/data/sources/routes.yaml +++ b/profiling/minio-kafka/data/sources/routes.yaml @@ -22,7 +22,7 @@ bucketName: "ckc" accessKey: "minio" secretKey: "miniostorage" -endpoint: "http://192.168.1.19:9000"; +endpoint: "http://localhost:9000"; steps: - to: uri: "kamelet:kafka-not-secured-sink"
[camel] 02/02: CAMEL-16861: Cleanup and update EIP docs
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 8baecff964ce4b8430cdebfab85f729e8e8db4cb
Author: Claus Ibsen
AuthorDate: Mon Oct 18 14:45:22 2021 +0200
CAMEL-16861: Cleanup and update EIP docs
---
.../docs/modules/eips/pages/setOutHeader-eip.adoc | 48 --
1 file changed, 48 deletions(-)
diff --git
a/core/camel-core-engine/src/main/docs/modules/eips/pages/setOutHeader-eip.adoc
b/core/camel-core-engine/src/main/docs/modules/eips/pages/setOutHeader-eip.adoc
deleted file mode 100644
index c9200b9..000
---
a/core/camel-core-engine/src/main/docs/modules/eips/pages/setOutHeader-eip.adoc
+++ /dev/null
@@ -1,48 +0,0 @@
-= Set Out Header EIP (deprecated)
-== Set Header EIP
-
-This EIP is deprecated.
-The SetOutHeader EIP allows you to set an header on the out message of your
exchange.
-
-== Options
-
-// eip options: START
-The Set Out Header EIP supports 1 options which are listed below:
-
-[width="100%",cols="2,5,^1,2",options="header"]
-|===
-| Name | Description | Default | Type
-| *headerName* | *Required* Name of message header to set a new value | |
String
-|===
-// eip options: END
-
-== Examples
-
-The following example shows how to use the SetOutHeader EIP
-
-[source,java]
-
-RouteBuilder builder = new RouteBuilder() {
-public void configure() {
-from("direct:a")
-.setOutHeader("myHeader", constant("test"))
-.to("direct:b");
-}
-};
-
-
-
-And the same example using XML:
-
-[source,xml]
-
-http://camel.apache.org/schema/spring";>
-
-
-
-test
-
-
-
-
-
\ No newline at end of file
[camel] 01/02: CAMEL-16861: Cleanup and update EIP docs
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit ba3f24e8eddc872e053b1a432979d69b23e2db8d
Author: Claus Ibsen
AuthorDate: Mon Oct 18 14:45:12 2021 +0200
CAMEL-16861: Cleanup and update EIP docs
---
.../docs/modules/eips/pages/setHeader-eip.adoc | 83 --
1 file changed, 63 insertions(+), 20 deletions(-)
diff --git
a/core/camel-core-engine/src/main/docs/modules/eips/pages/setHeader-eip.adoc
b/core/camel-core-engine/src/main/docs/modules/eips/pages/setHeader-eip.adoc
index 94aaa4f..671a6e6 100644
--- a/core/camel-core-engine/src/main/docs/modules/eips/pages/setHeader-eip.adoc
+++ b/core/camel-core-engine/src/main/docs/modules/eips/pages/setHeader-eip.adoc
@@ -5,7 +5,7 @@
:since:
:supportlevel: Stable
-The SetHeader EIP allows you to set and header on your exchange.
+The SetHeader EIP is used for setting a xref:message.adoc[message] header.
== Options
@@ -13,33 +13,76 @@ The SetHeader EIP allows you to set and header on your
exchange.
include::partial$eip-options.adoc[]
// eip options: END
-== Examples
+== Using Set Header
-The following example shows how to use the SetHeader EIP
+The following example shows how to set a header in a Camel route:
[source,java]
-RouteBuilder builder = new RouteBuilder() {
-public void configure() {
-from("direct:a")
-.setHeader("myHeader", constant("test"))
-.to("direct:b");
-}
-};
+from("direct:a")
+.setHeader("myHeader", constant("test"))
+.to("direct:b");
-
And the same example using XML:
[source,xml]
-http://camel.apache.org/schema/spring";>
-
-
-
-test
-
-
-
-
+
+
+
+test
+
+
+
+
+
+In the example the header value is a
xref:components:languages:constant-language.adoc[constant].
+
+Any of the Camel languages can be used, such as
xref:components:languages:simple-language.adoc[Simple].
+
+[source,java]
+
+from("direct:a")
+.setHeader("randomNumber", simple("${random(1,100)}"))
+.to("direct:b");
+
+
+And in XML:
+
+[source,xml]
+
+
+
+
+${random(1,100)}
+
+
+
+
+
+=== Setting a header from another header
+
+You can also set a header with the value from another header.
+
+In the example we set the header foo with the value from an existing header
named bar.
+
+[source,java]
+
+from("direct:a")
+.setHeader("foo", header("bar"))
+.to("direct:b");
+
+
+And in XML:
+
+[source,xml]
+
+
+
+
+bar
+
+
+
[camel] branch main updated (8f82205 -> 8baecff)
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel.git. from 8f82205 Restore RemoteProducerIT test new ba3f24e CAMEL-16861: Cleanup and update EIP docs new 8baecff CAMEL-16861: Cleanup and update EIP docs 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: .../docs/modules/eips/pages/setHeader-eip.adoc | 83 -- .../docs/modules/eips/pages/setOutHeader-eip.adoc | 48 - 2 files changed, 63 insertions(+), 68 deletions(-) delete mode 100644 core/camel-core-engine/src/main/docs/modules/eips/pages/setOutHeader-eip.adoc
[camel-performance-tests] 02/02: Minio to Kafka added to POM
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit 4ddc289a5010e96995787a9c44c4ab0659e15a46 Author: Andrea Cosentino AuthorDate: Mon Oct 18 14:39:43 2021 +0200 Minio to Kafka added to POM --- profiling/pom.xml | 1 + 1 file changed, 1 insertion(+) diff --git a/profiling/pom.xml b/profiling/pom.xml index af8ac34..75f1418 100644 --- a/profiling/pom.xml +++ b/profiling/pom.xml @@ -46,6 +46,7 @@ kafka-nats-exchange-pooling kafka-postgresql kafka-postgresql-exchange-pooling +minio-kafka mongo-kafka mongo-kafka-exchange-pooling postgresql-kafka
[camel-performance-tests] 01/02: Added a Minio to Kafka profiling example
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git
commit 68137e445c30c152c2117c45a9f55123580406b6
Author: Andrea Cosentino
AuthorDate: Mon Oct 18 14:39:18 2021 +0200
Added a Minio to Kafka profiling example
---
.../.mvn/wrapper/MavenWrapperDownloader.java | 117 +++
.../minio-kafka/.mvn/wrapper/maven-wrapper.jar | Bin 0 -> 50710 bytes
.../.mvn/wrapper/maven-wrapper.properties | 2 +
profiling/minio-kafka/README.md| 153
profiling/minio-kafka/data/application.properties | 30 +
profiling/minio-kafka/data/sources/routes.yaml | 32 +
profiling/minio-kafka/jfr/settings_for_heap.jfc| 965 +
profiling/minio-kafka/mvnw | 310 +++
profiling/minio-kafka/mvnw.cmd | 182
profiling/minio-kafka/pom.xml | 167
profiling/minio-kafka/script/minio-bulk.sh | 39 +
profiling/minio-kafka/script/msg1.txt | 1 +
12 files changed, 1998 insertions(+)
diff --git a/profiling/minio-kafka/.mvn/wrapper/MavenWrapperDownloader.java
b/profiling/minio-kafka/.mvn/wrapper/MavenWrapperDownloader.java
new file mode 100644
index 000..b901097
--- /dev/null
+++ b/profiling/minio-kafka/.mvn/wrapper/MavenWrapperDownloader.java
@@ -0,0 +1,117 @@
+/*
+ * Copyright 2007-present the original author or authors.
+ *
+ * Licensed 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.
+ */
+import java.net.*;
+import java.io.*;
+import java.nio.channels.*;
+import java.util.Properties;
+
+public class MavenWrapperDownloader {
+
+private static final String WRAPPER_VERSION = "0.5.6";
+/**
+ * Default URL to download the maven-wrapper.jar from, if no 'downloadUrl'
is provided.
+ */
+private static final String DEFAULT_DOWNLOAD_URL =
"https://repo.maven.apache.org/maven2/io/takari/maven-wrapper/";
++ WRAPPER_VERSION + "/maven-wrapper-" + WRAPPER_VERSION + ".jar";
+
+/**
+ * Path to the maven-wrapper.properties file, which might contain a
downloadUrl property to
+ * use instead of the default one.
+ */
+private static final String MAVEN_WRAPPER_PROPERTIES_PATH =
+".mvn/wrapper/maven-wrapper.properties";
+
+/**
+ * Path where the maven-wrapper.jar will be saved to.
+ */
+private static final String MAVEN_WRAPPER_JAR_PATH =
+".mvn/wrapper/maven-wrapper.jar";
+
+/**
+ * Name of the property which should be used to override the default
download url for the wrapper.
+ */
+private static final String PROPERTY_NAME_WRAPPER_URL = "wrapperUrl";
+
+public static void main(String args[]) {
+System.out.println("- Downloader started");
+File baseDirectory = new File(args[0]);
+System.out.println("- Using base directory: " +
baseDirectory.getAbsolutePath());
+
+// If the maven-wrapper.properties exists, read it and check if it
contains a custom
+// wrapperUrl parameter.
+File mavenWrapperPropertyFile = new File(baseDirectory,
MAVEN_WRAPPER_PROPERTIES_PATH);
+String url = DEFAULT_DOWNLOAD_URL;
+if(mavenWrapperPropertyFile.exists()) {
+FileInputStream mavenWrapperPropertyFileInputStream = null;
+try {
+mavenWrapperPropertyFileInputStream = new
FileInputStream(mavenWrapperPropertyFile);
+Properties mavenWrapperProperties = new Properties();
+
mavenWrapperProperties.load(mavenWrapperPropertyFileInputStream);
+url =
mavenWrapperProperties.getProperty(PROPERTY_NAME_WRAPPER_URL, url);
+} catch (IOException e) {
+System.out.println("- ERROR loading '" +
MAVEN_WRAPPER_PROPERTIES_PATH + "'");
+} finally {
+try {
+if(mavenWrapperPropertyFileInputStream != null) {
+mavenWrapperPropertyFileInputStream.close();
+}
+} catch (IOException e) {
+// Ignore ...
+}
+}
+}
+System.out.println("- Downloading from: " + url);
+
+File outputFile = new File(baseDirectory.getAbsolutePath(),
MAVEN_WRAPPER_JAR_PATH);
+if(!outputFile.getParentFile().exists()) {
+if(!outputFile.getParentFile().mkdir
[camel-performance-tests] branch main updated (90dfe98 -> 4ddc289)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git.
from 90dfe98 Postgresql Kafka renamed in POM
new 68137e4 Added a Minio to Kafka profiling example
new 4ddc289 Minio to Kafka added to POM
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:
.../.mvn/wrapper/MavenWrapperDownloader.java | 0
.../.mvn/wrapper/maven-wrapper.jar | Bin
.../.mvn/wrapper/maven-wrapper.properties | 0
profiling/{kafka-minio => minio-kafka}/README.md | 57 ++---
.../data/application.properties| 0
.../data/sources/routes.yaml | 13 +++--
.../jfr/settings_for_heap.jfc | 0
profiling/{postgresql-kafka => minio-kafka}/mvnw | 0
.../{postgresql-kafka => minio-kafka}/mvnw.cmd | 0
profiling/{kafka-mongo => minio-kafka}/pom.xml | 12 +++--
.../burst.sh => minio-kafka/script/minio-bulk.sh} | 15 ++
profiling/minio-kafka/script/msg1.txt | 1 +
profiling/pom.xml | 1 +
13 files changed, 47 insertions(+), 52 deletions(-)
copy profiling/{postgresql-kafka =>
minio-kafka}/.mvn/wrapper/MavenWrapperDownloader.java (100%)
copy profiling/{postgresql-kafka =>
minio-kafka}/.mvn/wrapper/maven-wrapper.jar (100%)
copy profiling/{postgresql-kafka =>
minio-kafka}/.mvn/wrapper/maven-wrapper.properties (100%)
copy profiling/{kafka-minio => minio-kafka}/README.md (77%)
copy profiling/{postgresql-kafka => minio-kafka}/data/application.properties
(100%)
copy profiling/{mongo-kafka => minio-kafka}/data/sources/routes.yaml (82%)
copy profiling/{postgresql-kafka => minio-kafka}/jfr/settings_for_heap.jfc
(100%)
copy profiling/{postgresql-kafka => minio-kafka}/mvnw (100%)
copy profiling/{postgresql-kafka => minio-kafka}/mvnw.cmd (100%)
copy profiling/{kafka-mongo => minio-kafka}/pom.xml (94%)
copy profiling/{kafka-mongo-exchange-pooling/script/burst.sh =>
minio-kafka/script/minio-bulk.sh} (72%)
create mode 100644 profiling/minio-kafka/script/msg1.txt
[GitHub] [camel-performance-tests] oscerd merged pull request #44: Minio kafka profiling example
oscerd merged pull request #44: URL: https://github.com/apache/camel-performance-tests/pull/44 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-performance-tests] 02/02: Minio to Kafka added to POM
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch minio-kafka in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git commit 55ff4d5488d5691fcc6c7d11c6a66108f5cb8d1e Author: Andrea Cosentino AuthorDate: Mon Oct 18 14:39:43 2021 +0200 Minio to Kafka added to POM --- profiling/pom.xml | 1 + 1 file changed, 1 insertion(+) diff --git a/profiling/pom.xml b/profiling/pom.xml index af8ac34..75f1418 100644 --- a/profiling/pom.xml +++ b/profiling/pom.xml @@ -46,6 +46,7 @@ kafka-nats-exchange-pooling kafka-postgresql kafka-postgresql-exchange-pooling +minio-kafka mongo-kafka mongo-kafka-exchange-pooling postgresql-kafka
[camel-performance-tests] 01/02: Added a Minio to Kafka profiling example
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch minio-kafka
in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git
commit 478de96fc987340d7adb7a40f81777671acc2d89
Author: Andrea Cosentino
AuthorDate: Mon Oct 18 14:39:18 2021 +0200
Added a Minio to Kafka profiling example
---
.../.mvn/wrapper/MavenWrapperDownloader.java | 117 +++
.../minio-kafka/.mvn/wrapper/maven-wrapper.jar | Bin 0 -> 50710 bytes
.../.mvn/wrapper/maven-wrapper.properties | 2 +
profiling/minio-kafka/README.md| 153
profiling/minio-kafka/data/application.properties | 30 +
profiling/minio-kafka/data/sources/routes.yaml | 32 +
profiling/minio-kafka/jfr/settings_for_heap.jfc| 965 +
profiling/minio-kafka/mvnw | 310 +++
profiling/minio-kafka/mvnw.cmd | 182
profiling/minio-kafka/pom.xml | 167
profiling/minio-kafka/script/minio-bulk.sh | 39 +
profiling/minio-kafka/script/msg1.txt | 1 +
12 files changed, 1998 insertions(+)
diff --git a/profiling/minio-kafka/.mvn/wrapper/MavenWrapperDownloader.java
b/profiling/minio-kafka/.mvn/wrapper/MavenWrapperDownloader.java
new file mode 100644
index 000..b901097
--- /dev/null
+++ b/profiling/minio-kafka/.mvn/wrapper/MavenWrapperDownloader.java
@@ -0,0 +1,117 @@
+/*
+ * Copyright 2007-present the original author or authors.
+ *
+ * Licensed 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.
+ */
+import java.net.*;
+import java.io.*;
+import java.nio.channels.*;
+import java.util.Properties;
+
+public class MavenWrapperDownloader {
+
+private static final String WRAPPER_VERSION = "0.5.6";
+/**
+ * Default URL to download the maven-wrapper.jar from, if no 'downloadUrl'
is provided.
+ */
+private static final String DEFAULT_DOWNLOAD_URL =
"https://repo.maven.apache.org/maven2/io/takari/maven-wrapper/";
++ WRAPPER_VERSION + "/maven-wrapper-" + WRAPPER_VERSION + ".jar";
+
+/**
+ * Path to the maven-wrapper.properties file, which might contain a
downloadUrl property to
+ * use instead of the default one.
+ */
+private static final String MAVEN_WRAPPER_PROPERTIES_PATH =
+".mvn/wrapper/maven-wrapper.properties";
+
+/**
+ * Path where the maven-wrapper.jar will be saved to.
+ */
+private static final String MAVEN_WRAPPER_JAR_PATH =
+".mvn/wrapper/maven-wrapper.jar";
+
+/**
+ * Name of the property which should be used to override the default
download url for the wrapper.
+ */
+private static final String PROPERTY_NAME_WRAPPER_URL = "wrapperUrl";
+
+public static void main(String args[]) {
+System.out.println("- Downloader started");
+File baseDirectory = new File(args[0]);
+System.out.println("- Using base directory: " +
baseDirectory.getAbsolutePath());
+
+// If the maven-wrapper.properties exists, read it and check if it
contains a custom
+// wrapperUrl parameter.
+File mavenWrapperPropertyFile = new File(baseDirectory,
MAVEN_WRAPPER_PROPERTIES_PATH);
+String url = DEFAULT_DOWNLOAD_URL;
+if(mavenWrapperPropertyFile.exists()) {
+FileInputStream mavenWrapperPropertyFileInputStream = null;
+try {
+mavenWrapperPropertyFileInputStream = new
FileInputStream(mavenWrapperPropertyFile);
+Properties mavenWrapperProperties = new Properties();
+
mavenWrapperProperties.load(mavenWrapperPropertyFileInputStream);
+url =
mavenWrapperProperties.getProperty(PROPERTY_NAME_WRAPPER_URL, url);
+} catch (IOException e) {
+System.out.println("- ERROR loading '" +
MAVEN_WRAPPER_PROPERTIES_PATH + "'");
+} finally {
+try {
+if(mavenWrapperPropertyFileInputStream != null) {
+mavenWrapperPropertyFileInputStream.close();
+}
+} catch (IOException e) {
+// Ignore ...
+}
+}
+}
+System.out.println("- Downloading from: " + url);
+
+File outputFile = new File(baseDirectory.getAbsolutePath(),
MAVEN_WRAPPER_JAR_PATH);
+if(!outputFile.getParentFile().exists()) {
+if(!outputFile.getParentFile(
[camel-performance-tests] branch minio-kafka created (now 55ff4d5)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch minio-kafka in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git. at 55ff4d5 Minio to Kafka added to POM This branch includes the following new commits: new 478de96 Added a Minio to Kafka profiling example new 55ff4d5 Minio to Kafka added to POM The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[camel] branch main updated: Restore RemoteProducerIT test
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 8f82205 Restore RemoteProducerIT test
8f82205 is described below
commit 8f8220538b63de1a5d22a98f6183aae8090bc8e4
Author: Federico Mariani
AuthorDate: Mon Oct 18 12:38:09 2021 +0200
Restore RemoteProducerIT test
Update Atlasmap to version 2.3.1 (#6282)
(chores) camel-cxf: fix test failure in Camel1145RouteTest due to fixed
port usage
CAMEL-17089: Upgrade gRPC to 1.41.0
CAMEL-17081: Upgrade Infinispan to 13.0.0
CAMEL-17090: Release view only on shutdown or after no routes left in
policy (#6290)
* CAMEL-17090: Release view only on shutdown and after no routes left in
policy
* CAMEL-17090: Fix formatting
CAMEL-17095: camel-resilience4j - Using timeout and bulkhead together does
not work
CAMEL-17098: Upgrade to CXF 3.4.5
Upgrade AWS SDK v2 to version 2.17.61
Sync deps
Upgrade JGit to version 5.13.0.202109080827-r
Sync deps
CAMEL-16861: Cleanup and update EIP docs
CAMEL-16861: Cleanup and update EIP docs
Regen for commit 77db8477b20baeb949f83f877082e06a944c24bc
Signed-off-by: GitHub
Restore InfinispanRemoteProducerIT test
---
.../remote/InfinispanRemoteProducerIT.java | 106 +
.../services/InfinispanLocalContainerService.java | 3 +
.../src/test/resources/infinispan.xml | 72 ++
3 files changed, 181 insertions(+)
diff --git
a/components/camel-infinispan/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/remote/InfinispanRemoteProducerIT.java
b/components/camel-infinispan/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/remote/InfinispanRemoteProducerIT.java
new file mode 100644
index 000..b318ac5
--- /dev/null
+++
b/components/camel-infinispan/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/remote/InfinispanRemoteProducerIT.java
@@ -0,0 +1,106 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.infinispan.remote;
+
+import java.util.function.BiFunction;
+
+import org.apache.camel.BindToRegistry;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.infinispan.InfinispanConstants;
+import org.apache.camel.component.infinispan.InfinispanOperation;
+import org.apache.camel.component.infinispan.InfinispanProducerTestSupport;
+import org.infinispan.client.hotrod.ServerStatistics;
+import org.infinispan.commons.api.BasicCache;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.condition.DisabledOnOs;
+import org.junit.jupiter.api.condition.OS;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
+@DisabledOnOs(OS.MAC)
+public class InfinispanRemoteProducerIT extends InfinispanRemoteTestSupport
implements InfinispanProducerTestSupport {
+
+@BindToRegistry("mappingFunction")
+public static BiFunction mappingFunction() {
+return (k, v) -> v + "replay";
+}
+
+@Test
+public void statsOperation() {
+fluentTemplate()
+.to("direct:start")
+.withHeader(InfinispanConstants.KEY,
InfinispanProducerTestSupport.KEY_ONE)
+.withHeader(InfinispanConstants.VALUE,
InfinispanProducerTestSupport.VALUE_ONE)
+.withHeader(InfinispanConstants.OPERATION,
InfinispanOperation.PUT)
+.send();
+
+assertEquals(InfinispanProducerTestSupport.VALUE_ONE,
getCache().get(InfinispanProducerTestSupport.KEY_ONE));
+
+fluentTemplate()
+.to("direct:start")
+.withHeader(InfinispanConstants.KEY,
InfinispanProducerTestSupport.KEY_TWO)
+.withHeader(InfinispanConstants.VALUE,
InfinispanProducerTestSupport.VALUE_TWO)
+.withHeader(InfinispanConstants.OPERATION,
InfinispanOperation.PUT)
+.send();
+
+assertEquals(Infin
[GitHub] [camel] oscerd commented on pull request #6295: Camel 17081
oscerd commented on pull request #6295: URL: https://github.com/apache/camel/pull/6295#issuecomment-945718920 Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] oscerd merged pull request #6295: Camel 17081
oscerd merged pull request #6295: URL: https://github.com/apache/camel/pull/6295 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch main updated: CAMEL-16861: Cleanup and update EIP docs
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new f4dd63e CAMEL-16861: Cleanup and update EIP docs
f4dd63e is described below
commit f4dd63e9182d29c794d5248c6ecda6f9ab1be74b
Author: Claus Ibsen
AuthorDate: Mon Oct 18 14:32:36 2021 +0200
CAMEL-16861: Cleanup and update EIP docs
---
.../docs/modules/eips/pages/service-activator.adoc | 22 +--
.../docs/modules/eips/pages/serviceCall-eip.adoc | 189 ++---
2 files changed, 101 insertions(+), 110 deletions(-)
diff --git
a/core/camel-core-engine/src/main/docs/modules/eips/pages/service-activator.adoc
b/core/camel-core-engine/src/main/docs/modules/eips/pages/service-activator.adoc
index be9e75c..ef7390d 100644
---
a/core/camel-core-engine/src/main/docs/modules/eips/pages/service-activator.adoc
+++
b/core/camel-core-engine/src/main/docs/modules/eips/pages/service-activator.adoc
@@ -10,21 +10,21 @@ image::eip/MessagingAdapterSolution.gif[image]
Design a Service Activator that connects the messages on the channel to the
service being accessed.
-Camel has several endpoint components that support the Service Activator from
the EIP patterns.
+Camel has several xref:components::index.adoc[Components] that support the
Service Activator EIP.
-Components like xref:components::bean-component.adoc[Bean] and
xref:components::bean-component.adoc[CXF]
-provide a way to bind the message exchange to a Java interface/service where
the route defines the
-endpoints and wires it up to the bean.
+Components like xref:components::bean-component.adoc[Bean] and
xref:components::bean-component.adoc[CXF]
+provide a way to bind the message
xref:latest@manual:ROOT:exchange.adoc[Exchange] to a Java interface/service
+where the route defines the endpoints and wires it up to the bean.
-In addition you can use the xref:latest@manual:ROOT:bean-integration.adoc[Bean
Integration] to wire messages
-to a bean using annotation.
+In addition, you can use the
xref:latest@manual:ROOT:bean-integration.adoc[Bean Integration] to wire messages
+to a bean using Java annotation.
-== Sample
+== Example
-Here is a simple example of using a Direct endpoint to create a messaging
interface
-to a POJO Bean service.
+Here is a simple example of using a
xref:components::direct-component.adoc[Direct] endpoint
+to create a messaging interface to a POJO
xref:components::bean-component.adoc[Bean] service.
-Using Java DSL
+Using Java DSL:
[source,java]
@@ -32,7 +32,7 @@ from("direct:invokeMyService")
.to("bean:myService");
-Using the XML DSL
+Using the XML DSL:
[source,xml]
diff --git
a/core/camel-core-engine/src/main/docs/modules/eips/pages/serviceCall-eip.adoc
b/core/camel-core-engine/src/main/docs/modules/eips/pages/serviceCall-eip.adoc
index 3032749..b45a869 100644
---
a/core/camel-core-engine/src/main/docs/modules/eips/pages/serviceCall-eip.adoc
+++
b/core/camel-core-engine/src/main/docs/modules/eips/pages/serviceCall-eip.adoc
@@ -5,7 +5,40 @@
:since:
:supportlevel: Stable
-The Service Call EIP allows to call remote services in a distributed system.
+How can I call a remote service in a distributed system where the service is
looked up from a service registry of some sorts?
+
+image::eip/MessagingGatewayIcon.gif[image]
+
+Use a Service Call acting as a xref:messaging-gateway.adoc[Messaging Gateway]
for distributed systems, that
+handles the complexity of calling the service in a reliable manner.
+
+The pattern has the following noteworthy features:
+
+* _Location transparency_ — Decouples Camel and the physical location of the
services
+using logical names representing the services.
+* _URI templating_ — Allows you to template the Camel endpoint URI as the
physical
+endpoint to use when calling the service.
+* _Service discovery_ - Looks up the service from a service registry of some
sort to know
+the physical locations of the services.
+* _Service filter_ — Allows you to filter unwanted services (for example,
blacklisted or
+unhealthy services).
+* _Service chooser_ — Allows you to choose the most appropriate service based
on
+factors such as geographical zone, affinity, plans, canary deployments, and
SLAs.
+* _Load balancer_ — A preconfigured Service Discovery, Filter, and Chooser
intended
+for a specific runtime (these three features combined as one).
+
+In a nutshell, the EIP pattern sits between your Camel application and the
services running
+in a distributed system (cluster). The pattern hides all the complexity of
keeping
+track of all the physical locations where the services are running and allows
you to call
+the service by a name.
+
+== Options
+// eip options: START
+include::partial$eip-options.adoc[]
+// eip options: END
+
+== Using Service Call
+
The service to call is looked up in a service regis
[GitHub] [camel-quarkus] VratislavHais commented on pull request #3170: Aws sqs test fix
VratislavHais commented on pull request #3170: URL: https://github.com/apache/camel-quarkus/pull/3170#issuecomment-945715073 Thank you @aldettinger . I'll attempt to run it on Ubuntu -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] aldettinger commented on pull request #3170: Aws sqs test fix
aldettinger commented on pull request #3170: URL: https://github.com/apache/camel-quarkus/pull/3170#issuecomment-945712044 As far as I remember, we are running on RHEL 7 and RHEL 8 and the test passes on our machines. CI builds seem to occur on Ubuntu 20.04.3. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] VratislavHais commented on pull request #3170: Aws sqs test fix
VratislavHais commented on pull request #3170: URL: https://github.com/apache/camel-quarkus/pull/3170#issuecomment-945700750 I was wondering - what OS are you on @aldettinger @zbendhiba ? Maybe it can be OS related as it is running on Ubuntu? (just a wild guess) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] zbendhiba commented on issue #3189: [camel-main]atlasmap integration tests failed in native mode caused by atlasmap version bump(from 2.2.3 to 2.3.x)
zbendhiba commented on issue #3189: URL: https://github.com/apache/camel-quarkus/issues/3189#issuecomment-945683220 maybe we should ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
