[camel] branch main updated: camel-jbang - Upgrade to quarkus 2.13.2
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 64b3d36b5fd camel-jbang - Upgrade to quarkus 2.13.2
64b3d36b5fd is described below
commit 64b3d36b5fdeebd80f9b8add9be1713b125c9dd1
Author: Claus Ibsen
AuthorDate: Thu Oct 13 08:29:21 2022 +0200
camel-jbang - Upgrade to quarkus 2.13.2
---
.../org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java
index bc7351a350f..cf5016f2d2f 100644
---
a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java
+++
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java
@@ -98,7 +98,7 @@ abstract class ExportBaseCommand extends CamelCommand {
protected String quarkusArtifactId;
@CommandLine.Option(names = { "--quarkus-version" }, description =
"Quarkus Platform version",
-defaultValue = "2.13.1.Final")
+defaultValue = "2.13.2.Final")
protected String quarkusVersion;
@CommandLine.Option(names = { "--maven-wrapper" }, defaultValue = "true",
[GitHub] [camel] davsclaus commented on pull request #8533: CAMEL-18576: Using property placeholder allows to turn off nested, wi…
davsclaus commented on PR #8533: URL: https://github.com/apache/camel/pull/8533#issuecomment-1277092479 @essobedo - I think your docs about escaping placeholder, should be moved from properties-component to using-propertyplaceholder.adoc nearby the nested section. -- This is an automated message from the 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] davsclaus opened a new pull request, #8533: CAMEL-18576: Using property placeholder allows to turn off nested, wi…
davsclaus opened a new pull request, #8533: URL: https://github.com/apache/camel/pull/8533 …th myKey?nested=false. -- This is an automated message from the 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] 01/01: CAMEL-18576: Using property placeholder allows to turn off nested, with myKey?nested=false.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch nested
in repository https://gitbox.apache.org/repos/asf/camel.git
commit cdcc397312a3a5dc971e7344f7151de11fb857ad
Author: Claus Ibsen
AuthorDate: Thu Oct 13 08:25:27 2022 +0200
CAMEL-18576: Using property placeholder allows to turn off nested, with
myKey?nested=false.
---
.../properties/DefaultPropertiesParser.java| 15 +--
...t.java => ExpressionPlaceholderNestedTest.java} | 47 ++
.../ROOT/pages/using-propertyplaceholder.adoc | 34 +++-
3 files changed, 84 insertions(+), 12 deletions(-)
diff --git
a/core/camel-base/src/main/java/org/apache/camel/component/properties/DefaultPropertiesParser.java
b/core/camel-base/src/main/java/org/apache/camel/component/properties/DefaultPropertiesParser.java
index 7cb0d895576..83a1e16a3cf 100644
---
a/core/camel-base/src/main/java/org/apache/camel/component/properties/DefaultPropertiesParser.java
+++
b/core/camel-base/src/main/java/org/apache/camel/component/properties/DefaultPropertiesParser.java
@@ -105,7 +105,16 @@ public class DefaultPropertiesParser implements
PropertiesParser {
* @return Evaluated string
*/
public String parse(String input) {
-if (nestedPlaceholder) {
+// does the key turn on or off nested?
+boolean nested = nestedPlaceholder;
+if (input.contains("?nested=true")) {
+nested = true;
+input = input.replace("?nested=true", "");
+} else if (input.contains("?nested=false")) {
+nested = false;
+input = input.replace("?nested=false", "");
+}
+if (nested) {
return doParseNested(input, new HashSet());
} else {
return doParse(input);
@@ -474,14 +483,14 @@ public class DefaultPropertiesParser implements
PropertiesParser {
}
/**
- * Gets the begin index of the property (including the prefix token).
+ * Gets the beginning index of the property (including the prefix
token).
*/
public int getBeginIndex() {
return beginIndex;
}
/**
- * Gets the end index of the property (including the suffix token).
+ * Gets the ending index of the property (including the suffix token).
*/
public int getEndIndex() {
return endIndex;
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/ExpressionPlaceholderTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/ExpressionPlaceholderNestedTest.java
similarity index 55%
rename from
core/camel-core/src/test/java/org/apache/camel/processor/ExpressionPlaceholderTest.java
rename to
core/camel-core/src/test/java/org/apache/camel/processor/ExpressionPlaceholderNestedTest.java
index b331096352a..8035fe588c6 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/ExpressionPlaceholderTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/ExpressionPlaceholderNestedTest.java
@@ -20,13 +20,14 @@ import java.util.Properties;
import org.apache.camel.CamelContext;
import org.apache.camel.ContextTestSupport;
+import org.apache.camel.FailedToCreateRouteException;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
-@Disabled("CAMEL-18576")
-public class ExpressionPlaceholderTest extends ContextTestSupport {
+import static org.junit.jupiter.api.Assertions.fail;
+
+public class ExpressionPlaceholderNestedTest extends ContextTestSupport {
@Override
protected CamelContext createCamelContext() throws Exception {
@@ -34,6 +35,7 @@ public class ExpressionPlaceholderTest extends
ContextTestSupport {
Properties myProp = new Properties();
myProp.put("query", "{\"query\":{\"match_all\":{}}}");
+myProp.put("queryEscaped", "{\"query\":{\"match_all\":{}\\}}");
context.getPropertiesComponent().setInitialProperties(myProp);
@@ -41,11 +43,38 @@ public class ExpressionPlaceholderTest extends
ContextTestSupport {
}
@Test
-public void testPlaceholder() throws Exception {
+public void testPlaceholderFalse() throws Exception {
+MockEndpoint mock = getMockEndpoint("mock:result");
+mock.expectedBodiesReceived("{\"query\":{\"match_all\":{}}}");
+
+template.sendBody("direct:off", "Hello World");
+
+assertMockEndpointsSatisfied();
+}
+
+@Test
+public void testPlaceholderOn() throws Exception {
+try {
+context.addRoutes(new RouteBuilder() {
+@Override
+public void configure() throws Exception {
+from("direct:on")
+.setBody().constant("{{
[camel] branch nested created (now cdcc397312a)
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a change to branch nested in repository https://gitbox.apache.org/repos/asf/camel.git at cdcc397312a CAMEL-18576: Using property placeholder allows to turn off nested, with myKey?nested=false. This branch includes the following new commits: new cdcc397312a CAMEL-18576: Using property placeholder allows to turn off nested, with myKey?nested=false. 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-quarkus] 01/03: Upgrade Quarkus to 2.13.2.Final
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 386af9f7a2d711162a074a21edad0203b5026c93
Author: James Netherton
AuthorDate: Wed Oct 12 16:23:51 2022 +0100
Upgrade Quarkus to 2.13.2.Final
---
docs/antora.yml | 2 +-
pom.xml | 4 ++--
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/docs/antora.yml b/docs/antora.yml
index 4306f51936..32159412e3 100644
--- a/docs/antora.yml
+++ b/docs/antora.yml
@@ -30,7 +30,7 @@ asciidoc:
# Project versions
camel-version: 3.18.2 # replace ${camel.version}
camel-docs-version: 3.18.x # replace ${camel.docs.components.version}
-quarkus-version: 2.13.1.Final # replace ${quarkus.version}
+quarkus-version: 2.13.2.Final # replace ${quarkus.version}
graalvm-version: 22.2.0 # replace ${graalvm.version}
graalvm-docs-version: 22.2
min-maven-version: 3.8.2 # replace ${min-maven-version}
diff --git a/pom.xml b/pom.xml
index a57e2506b9..3c687f86a9 100644
--- a/pom.xml
+++ b/pom.xml
@@ -58,7 +58,7 @@
2.9.2
1.0.4
1.0.3
-2.13.1.Final
+2.13.2.Final
3.0.0
0.38.0
@@ -127,7 +127,7 @@
${squareup-okio-version}
0.31.0
0.25.0
-3.19.3
+3.19.6
3.4.22
${reactor-netty-version}
2.5.0
[camel-quarkus] 02/03: Revert "Disable tests for native mode serialization due to #4148"
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 4289d6b4aa204b11ff5f049158ac2ee32bc79e0e
Author: James Netherton
AuthorDate: Wed Oct 12 16:17:59 2022 +0100
Revert "Disable tests for native mode serialization due to #4148"
This reverts commit 6b483e8fe75bf7f2d2d75c29f7428778a5139c77.
Fixes #4148
---
.../test/java/org/apache/camel/quarkus/component/http/it/HttpTest.java | 2 --
.../apache/camel/quarkus/messaging/jms/AbstractJmsMessagingTest.java| 2 --
2 files changed, 4 deletions(-)
diff --git
a/integration-tests/http/src/test/java/org/apache/camel/quarkus/component/http/it/HttpTest.java
b/integration-tests/http/src/test/java/org/apache/camel/quarkus/component/http/it/HttpTest.java
index 1d2bd1e744..e9d330bc5f 100644
---
a/integration-tests/http/src/test/java/org/apache/camel/quarkus/component/http/it/HttpTest.java
+++
b/integration-tests/http/src/test/java/org/apache/camel/quarkus/component/http/it/HttpTest.java
@@ -17,7 +17,6 @@
package org.apache.camel.quarkus.component.http.it;
import io.quarkus.test.common.QuarkusTestResource;
-import io.quarkus.test.junit.DisabledOnIntegrationTest;
import io.quarkus.test.junit.QuarkusTest;
import io.restassured.RestAssured;
import io.restassured.http.ContentType;
@@ -158,7 +157,6 @@ class HttpTest {
.body(is("Netty Hello World Compressed"));
}
-
@DisabledOnIntegrationTest("https://github.com/apache/camel-quarkus/issues/4148";)
@ParameterizedTest
@MethodSource("getHttpComponentNames")
public void transferException(String component) {
diff --git
a/integration-tests/messaging/jms/src/test/java/org/apache/camel/quarkus/messaging/jms/AbstractJmsMessagingTest.java
b/integration-tests/messaging/jms/src/test/java/org/apache/camel/quarkus/messaging/jms/AbstractJmsMessagingTest.java
index 17ff918f31..6b0c427058 100644
---
a/integration-tests/messaging/jms/src/test/java/org/apache/camel/quarkus/messaging/jms/AbstractJmsMessagingTest.java
+++
b/integration-tests/messaging/jms/src/test/java/org/apache/camel/quarkus/messaging/jms/AbstractJmsMessagingTest.java
@@ -18,7 +18,6 @@ package org.apache.camel.quarkus.messaging.jms;
import java.util.UUID;
-import io.quarkus.test.junit.DisabledOnIntegrationTest;
import io.restassured.RestAssured;
import io.restassured.http.ContentType;
import org.apache.camel.quarkus.component.messaging.it.AbstractMessagingTest;
@@ -40,7 +39,6 @@ public class AbstractJmsMessagingTest extends
AbstractMessagingTest {
.body(is(message));
}
-
@DisabledOnIntegrationTest("https://github.com/apache/camel-quarkus/issues/4148";)
@Test
public void testJmsTransferException() {
RestAssured.given()
[camel-quarkus] 03/03: Revert "Disable XStream native tests due to #4149"
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit c7769244aa2ce5872cb5eaa4a52fe76e447f5754
Author: James Netherton
AuthorDate: Wed Oct 12 16:18:16 2022 +0100
Revert "Disable XStream native tests due to #4149"
This reverts commit 2f24671fe4541c0bc0e81d54e26e5c95396c.
Fixes #4149
---
.../java/org/apache/camel/quarkus/component/xstream/it/XstreamTest.java | 2 --
1 file changed, 2 deletions(-)
diff --git
a/integration-tests/xstream/src/test/java/org/apache/camel/quarkus/component/xstream/it/XstreamTest.java
b/integration-tests/xstream/src/test/java/org/apache/camel/quarkus/component/xstream/it/XstreamTest.java
index e9187ffdbf..6e3e5763c8 100644
---
a/integration-tests/xstream/src/test/java/org/apache/camel/quarkus/component/xstream/it/XstreamTest.java
+++
b/integration-tests/xstream/src/test/java/org/apache/camel/quarkus/component/xstream/it/XstreamTest.java
@@ -18,7 +18,6 @@ package org.apache.camel.quarkus.component.xstream.it;
import javax.json.bind.JsonbBuilder;
-import io.quarkus.test.junit.DisabledOnIntegrationTest;
import io.quarkus.test.junit.QuarkusTest;
import io.restassured.RestAssured;
import io.restassured.http.ContentType;
@@ -30,7 +29,6 @@ import static org.hamcrest.Matchers.equalTo;
@QuarkusTest
class XstreamTest {
-
@DisabledOnIntegrationTest("https://github.com/apache/camel-quarkus/issues/4149";)
@Test
void xstream() {
final String xml =
"Joe";
[camel-quarkus] branch main updated (7ea2e1fb2f -> c7769244aa)
This is an automated email from the ASF dual-hosted git repository. jamesnetherton pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git from 7ea2e1fb2f Fix assertion invocation in core extension tests new 386af9f7a2 Upgrade Quarkus to 2.13.2.Final new 4289d6b4aa Revert "Disable tests for native mode serialization due to #4148" new c7769244aa Revert "Disable XStream native tests due to #4149" 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: docs/antora.yml | 2 +- .../java/org/apache/camel/quarkus/component/http/it/HttpTest.java | 2 -- .../apache/camel/quarkus/messaging/jms/AbstractJmsMessagingTest.java | 2 -- .../org/apache/camel/quarkus/component/xstream/it/XstreamTest.java| 2 -- pom.xml | 4 ++-- 5 files changed, 3 insertions(+), 9 deletions(-)
[GitHub] [camel-quarkus] jamesnetherton closed issue #4149: XStream native integration test failure
jamesnetherton closed issue #4149: XStream native integration test failure URL: https://github.com/apache/camel-quarkus/issues/4149 -- This is an automated message from the 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 closed issue #4148: Native mode tests for serialization are failing
jamesnetherton closed issue #4148: Native mode tests for serialization are failing URL: https://github.com/apache/camel-quarkus/issues/4148 -- This is an automated message from the 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 merged pull request #4174: Upgrade Quarkus to 2.13.2.Final
jamesnetherton merged PR #4174: URL: https://github.com/apache/camel-quarkus/pull/4174 -- This is an automated message from the 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: Fix assertion invocation in core extension tests
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton 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 7ea2e1fb2f Fix assertion invocation in core extension tests
7ea2e1fb2f is described below
commit 7ea2e1fb2f625d7962bf52304951e5093817fdc7
Author: Tomas Turek
AuthorDate: Wed Oct 12 14:20:10 2022 +0200
Fix assertion invocation in core extension tests
---
.../camel/quarkus/core/deployment/CamelContextCustomizerTest.java | 2 +-
.../camel/quarkus/core/deployment/CamelContextDefaultStrategyTest.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
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 69f04c3ccc..c2a93f9766 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
@@ -69,6 +69,6 @@ public class CamelContextCustomizerTest {
@Test
public void testRestConfiguration() {
-
assertThat(camelContext.getRestConfiguration().getApiContextPath().equals("/example"));
+
assertThat(camelContext.getRestConfiguration().getApiContextPath()).isEqualTo("/example");
}
}
diff --git
a/extensions-core/core/deployment/src/test/java/org/apache/camel/quarkus/core/deployment/CamelContextDefaultStrategyTest.java
b/extensions-core/core/deployment/src/test/java/org/apache/camel/quarkus/core/deployment/CamelContextDefaultStrategyTest.java
index 8a50011289..529809ca5d 100644
---
a/extensions-core/core/deployment/src/test/java/org/apache/camel/quarkus/core/deployment/CamelContextDefaultStrategyTest.java
+++
b/extensions-core/core/deployment/src/test/java/org/apache/camel/quarkus/core/deployment/CamelContextDefaultStrategyTest.java
@@ -35,6 +35,6 @@ public class CamelContextDefaultStrategyTest {
@Test
public void testRestConfiguration() {
-assertThat(camelContext.getShutdownStrategy() instanceof
DefaultShutdownStrategy);
+assertThat(camelContext.getShutdownStrategy() instanceof
DefaultShutdownStrategy).isTrue();
}
}
[GitHub] [camel-quarkus] jamesnetherton merged pull request #4173: Fix assertion invocation in core extension tests
jamesnetherton merged PR #4173: URL: https://github.com/apache/camel-quarkus/pull/4173 -- This is an automated message from the 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 merged pull request #4157: Upgrade Quarkus Amazon services to 1.3.0
jamesnetherton merged PR #4157: URL: https://github.com/apache/camel-quarkus/pull/4157 -- This is an automated message from the 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 46bb6d4fc98 [create-pull-request] automated change
46bb6d4fc98 is described below
commit 46bb6d4fc98a6d1a659f097a07c52fd32d05bff3
Author: oscerd
AuthorDate: Thu Oct 13 01:10:34 2022 +
[create-pull-request] automated change
---
.../camel/springboot/catalog/components/pulsar.json | 4 ++--
.../camel-pulsar-starter/src/main/docs/pulsar.json | 16 +---
.../pulsar/springboot/PulsarComponentConfiguration.java | 5 +
3 files changed, 16 insertions(+), 9 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/pulsar.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/pulsar.json
index 1ac6e60d769..b75d9beca0a 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/pulsar.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/pulsar.json
@@ -57,7 +57,7 @@
"initialSequenceId": { "kind": "property", "displayName": "Initial
Sequence Id", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": -1, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "The first message published will have a
sequence Id of initialSequenceId 1." },
"lazyStartProducer": { "kind": "property", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during star [...]
"maxPendingMessages": { "kind": "property", "displayName": "Max Pending
Messages", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Size of the pending massages queue. When the
queue is full, by default, any further sends wi [...]
-"maxPendingMessagesAcrossPartitions": { "kind": "property", "displayName":
"Max Pending Messages Across Partitions", "group": "producer", "label":
"producer", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
5, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "The maximum number of pending messages for
partitioned to [...]
+"maxPendingMessagesAcrossPartitions": { "kind": "property", "displayName":
"Max Pending Messages Across Partitions", "group": "producer", "label":
"producer", "required": false, "type": "integer", "javaType": "int",
"deprecated": true, "autowired": false, "secret": false, "defaultValue": 5,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "The maximum number of
pending messages for partitioned top [...]
"messageRouter": { "kind": "property", "displayName": "Message Router",
"group": "producer", "label": "producer", "required": false, "type": "object",
"javaType": "org.apache.pulsar.client.api.MessageRouter", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Custom Message Router to use" },
"messageRoutingMode": { "kind": "property", "displayName": "Message
Routing Mode", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType":
"org.apache.pulsar.client.api.MessageRoutingMode", "enum": [ "SinglePartition",
"RoundRobinPartition", "CustomPartition" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "RoundRobinPartition",
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configuration [...]
"producerName": { "kind": "property", "displayName": "Producer Name",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated":
[GitHub] [camel-spring-boot] oscerd merged pull request #644: [Github Actions] Periodic Sync Camel Spring Boot Main Branch
oscerd merged PR #644: URL: https://github.com/apache/camel-spring-boot/pull/644 -- This is an automated message from the 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-1277005659 The [camel-main](https://github.com/apache/camel-quarkus/tree/camel-main) branch build has failed: * Build ID: 3238785419-799-c264aeb4-bbef-4ec8-a4e4-8570abff14a3 * Camel Quarkus Commit: 4b8b3c8bfeeea44bd2ea48ffde97f480b05f1d3a * Camel Main Commit: d72e4fb41bae0ff0d9395e7fdbd4e7cbae96246c * Link to build: https://github.com/apache/camel-quarkus/actions/runs/3238785419 -- This is an automated message from the 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 cf06053dd9 Updated CHANGELOG.md cf06053dd9 is described below commit cf06053dd94bd44318d4ac6ed07b48239fac88e6 Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Thu Oct 13 04:00:17 2022 + Updated CHANGELOG.md --- CHANGELOG.md | 3 +++ 1 file changed, 3 insertions(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index a89fbddf51..cd48c52833 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -12,6 +12,7 @@ **Closed issues:** +- Fallback to mocked back end for XChange tests if crypto API endpoints are not available [\#4169](https://github.com/apache/camel-quarkus/issues/4169) - Manage `io.projectreactor:reactor-core` [\#4138](https://github.com/apache/camel-quarkus/issues/4138) - Deprecated parameters in several annotations are ignored - inconsistent with other annotations. [\#4097](https://github.com/apache/camel-quarkus/issues/4097) - \[Camel 3.19.0\] azure-core-http-client-vertx: Deployment tests are failing on java heap space [\#4090](https://github.com/apache/camel-quarkus/issues/4090) @@ -22,6 +23,7 @@ **Merged pull requests:** +- Fallback to mocked responses if XChange APIs are not available [\#4170](https://github.com/apache/camel-quarkus/pull/4170) ([jamesnetherton](https://github.com/jamesnetherton)) - rest-openapi: Minor update to usage doc \(\#4117\) [\#4168](https://github.com/apache/camel-quarkus/pull/4168) ([djcoleman](https://github.com/djcoleman)) - Fix Salesforce endpoint URIs for CDC eventing [\#4166](https://github.com/apache/camel-quarkus/pull/4166) ([jamesnetherton](https://github.com/jamesnetherton)) - Add sync tag for ahc.version property [\#4164](https://github.com/apache/camel-quarkus/pull/4164) ([jamesnetherton](https://github.com/jamesnetherton)) @@ -38,6 +40,7 @@ - Manage `reactor-core` & `google-oauth-client` [\#4140](https://github.com/apache/camel-quarkus/pull/4140) ([jamesnetherton](https://github.com/jamesnetherton)) - Update release guide [\#4137](https://github.com/apache/camel-quarkus/pull/4137) ([zbendhiba](https://github.com/zbendhiba)) - Upgrade Quarkus CXF to 1.5.2 [\#4136](https://github.com/apache/camel-quarkus/pull/4136) ([jamesnetherton](https://github.com/jamesnetherton)) +- Improve test coverage for scheduler component. [\#4133](https://github.com/apache/camel-quarkus/pull/4133) ([svkcemk](https://github.com/svkcemk)) - Fix malformed id headings for AWS extensions [\#4132](https://github.com/apache/camel-quarkus/pull/4132) ([jamesnetherton](https://github.com/jamesnetherton)) - Next is 2.14.0 [\#4131](https://github.com/apache/camel-quarkus/pull/4131) ([zbendhiba](https://github.com/zbendhiba)) - Fix Netty integration tests on FIPS system [\#4130](https://github.com/apache/camel-quarkus/pull/4130) ([osmman](https://github.com/osmman))
[camel-spring-boot] branch automatic-periodic-sync updated (84f50efae15 -> fe92d6ac31f)
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 84f50efae15 [create-pull-request] automated change add 2edc221eea2 [create-pull-request] automated change add fe92d6ac31f [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 (84f50efae15) \ N -- N -- N refs/heads/automatic-periodic-sync (fe92d6ac31f) 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: .../camel/springboot/catalog/components/pulsar.json | 4 ++-- .../camel-pulsar-starter/src/main/docs/pulsar.json | 16 +--- .../pulsar/springboot/PulsarComponentConfiguration.java | 5 + 3 files changed, 16 insertions(+), 9 deletions(-)
[GitHub] [camel-spring-boot] github-actions[bot] opened a new pull request, #644: [Github Actions] Periodic Sync Camel Spring Boot Main Branch
github-actions[bot] opened a new pull request, #644: URL: https://github.com/apache/camel-spring-boot/pull/644 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
[GitHub] [camel-quarkus] ppalaga commented on pull request #4165: Upgrade to quarkus-cxf 1.5.3
ppalaga commented on PR #4165: URL: https://github.com/apache/camel-quarkus/pull/4165#issuecomment-1276808028 Blocked by https://github.com/quarkiverse/quarkus-cxf/pull/572 -- This is an automated message from the 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] github-actions[bot] commented on pull request #8531: CAMEL-18148: Added support for running callbacks on offset updates
github-actions[bot] commented on PR #8531: URL: https://github.com/apache/camel/pull/8531#issuecomment-1276500879 :x: Finished component verification: **1 component(s) test failed** out of 1 component(s) tested -- This is an automated message from the 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 issue #4175: Improve test coverage for scheduler component
aldettinger commented on issue #4175: URL: https://github.com/apache/camel-quarkus/issues/4175#issuecomment-1276471072 @svkcemk We generally create a ticket unless this is very trivial changes. The ticket can be referenced in the commit by including "#4175" in the comment. For traceability purpose, let's state that the PR was #4133 and the commit merged to main is this one: https://github.com/apache/camel-quarkus/commit/d72e4fb41bae0ff0d9395e7fdbd4e7cbae96246c The PR has been labelled with backport_2.13.x, so it will be present in next 2.13.x release, probably 2.13.1. From there @svkcemk, is there any work left in this ticket, like deleting a useless branch, update some docs or opening any follow up issues ? If not, we gonna set the milestone and close this issue. @jamesnetherton Note that I'm not able to assign this ticket to souvik. Is there anything to tune in the repository ? -- This is an automated message from the 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: Improve test coverage for scheduler component.
This is an automated email from the ASF dual-hosted git repository.
aldettinger 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 d72e4fb41b Improve test coverage for scheduler component.
d72e4fb41b is described below
commit d72e4fb41bae0ff0d9395e7fdbd4e7cbae96246c
Author: svkcemk
AuthorDate: Mon Sep 26 13:41:09 2022 +0530
Improve test coverage for scheduler component.
---
.../component/scheduler/it/SchedulerResource.java | 72 +-
.../component/scheduler/it/SchedulerRoute.java | 29 -
.../component/scheduler/it/SchedulerTest.java | 40 +++-
3 files changed, 135 insertions(+), 6 deletions(-)
diff --git
a/integration-test-groups/foundation/scheduler/src/main/java/org/apache/camel/quarkus/component/scheduler/it/SchedulerResource.java
b/integration-test-groups/foundation/scheduler/src/main/java/org/apache/camel/quarkus/component/scheduler/it/SchedulerResource.java
index a3971bfa8c..c5632a7438 100644
---
a/integration-test-groups/foundation/scheduler/src/main/java/org/apache/camel/quarkus/component/scheduler/it/SchedulerResource.java
+++
b/integration-test-groups/foundation/scheduler/src/main/java/org/apache/camel/quarkus/component/scheduler/it/SchedulerResource.java
@@ -26,14 +26,24 @@ import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;
-import org.apache.camel.ProducerTemplate;
-
@Path("/scheduler")
@ApplicationScoped
public class SchedulerResource {
@Inject
-ProducerTemplate producerTemplate;
+@Named("withDelayCounter")
+AtomicInteger withDelayCounter;
+
+@Inject
+@Named("useFixedDelayCounter")
+AtomicInteger useFixedDelayCounter;
+
+@Named("withDelayRepeatCounter")
+AtomicInteger withDelayRepeatCounter;
+
+@Inject
+@Named("greedyCounter")
+AtomicInteger greedyCounter;
@Inject
@Named("schedulerCounter")
@@ -46,6 +56,34 @@ public class SchedulerResource {
return schedulerCounter.get();
}
+@Path("/get-delay-count")
+@GET
+@Produces(MediaType.TEXT_PLAIN)
+public int getCountDelay() {
+return withDelayCounter.get();
+}
+
+@Path("/get-fixed-delay-count")
+@GET
+@Produces(MediaType.TEXT_PLAIN)
+public int getCountFixedDelay() {
+return useFixedDelayCounter.get();
+}
+
+@Path("/get-repeat-count")
+@GET
+@Produces(MediaType.TEXT_PLAIN)
+public int getRepeatCount() {
+return withDelayRepeatCounter.get();
+}
+
+@Path("/get-greedy-count")
+@GET
+@Produces(MediaType.TEXT_PLAIN)
+public int getGreedyCount() {
+return greedyCounter.get();
+}
+
@javax.enterprise.inject.Produces
@ApplicationScoped
@Named("schedulerCounter")
@@ -53,4 +91,32 @@ public class SchedulerResource {
return new AtomicInteger();
}
+@javax.enterprise.inject.Produces
+@ApplicationScoped
+@Named("withDelayRepeatCounter")
+AtomicInteger withDelayRepeatCounter() {
+return new AtomicInteger();
+}
+
+@javax.enterprise.inject.Produces
+@ApplicationScoped
+@Named("withDelayCounter")
+AtomicInteger withDelayCounter() {
+return new AtomicInteger();
+}
+
+@javax.enterprise.inject.Produces
+@ApplicationScoped
+@Named("useFixedDelayCounter")
+AtomicInteger useFixedDelayCounter() {
+return new AtomicInteger();
+}
+
+@javax.enterprise.inject.Produces
+@ApplicationScoped
+@Named("greedyCounter")
+AtomicInteger greedyCounter() {
+return new AtomicInteger();
+}
+
}
diff --git
a/integration-test-groups/foundation/scheduler/src/main/java/org/apache/camel/quarkus/component/scheduler/it/SchedulerRoute.java
b/integration-test-groups/foundation/scheduler/src/main/java/org/apache/camel/quarkus/component/scheduler/it/SchedulerRoute.java
index 98224bf9cf..096c934df1 100644
---
a/integration-test-groups/foundation/scheduler/src/main/java/org/apache/camel/quarkus/component/scheduler/it/SchedulerRoute.java
+++
b/integration-test-groups/foundation/scheduler/src/main/java/org/apache/camel/quarkus/component/scheduler/it/SchedulerRoute.java
@@ -31,10 +31,37 @@ public class SchedulerRoute extends RouteBuilder {
@Named("schedulerCounter")
AtomicInteger schedulerCounter;
+@Inject
+@Named("withDelayCounter")
+AtomicInteger withDelayCounter;
+
+@Inject
+@Named("useFixedDelayCounter")
+AtomicInteger useFixedDelayCounter;
+
+@Inject
+@Named("withDelayRepeatCounter")
+AtomicInteger withDelayRepeatCounter;
+
+@Inject
+@Named("greedyCounter")
+AtomicInteger greedyCounter;
+
@Override
public void configure() throws Exception {
-from("scheduler:start?initialDelay=1")
+from("scheduler:withInitialDelay?initialDelay=1")
.process(e -> sc
[GitHub] [camel-quarkus] aldettinger merged pull request #4133: Improve test coverage for scheduler component.
aldettinger merged PR #4133: URL: https://github.com/apache/camel-quarkus/pull/4133 -- This is an automated message from the 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 #4133: Improve test coverage for scheduler component.
aldettinger commented on PR #4133: URL: https://github.com/apache/camel-quarkus/pull/4133#issuecomment-1276460962 The failing test is not related. Merging then. -- This is an automated message from the 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: Regen for commit e2f1948808f8824eb959cf2352d8768bd34938a1
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 5e1c4a0daa6 Regen for commit e2f1948808f8824eb959cf2352d8768bd34938a1
5e1c4a0daa6 is described below
commit 5e1c4a0daa65636fbb68b096a15d542579c01f92
Author: oscerd
AuthorDate: Wed Oct 12 16:35:59 2022 +
Regen for commit e2f1948808f8824eb959cf2352d8768bd34938a1
Signed-off-by: GitHub
---
.../apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java
index e8e1dd42c69..d25310f27df 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java
@@ -1178,6 +1178,7 @@ public interface PulsarEndpointBuilderFactory {
* @param maxPendingMessagesAcrossPartitions the value to set
* @return the dsl builder
*/
+@Deprecated
default PulsarEndpointProducerBuilder
maxPendingMessagesAcrossPartitions(
int maxPendingMessagesAcrossPartitions) {
doSetProperty("maxPendingMessagesAcrossPartitions",
maxPendingMessagesAcrossPartitions);
@@ -1197,6 +1198,7 @@ public interface PulsarEndpointBuilderFactory {
* @param maxPendingMessagesAcrossPartitions the value to set
* @return the dsl builder
*/
+@Deprecated
default PulsarEndpointProducerBuilder
maxPendingMessagesAcrossPartitions(
String maxPendingMessagesAcrossPartitions) {
doSetProperty("maxPendingMessagesAcrossPartitions",
maxPendingMessagesAcrossPartitions);
[GitHub] [camel] oscerd merged pull request #8532: Generated sources regen
oscerd merged PR #8532: URL: https://github.com/apache/camel/pull/8532 -- This is an automated message from the 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 (a01ac209daf -> 0aa6cc4a870)
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 a01ac209daf Regen for commit ae2f8e250c5ab7210e1b3ff5ee06aa68e28de2c4 add e2f1948808f Regen for commit ae2f8e250c5ab7210e1b3ff5ee06aa68e28de2c4 add 0aa6cc4a870 Regen for commit e2f1948808f8824eb959cf2352d8768bd34938a1 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 (a01ac209daf) \ N -- N -- N refs/heads/regen_bot (0aa6cc4a870) 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: .../apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java | 2 ++ 1 file changed, 2 insertions(+)
[GitHub] [camel] github-actions[bot] opened a new pull request, #8532: Generated sources regen
github-actions[bot] opened a new pull request, #8532: URL: https://github.com/apache/camel/pull/8532 Regen bot :robot: found some uncommitted 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] github-actions[bot] commented on pull request #8531: CAMEL-18148: Added support for running callbacks on offset updates
github-actions[bot] commented on PR #8531: URL: https://github.com/apache/camel/pull/8531#issuecomment-1276430971 :warning: This PR changes Camel components and will be tested automatically. -- This is an automated message from the 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, #8531: CAMEL-18148: Added support for running callbacks on offset updates
orpiske opened a new pull request, #8531: URL: https://github.com/apache/camel/pull/8531 -- This is an automated message from the 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: Regen for commit ae2f8e250c5ab7210e1b3ff5ee06aa68e28de2c4
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 e2f1948808f Regen for commit ae2f8e250c5ab7210e1b3ff5ee06aa68e28de2c4
e2f1948808f is described below
commit e2f1948808f8824eb959cf2352d8768bd34938a1
Author: essobedo
AuthorDate: Wed Oct 12 15:49:09 2022 +
Regen for commit ae2f8e250c5ab7210e1b3ff5ee06aa68e28de2c4
Signed-off-by: GitHub
---
.../resources/org/apache/camel/catalog/components/pulsar.json | 4 ++--
.../camel/builder/component/dsl/PulsarComponentBuilderFactory.java| 1 +
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/pulsar.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/pulsar.json
index b95da9667fe..183bf83b416 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/pulsar.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/pulsar.json
@@ -57,7 +57,7 @@
"initialSequenceId": { "kind": "property", "displayName": "Initial
Sequence Id", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": -1, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "The first message published will have a
sequence Id of initialSequenceId 1." },
"lazyStartProducer": { "kind": "property", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during star [...]
"maxPendingMessages": { "kind": "property", "displayName": "Max Pending
Messages", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Size of the pending massages queue. When the
queue is full, by default, any further sends wi [...]
-"maxPendingMessagesAcrossPartitions": { "kind": "property", "displayName":
"Max Pending Messages Across Partitions", "group": "producer", "label":
"producer", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
5, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "The maximum number of pending messages for
partitioned to [...]
+"maxPendingMessagesAcrossPartitions": { "kind": "property", "displayName":
"Max Pending Messages Across Partitions", "group": "producer", "label":
"producer", "required": false, "type": "integer", "javaType": "int",
"deprecated": true, "autowired": false, "secret": false, "defaultValue": 5,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "The maximum number of
pending messages for partitioned top [...]
"messageRouter": { "kind": "property", "displayName": "Message Router",
"group": "producer", "label": "producer", "required": false, "type": "object",
"javaType": "org.apache.pulsar.client.api.MessageRouter", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Custom Message Router to use" },
"messageRoutingMode": { "kind": "property", "displayName": "Message
Routing Mode", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType":
"org.apache.pulsar.client.api.MessageRoutingMode", "enum": [ "SinglePartition",
"RoundRobinPartition", "CustomPartition" ], "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "RoundRobinPartition",
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configuration [...]
"producerName": { "kind": "property", "displayName": "Producer Name",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.pulsar.Pu
[GitHub] [camel] oscerd merged pull request #8530: Generated sources regen
oscerd merged PR #8530: URL: https://github.com/apache/camel/pull/8530 -- This is an automated message from the 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 (064bee0da8c -> a01ac209daf)
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 064bee0da8c CAMEL-18603: camel-jbang - run with kamelets classloading issue add 18b3fe2daa3 camel-jbang - Upgrade to SB 2.7.4 add ae2f8e250c5 CAMEL-16030: camel-pulsar - Add async send to producer (#8529) add a01ac209daf Regen for commit ae2f8e250c5ab7210e1b3ff5ee06aa68e28de2c4 No new revisions were added by this update. Summary of changes: .../apache/camel/catalog/components/pulsar.json| 4 +- .../org/apache/camel/component/pulsar/pulsar.json | 4 +- .../component/pulsar/PulsarConfiguration.java | 6 +- .../camel/component/pulsar/PulsarProducer.java | 145 + .../dsl/PulsarComponentBuilderFactory.java | 1 + .../dsl/jbang/core/commands/ExportBaseCommand.java | 2 +- 6 files changed, 103 insertions(+), 59 deletions(-)
[GitHub] [camel] github-actions[bot] opened a new pull request, #8530: Generated sources regen
github-actions[bot] opened a new pull request, #8530: URL: https://github.com/apache/camel/pull/8530 Regen bot :robot: found some uncommitted 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-kamelets] oscerd opened a new issue, #1086: Add Nats Source and Sink Kamelets specialized for Authenticated NATS Server
oscerd opened a new issue, #1086: URL: https://github.com/apache/camel-kamelets/issues/1086 @chrisdutz from the discussion in dev. -- This is an automated message from the 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] essobedo merged pull request #8529: CAMEL-16030: camel-pulsar - Add async send to producer
essobedo merged PR #8529: URL: https://github.com/apache/camel/pull/8529 -- This is an automated message from the 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-16030: camel-pulsar - Add async send to producer (#8529)
This is an automated email from the ASF dual-hosted git repository.
nfilotto 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 ae2f8e250c5 CAMEL-16030: camel-pulsar - Add async send to producer
(#8529)
ae2f8e250c5 is described below
commit ae2f8e250c5ab7210e1b3ff5ee06aa68e28de2c4
Author: Nicolas Filotto
AuthorDate: Wed Oct 12 17:04:27 2022 +0200
CAMEL-16030: camel-pulsar - Add async send to producer (#8529)
## Motivation
The producer is synchronous today. But pulsar allows sending
asynchronously, where a `CompletableFuture` is returned. We can leverage this
for async send, and call `AsyncCallback` from the future.
## Modifications:
* Make `PulsarProducer` extend `DefaultAsyncProducer` and implement the
corresponding `process` method
* Ensure the thread safety of the producer initialization (not directly
related to the initial issue)
* Deprecate the option `maxPendingMessagesAcrossPartitions` as it is
deprecated in the pulsar client
---
.../org/apache/camel/component/pulsar/pulsar.json | 4 +-
.../component/pulsar/PulsarConfiguration.java | 6 +-
.../camel/component/pulsar/PulsarProducer.java | 145 +
3 files changed, 99 insertions(+), 56 deletions(-)
diff --git
a/components/camel-pulsar/src/generated/resources/org/apache/camel/component/pulsar/pulsar.json
b/components/camel-pulsar/src/generated/resources/org/apache/camel/component/pulsar/pulsar.json
index b95da9667fe..183bf83b416 100644
---
a/components/camel-pulsar/src/generated/resources/org/apache/camel/component/pulsar/pulsar.json
+++
b/components/camel-pulsar/src/generated/resources/org/apache/camel/component/pulsar/pulsar.json
@@ -57,7 +57,7 @@
"initialSequenceId": { "kind": "property", "displayName": "Initial
Sequence Id", "group": "producer", "label": "producer", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": -1, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "The first message published will have a
sequence Id of initialSequenceId 1." },
"lazyStartProducer": { "kind": "property", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during star [...]
"maxPendingMessages": { "kind": "property", "displayName": "Max Pending
Messages", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Size of the pending massages queue. When the
queue is full, by default, any further sends wi [...]
-"maxPendingMessagesAcrossPartitions": { "kind": "property", "displayName":
"Max Pending Messages Across Partitions", "group": "producer", "label":
"producer", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
5, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "The maximum number of pending messages for
partitioned to [...]
+"maxPendingMessagesAcrossPartitions": { "kind": "property", "displayName":
"Max Pending Messages Across Partitions", "group": "producer", "label":
"producer", "required": false, "type": "integer", "javaType": "int",
"deprecated": true, "autowired": false, "secret": false, "defaultValue": 5,
"configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration",
"configurationField": "configuration", "description": "The maximum number of
pending messages for partitioned top [...]
"messageRouter": { "kind": "property", "displayName": "Message Router",
"group": "producer", "label": "producer", "required": false, "type": "object",
"javaType": "org.apache.pulsar.client.api.MessageRouter", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Custom Message Router to use" },
"messageRoutingMode": { "kind": "property", "displayName": "Message
Routing Mode", "group": "producer", "label": "producer", "required": false,
"type": "object", "javaType":
"org.apache.pulsa
[GitHub] [camel] github-actions[bot] commented on pull request #8529: CAMEL-16030: camel-pulsar - Add async send to producer
github-actions[bot] commented on PR #8529: URL: https://github.com/apache/camel/pull/8529#issuecomment-1276328279 :heavy_check_mark: Finished component verification: 0 component(s) test failed out of **1 component(s) tested** -- This is an automated message from the 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 camel-main updated (ecdf2efb61 -> 57058716ad)
This is an automated email from the ASF dual-hosted git repository. jiriondrusek pushed a change to branch camel-main in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git discard ecdf2efb61 Upgrade Camel to 3.20.0 new 57058716ad Upgrade Camel to 3.20.0 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 (ecdf2efb61) \ N -- N -- N refs/heads/camel-main (57058716ad) 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: poms/bom/src/main/generated/flattened-full-pom.xml | 34 +- .../generated/flattened-reduced-verbose-pom.xml| 18 ++-- 2 files changed, 23 insertions(+), 29 deletions(-)
[GitHub] [camel-spring-boot-examples] kariuwu commented on pull request #94: [refactor] refactoring settings properties
kariuwu commented on PR #94: URL: https://github.com/apache/camel-spring-boot-examples/pull/94#issuecomment-1276300281 Duplicated pull request -- This is an automated message from the 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-examples] kariuwu closed pull request #94: [refactor] refactoring settings properties
kariuwu closed pull request #94: [refactor] refactoring settings properties URL: https://github.com/apache/camel-spring-boot-examples/pull/94 -- This is an automated message from the 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 (18b3fe2daa3 -> 064bee0da8c)
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 18b3fe2daa3 camel-jbang - Upgrade to SB 2.7.4 This update removed existing revisions from the reference, leaving the reference pointing at a previous point in the repository history. * -- * -- N refs/heads/regen_bot (064bee0da8c) \ O -- O -- O (18b3fe2daa3) Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: .../org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[GitHub] [camel-spring-boot-examples] kariuwu opened a new pull request, #94: [refactor] refactoring settings properties
kariuwu opened a new pull request, #94: URL: https://github.com/apache/camel-spring-boot-examples/pull/94 This refactor is needed for QE testing CSB. -- This is an automated message from the 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 (e20b717f94e -> 18b3fe2daa3)
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 e20b717f94e CAMEL-18607: camel-yaml-dsl - Should continue evaluating the rest of the properties (#8528) add 064bee0da8c CAMEL-18603: camel-jbang - run with kamelets classloading issue add 18b3fe2daa3 camel-jbang - Upgrade to SB 2.7.4 No new revisions were added by this update. Summary of changes: .../dsl/jbang/core/commands/ExportBaseCommand.java | 4 ++- .../camel-jbang-main/dist/CamelJBang.java | 1 - .../src/main/jbang/main/CamelJBang.java| 1 - .../main/download/DependencyDownloaderKamelet.java | 40 ++ .../main/download/MavenDependencyDownloader.java | 33 ++ 5 files changed, 39 insertions(+), 40 deletions(-)
[GitHub] [camel] github-actions[bot] commented on pull request #8529: CAMEL-16030: camel-pulsar - Add async send to producer
github-actions[bot] commented on PR #8529: URL: https://github.com/apache/camel/pull/8529#issuecomment-1276269696 :heavy_check_mark: Finished component verification: 0 component(s) test failed out of **1 component(s) tested** -- This is an automated message from the 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 (2024ab9acc4 -> e20b717f94e)
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 2024ab9acc4 CAMEL-18576: camel-base - Escape a placeholder (#8521) add e20b717f94e CAMEL-18607: camel-yaml-dsl - Should continue evaluating the rest of the properties (#8528) No new revisions were added by this update. Summary of changes: .../java/org/apache/camel/maven/dsl/yaml/GenerateYamlSchemaMojo.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-)
[camel] branch CAMEL-16030/async-producer updated (e58c997431a -> c76695bcd92)
This is an automated email from the ASF dual-hosted git repository. nfilotto pushed a change to branch CAMEL-16030/async-producer in repository https://gitbox.apache.org/repos/asf/camel.git omit e58c997431a CAMEL-16030: camel-pulsar - Add async send to producer add c76695bcd92 CAMEL-16030: camel-pulsar - Add async send to producer 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 (e58c997431a) \ N -- N -- N refs/heads/CAMEL-16030/async-producer (c76695bcd92) 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: .../generated/resources/org/apache/camel/component/pulsar/pulsar.json | 4 ++-- .../java/org/apache/camel/component/pulsar/PulsarConfiguration.java | 1 + 2 files changed, 3 insertions(+), 2 deletions(-)
[camel] branch camel-3.18.x updated (da5f70c22bf -> f519f84b7df)
This is an automated email from the ASF dual-hosted git repository. orpiske pushed a change to branch camel-3.18.x in repository https://gitbox.apache.org/repos/asf/camel.git from da5f70c22bf camel-jbang - Upgrade to quarkus 2.13.1 new d407362d057 [camel-18588] Added condition to only commit offset if it is not -1 new 8aebc9d7ad6 [camel-18588] Added condition to only commit offset if it is not alreday paused new f519f84b7df [camel-18327] resuming from last committed offset 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: .../apache/camel/component/kafka/KafkaFetchRecords.java | 15 --- .../kafka/consumer/support/KafkaRecordProcessor.java | 8 ++-- 2 files changed, 18 insertions(+), 5 deletions(-)
[camel] 03/03: [camel-18327] resuming from last committed offset
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch camel-3.18.x
in repository https://gitbox.apache.org/repos/asf/camel.git
commit f519f84b7df11ebc12bf475c70bd35a126f480c0
Author: geekr
AuthorDate: Fri Oct 7 13:54:42 2022 -0400
[camel-18327] resuming from last committed offset
---
.../org/apache/camel/component/kafka/KafkaFetchRecords.java| 10 ++
1 file changed, 10 insertions(+)
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
index edf39671436..079a14615ab 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
@@ -41,7 +41,9 @@ import org.apache.camel.util.ReflectionHelper;
import org.apache.camel.util.TimeUtils;
import org.apache.kafka.clients.CommonClientConfigs;
import org.apache.kafka.clients.consumer.ConsumerRecords;
+import org.apache.kafka.clients.consumer.OffsetAndMetadata;
import org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient;
+import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.errors.InterruptException;
import org.apache.kafka.common.errors.WakeupException;
import org.slf4j.Logger;
@@ -380,6 +382,14 @@ public class KafkaFetchRecords implements Runnable {
break;
case RESUME_REQUESTED:
LOG.info("Resuming the consumer as a response to a resume
request");
+if (consumer.committed(this.consumer.assignment()) != null) {
+consumer.committed(this.consumer.assignment()).forEach((k,
v) -> {
+final TopicPartition tp = (TopicPartition) k;
+LOG.info("Resuming from the offset {} for the topic {}
with partition {}",
+((OffsetAndMetadata) v).offset(), tp.topic(),
tp.partition());
+consumer.seek(tp, ((OffsetAndMetadata) v).offset());
+});
+}
consumer.resume(consumer.assignment());
state = State.RUNNING;
break;
[camel] 02/03: [camel-18588] Added condition to only commit offset if it is not alreday paused
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch camel-3.18.x
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 8aebc9d7ad659b4238aefa215c63d6b438bb9af5
Author: geekr
AuthorDate: Tue Oct 11 15:01:11 2022 -0400
[camel-18588] Added condition to only commit offset if it is not alreday
paused
---
.../java/org/apache/camel/component/kafka/KafkaFetchRecords.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
index 5684375bbdd..edf39671436 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java
@@ -317,8 +317,8 @@ public class KafkaFetchRecords implements Runnable {
}
ProcessingResult result =
recordProcessorFacade.processPolledRecords(allRecords, lastResult);
-
-if (result.isBreakOnErrorHit()) {
+updateTaskState();
+if (result.isBreakOnErrorHit() &&
!this.state.equals(State.PAUSED)) {
LOG.debug("We hit an error ... setting flags to force
reconnect");
// force re-connect
setReconnect(true);
@@ -327,7 +327,6 @@ public class KafkaFetchRecords implements Runnable {
lastResult = result;
}
-updateTaskState();
}
if (!isConnected()) {
[camel] 01/03: [camel-18588] Added condition to only commit offset if it is not -1
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch camel-3.18.x
in repository https://gitbox.apache.org/repos/asf/camel.git
commit d407362d0571cedcb2dfd4d04d83263b8da729d3
Author: geekr
AuthorDate: Mon Oct 10 15:38:32 2022 -0400
[camel-18588] Added condition to only commit offset if it is not -1
---
.../component/kafka/consumer/support/KafkaRecordProcessor.java| 8 ++--
1 file changed, 6 insertions(+), 2 deletions(-)
diff --git
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/KafkaRecordProcessor.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/KafkaRecordProcessor.java
index 38763385b78..1afe53cbe2b 100644
---
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/KafkaRecordProcessor.java
+++
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/support/KafkaRecordProcessor.java
@@ -23,6 +23,7 @@ import org.apache.camel.Message;
import org.apache.camel.Processor;
import org.apache.camel.component.kafka.KafkaConfiguration;
import org.apache.camel.component.kafka.KafkaConstants;
+import org.apache.camel.component.kafka.consumer.AbstractCommitManager;
import org.apache.camel.component.kafka.consumer.CommitManager;
import org.apache.camel.component.kafka.consumer.KafkaManualCommit;
import org.apache.camel.component.kafka.serde.KafkaHeaderDeserializer;
@@ -131,8 +132,11 @@ public class KafkaRecordProcessor {
LOG.warn("Will seek consumer to offset {} and start polling
again.", partitionLastOffset);
}
-// force commit, so we resume on next poll where we failed
-commitManager.forceCommit(partition, partitionLastOffset);
+// force commit, so we resume on next poll where we failed except
when the failure happened
+// at the first message in a poll
+if (partitionLastOffset != AbstractCommitManager.START_OFFSET) {
+commitManager.forceCommit(partition, partitionLastOffset);
+}
// continue to next partition
return true;
[GitHub] [camel] orpiske merged pull request #8526: Backport to 3.18 a few Kafka fixes
orpiske merged PR #8526: URL: https://github.com/apache/camel/pull/8526 -- This is an automated message from the 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] geekrupam commented on pull request #8526: Backport to 3.18 a few Kafka fixes
geekrupam commented on PR #8526: URL: https://github.com/apache/camel/pull/8526#issuecomment-1276212476 > Hello, @geekrupam > > This backports the fixes you worked on main to the Camel 3.18 LTS release. Please, feel free to review if everything you worked on is available here. > > Thanks for your contributions! LGTM! Thanks @orpiske -- This is an automated message from the 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 (526c0a13357 -> 2024ab9acc4)
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 526c0a13357 CAMEL-18608: camel-box - Fix the regression with shared
connection (#8527)
add 2024ab9acc4 CAMEL-18576: camel-base - Escape a placeholder (#8521)
No new revisions were added by this update.
Summary of changes:
.../src/main/docs/properties-component.adoc| 7
.../properties/DefaultPropertiesParser.java| 30 ++---
.../component/properties/PropertiesComponent.java | 38 ++
...st.java => PropertiesComponentEscapedTest.java} | 17 ++
.../PropertiesComponentLoadPropertiesTest.java | 6 ++--
.../component/properties/myproperties.properties | 1 +
6 files changed, 84 insertions(+), 15 deletions(-)
copy
core/camel-core/src/test/java/org/apache/camel/component/properties/{PropertiesComponentNestedTest.java
=> PropertiesComponentEscapedTest.java} (71%)
[camel] 02/03: camel-jbang - Upgrade to Camel 3.18.2
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-3.18.x
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 2dcba6cfa86bede5cdfd217ccb014e3a02ab131c
Author: Claus Ibsen
AuthorDate: Wed Oct 12 15:52:05 2022 +0200
camel-jbang - Upgrade to Camel 3.18.2
---
dsl/camel-jbang/camel-jbang-main/dist/CamelJBang.java| 4 ++--
dsl/camel-jbang/camel-jbang-main/src/main/jbang/main/CamelJBang.java | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/dsl/camel-jbang/camel-jbang-main/dist/CamelJBang.java
b/dsl/camel-jbang/camel-jbang-main/dist/CamelJBang.java
index 4310369c751..01be06318b3 100755
--- a/dsl/camel-jbang/camel-jbang-main/dist/CamelJBang.java
+++ b/dsl/camel-jbang/camel-jbang-main/dist/CamelJBang.java
@@ -19,8 +19,8 @@
//JAVA 11+
//REPOS mavencentral,apache=https://repository.apache.org/snapshots
-//DEPS org.apache.camel:camel-bom:${camel.jbang.version:3.18.1}@pom
-//DEPS org.apache.camel:camel-jbang-core:${camel.jbang.version:3.18.1}
+//DEPS org.apache.camel:camel-bom:${camel.jbang.version:3.18.2}@pom
+//DEPS org.apache.camel:camel-jbang-core:${camel.jbang.version:3.18.2}
//DEPS org.apache.camel.kamelets:camel-kamelets:${camel-kamelets.version:0.9.0}
package main;
diff --git
a/dsl/camel-jbang/camel-jbang-main/src/main/jbang/main/CamelJBang.java
b/dsl/camel-jbang/camel-jbang-main/src/main/jbang/main/CamelJBang.java
index 4310369c751..01be06318b3 100755
--- a/dsl/camel-jbang/camel-jbang-main/src/main/jbang/main/CamelJBang.java
+++ b/dsl/camel-jbang/camel-jbang-main/src/main/jbang/main/CamelJBang.java
@@ -19,8 +19,8 @@
//JAVA 11+
//REPOS mavencentral,apache=https://repository.apache.org/snapshots
-//DEPS org.apache.camel:camel-bom:${camel.jbang.version:3.18.1}@pom
-//DEPS org.apache.camel:camel-jbang-core:${camel.jbang.version:3.18.1}
+//DEPS org.apache.camel:camel-bom:${camel.jbang.version:3.18.2}@pom
+//DEPS org.apache.camel:camel-jbang-core:${camel.jbang.version:3.18.2}
//DEPS org.apache.camel.kamelets:camel-kamelets:${camel-kamelets.version:0.9.0}
package main;
[camel] 01/03: CAMEL-18603: camel-jbang - run with kamelets classloading issue
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-3.18.x
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 7b2985e92123348bfe2e880f45e42c9da5b6313f
Author: Claus Ibsen
AuthorDate: Wed Oct 12 15:47:36 2022 +0200
CAMEL-18603: camel-jbang - run with kamelets classloading issue
---
.../dsl/jbang/core/commands/ExportBaseCommand.java | 2 ++
.../camel-jbang-main/dist/CamelJBang.java | 1 -
.../src/main/jbang/main/CamelJBang.java| 1 -
.../main/download/DependencyDownloaderKamelet.java | 40 ++
4 files changed, 35 insertions(+), 9 deletions(-)
diff --git
a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java
index 12a741293f1..bc82eb9e4a5 100644
---
a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java
+++
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java
@@ -194,6 +194,7 @@ abstract class ExportBaseCommand extends CamelCommand {
// include yaml-dsl and kamelet catalog if we use kamelets
answer.add("camel:yaml-dsl");
answer.add("org.apache.camel.kamelets:camel-kamelets:" +
kameletsVersion);
+
answer.add("org.apache.camel.kamelets:camel-kamelets-utils:" + kameletsVersion);
}
} else if (line.startsWith("camel.jbang.dependencies=")) {
String deps = StringHelper.after(line,
"camel.jbang.dependencies=");
@@ -235,6 +236,7 @@ abstract class ExportBaseCommand extends CamelCommand {
} else if (line.startsWith("camel.component.kamelet.location=")) {
// include kamelet catalog if we use kamelets
answer.add("mvn:org.apache.camel.kamelets:camel-kamelets:" +
kameletsVersion);
+
answer.add("mvn:org.apache.camel.kamelets:camel-kamelets-utils:" +
kameletsVersion);
}
}
diff --git a/dsl/camel-jbang/camel-jbang-main/dist/CamelJBang.java
b/dsl/camel-jbang/camel-jbang-main/dist/CamelJBang.java
index d2df7b5ab34..4310369c751 100755
--- a/dsl/camel-jbang/camel-jbang-main/dist/CamelJBang.java
+++ b/dsl/camel-jbang/camel-jbang-main/dist/CamelJBang.java
@@ -22,7 +22,6 @@
//DEPS org.apache.camel:camel-bom:${camel.jbang.version:3.18.1}@pom
//DEPS org.apache.camel:camel-jbang-core:${camel.jbang.version:3.18.1}
//DEPS org.apache.camel.kamelets:camel-kamelets:${camel-kamelets.version:0.9.0}
-//DEPS
org.apache.camel.kamelets:camel-kamelets-utils:${camel-kamelets.version:0.9.0}
package main;
diff --git
a/dsl/camel-jbang/camel-jbang-main/src/main/jbang/main/CamelJBang.java
b/dsl/camel-jbang/camel-jbang-main/src/main/jbang/main/CamelJBang.java
index d2df7b5ab34..4310369c751 100755
--- a/dsl/camel-jbang/camel-jbang-main/src/main/jbang/main/CamelJBang.java
+++ b/dsl/camel-jbang/camel-jbang-main/src/main/jbang/main/CamelJBang.java
@@ -22,7 +22,6 @@
//DEPS org.apache.camel:camel-bom:${camel.jbang.version:3.18.1}@pom
//DEPS org.apache.camel:camel-jbang-core:${camel.jbang.version:3.18.1}
//DEPS org.apache.camel.kamelets:camel-kamelets:${camel-kamelets.version:0.9.0}
-//DEPS
org.apache.camel.kamelets:camel-kamelets-utils:${camel-kamelets.version:0.9.0}
package main;
diff --git
a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderKamelet.java
b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderKamelet.java
index 5c8f0c37a56..b4fe5aa461c 100644
---
a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderKamelet.java
+++
b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderKamelet.java
@@ -16,6 +16,8 @@
*/
package org.apache.camel.main.download;
+import java.lang.management.ManagementFactory;
+import java.lang.management.RuntimeMXBean;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
@@ -32,6 +34,7 @@ import org.apache.camel.spi.Resource;
import org.apache.camel.spi.RouteTemplateLoaderListener;
import org.apache.camel.support.service.ServiceHelper;
import org.apache.camel.support.service.ServiceSupport;
+import org.apache.camel.util.StringHelper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.snakeyaml.engine.v2.nodes.Node;
@@ -47,12 +50,12 @@ import static
org.apache.camel.dsl.yaml.common.YamlDeserializerSupport.nodeAt;
public final class DependencyDownloaderKamelet extends ServiceSupport
implements CamelContextAware, RouteTemplateLoaderListener {
-private final KameletDependencyDownloader downloader;
+private static final String KAMELETS_VERSION = "0.9.0";
+privat
[camel] branch camel-3.18.x updated (fb90d971ada -> da5f70c22bf)
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a change to branch camel-3.18.x in repository https://gitbox.apache.org/repos/asf/camel.git from fb90d971ada [CXF-8762] CXF client sends the SOAPAction header without quotes (#8494) new 7b2985e9212 CAMEL-18603: camel-jbang - run with kamelets classloading issue new 2dcba6cfa86 camel-jbang - Upgrade to Camel 3.18.2 new da5f70c22bf camel-jbang - Upgrade to quarkus 2.13.1 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: .../dsl/jbang/core/commands/ExportBaseCommand.java | 4 ++- .../camel-jbang-main/dist/CamelJBang.java | 5 ++- .../src/main/jbang/main/CamelJBang.java| 5 ++- .../main/download/DependencyDownloaderKamelet.java | 40 ++ 4 files changed, 40 insertions(+), 14 deletions(-)
[camel] 03/03: camel-jbang - Upgrade to quarkus 2.13.1
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-3.18.x
in repository https://gitbox.apache.org/repos/asf/camel.git
commit da5f70c22bf0377218b1384de7a927e8e8ccb76d
Author: Claus Ibsen
AuthorDate: Wed Oct 12 15:52:49 2022 +0200
camel-jbang - Upgrade to quarkus 2.13.1
---
.../org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java
index bc82eb9e4a5..bc7351a350f 100644
---
a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java
+++
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java
@@ -98,7 +98,7 @@ abstract class ExportBaseCommand extends CamelCommand {
protected String quarkusArtifactId;
@CommandLine.Option(names = { "--quarkus-version" }, description =
"Quarkus Platform version",
-defaultValue = "2.12.3.Final")
+defaultValue = "2.13.1.Final")
protected String quarkusVersion;
@CommandLine.Option(names = { "--maven-wrapper" }, defaultValue = "true",
[camel] branch main updated: camel-jbang - Upgrade to SB 2.7.4
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 18b3fe2daa3 camel-jbang - Upgrade to SB 2.7.4
18b3fe2daa3 is described below
commit 18b3fe2daa38ae22031f28357ead218ab54612a1
Author: Claus Ibsen
AuthorDate: Wed Oct 12 15:48:16 2022 +0200
camel-jbang - Upgrade to SB 2.7.4
---
.../org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java
index 10a7a36eef5..bc7351a350f 100644
---
a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java
+++
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java
@@ -86,7 +86,7 @@ abstract class ExportBaseCommand extends CamelCommand {
protected String localKameletDir;
@CommandLine.Option(names = { "--spring-boot-version" }, description =
"Spring Boot version",
-defaultValue = "2.7.3")
+defaultValue = "2.7.4")
protected String springBootVersion;
@CommandLine.Option(names = { "--quarkus-group-id" }, description =
"Quarkus Platform Maven groupId",
[camel] branch main updated: CAMEL-18603: camel-jbang - run with kamelets classloading issue
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 064bee0da8c CAMEL-18603: camel-jbang - run with kamelets classloading
issue
064bee0da8c is described below
commit 064bee0da8c8a608b3c6d54bd9645c04e0dbe016
Author: Claus Ibsen
AuthorDate: Wed Oct 12 15:47:36 2022 +0200
CAMEL-18603: camel-jbang - run with kamelets classloading issue
---
.../dsl/jbang/core/commands/ExportBaseCommand.java | 2 ++
.../camel-jbang-main/dist/CamelJBang.java | 1 -
.../src/main/jbang/main/CamelJBang.java| 1 -
.../main/download/DependencyDownloaderKamelet.java | 40 ++
.../main/download/MavenDependencyDownloader.java | 33 ++
5 files changed, 38 insertions(+), 39 deletions(-)
diff --git
a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java
index d0ff0d7bca7..10a7a36eef5 100644
---
a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java
+++
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ExportBaseCommand.java
@@ -194,6 +194,7 @@ abstract class ExportBaseCommand extends CamelCommand {
// include yaml-dsl and kamelet catalog if we use kamelets
answer.add("camel:yaml-dsl");
answer.add("org.apache.camel.kamelets:camel-kamelets:" +
kameletsVersion);
+
answer.add("org.apache.camel.kamelets:camel-kamelets-utils:" + kameletsVersion);
}
} else if (line.startsWith("camel.jbang.dependencies=")) {
String deps = StringHelper.after(line,
"camel.jbang.dependencies=");
@@ -235,6 +236,7 @@ abstract class ExportBaseCommand extends CamelCommand {
} else if (line.startsWith("camel.component.kamelet.location=")) {
// include kamelet catalog if we use kamelets
answer.add("mvn:org.apache.camel.kamelets:camel-kamelets:" +
kameletsVersion);
+
answer.add("mvn:org.apache.camel.kamelets:camel-kamelets-utils:" +
kameletsVersion);
}
}
diff --git a/dsl/camel-jbang/camel-jbang-main/dist/CamelJBang.java
b/dsl/camel-jbang/camel-jbang-main/dist/CamelJBang.java
index 7bea892a39a..84baa24e8eb 100755
--- a/dsl/camel-jbang/camel-jbang-main/dist/CamelJBang.java
+++ b/dsl/camel-jbang/camel-jbang-main/dist/CamelJBang.java
@@ -22,7 +22,6 @@
//DEPS org.apache.camel:camel-bom:${camel.jbang.version:3.19.0}@pom
//DEPS org.apache.camel:camel-jbang-core:${camel.jbang.version:3.19.0}
//DEPS org.apache.camel.kamelets:camel-kamelets:${camel-kamelets.version:0.9.0}
-//DEPS
org.apache.camel.kamelets:camel-kamelets-utils:${camel-kamelets.version:0.9.0}
package main;
diff --git
a/dsl/camel-jbang/camel-jbang-main/src/main/jbang/main/CamelJBang.java
b/dsl/camel-jbang/camel-jbang-main/src/main/jbang/main/CamelJBang.java
index 7bea892a39a..84baa24e8eb 100755
--- a/dsl/camel-jbang/camel-jbang-main/src/main/jbang/main/CamelJBang.java
+++ b/dsl/camel-jbang/camel-jbang-main/src/main/jbang/main/CamelJBang.java
@@ -22,7 +22,6 @@
//DEPS org.apache.camel:camel-bom:${camel.jbang.version:3.19.0}@pom
//DEPS org.apache.camel:camel-jbang-core:${camel.jbang.version:3.19.0}
//DEPS org.apache.camel.kamelets:camel-kamelets:${camel-kamelets.version:0.9.0}
-//DEPS
org.apache.camel.kamelets:camel-kamelets-utils:${camel-kamelets.version:0.9.0}
package main;
diff --git
a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderKamelet.java
b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderKamelet.java
index 5c8f0c37a56..b4fe5aa461c 100644
---
a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderKamelet.java
+++
b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/DependencyDownloaderKamelet.java
@@ -16,6 +16,8 @@
*/
package org.apache.camel.main.download;
+import java.lang.management.ManagementFactory;
+import java.lang.management.RuntimeMXBean;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
@@ -32,6 +34,7 @@ import org.apache.camel.spi.Resource;
import org.apache.camel.spi.RouteTemplateLoaderListener;
import org.apache.camel.support.service.ServiceHelper;
import org.apache.camel.support.service.ServiceSupport;
+import org.apache.camel.util.StringHelper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.snakeyaml.engine.v2.nodes.Node;
@@ -47,12 +50,12 @@ import static
org.apache.camel.dsl.yaml.common.YamlDeserializerSupport.nodeAt;
public final cla
[GitHub] [camel-quarkus] aldettinger commented on a diff in pull request #4133: Improve test coverage for scheduler component.
aldettinger commented on code in PR #4133:
URL: https://github.com/apache/camel-quarkus/pull/4133#discussion_r993471663
##
integration-test-groups/foundation/scheduler/src/test/java/org/apache/camel/quarkus/component/scheduler/it/SchedulerTest.java:
##
@@ -28,12 +28,48 @@
class SchedulerTest {
@Test
-public void test() throws Exception {
-// wait until the scheduler has run and return a counter that is > 0
+public void testInitialDelay() throws Exception {
await().atMost(5, TimeUnit.SECONDS).until(() -> {
String body =
RestAssured.get("/scheduler/get").then().statusCode(200).extract().body().asString();
return !body.equals("0");
});
}
+@Test
+public void testDelay() throws Exception {
+await().atMost(2, TimeUnit.SECONDS).until(() -> {
+String body =
RestAssured.get("/scheduler/get-delay-count").then().statusCode(200).extract().body()
+.asString();
+return Integer.parseInt(body) > 2;
+});
+
+}
+
+@Test
+public void testFixedDelay() throws Exception {
+await().atMost(2, TimeUnit.SECONDS).until(() -> {
+String body =
RestAssured.get("/scheduler/get-fixed-delay-count").then().statusCode(200).extract().body()
+.asString();
+return Integer.parseInt(body) > 2;
+});
+}
+
+@Test
+public void testDelayWithRepeat() throws Exception {
+await().atMost(4, TimeUnit.SECONDS).until(() -> {
+String body =
RestAssured.get("/scheduler/get-repeat-count").then().statusCode(200).extract().body()
+.asString();
+return Integer.parseInt(body) >= 4;
+});
+}
+
+@Test
+public void testGreedyScheduler() throws Exception {
+await().atMost(1, TimeUnit.SECONDS).until(() -> {
+String body =
RestAssured.get("/scheduler/get-greedy-count").then().statusCode(200).extract().body()
+.asString();
+return Integer.parseInt(body) > 10;
Review Comment:
For a next round, maybe `body().as(Integer.class)` would avoid manual
parsing here. Not a blocker though :)
--
This is an automated message from the 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-18607: camel-yaml-dsl - Should continue evaluating the rest of the properties (#8528)
This is an automated email from the ASF dual-hosted git repository.
igarashitm 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 e20b717f94e CAMEL-18607: camel-yaml-dsl - Should continue evaluating
the rest of the properties (#8528)
e20b717f94e is described below
commit e20b717f94e362f6b37d432aec0e92c4fbc7645c
Author: Tomohisa Igarashi
AuthorDate: Wed Oct 12 09:31:13 2022 -0400
CAMEL-18607: camel-yaml-dsl - Should continue evaluating the rest of the
properties (#8528)
---
.../java/org/apache/camel/maven/dsl/yaml/GenerateYamlSchemaMojo.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git
a/dsl/camel-yaml-dsl/camel-yaml-dsl-maven-plugin/src/main/java/org/apache/camel/maven/dsl/yaml/GenerateYamlSchemaMojo.java
b/dsl/camel-yaml-dsl/camel-yaml-dsl-maven-plugin/src/main/java/org/apache/camel/maven/dsl/yaml/GenerateYamlSchemaMojo.java
index 9ce20a6be9e..19a337ed8b5 100644
---
a/dsl/camel-yaml-dsl/camel-yaml-dsl-maven-plugin/src/main/java/org/apache/camel/maven/dsl/yaml/GenerateYamlSchemaMojo.java
+++
b/dsl/camel-yaml-dsl/camel-yaml-dsl-maven-plugin/src/main/java/org/apache/camel/maven/dsl/yaml/GenerateYamlSchemaMojo.java
@@ -298,11 +298,10 @@ public class GenerateYamlSchemaMojo extends
GenerateYamlSupportMojo {
return;
}
-
if (propertyType.startsWith("object:")) {
final DotName dn =
DotName.createSimple(propertyType.substring(7));
if (isBanned(view.getClassByName(dn))) {
-return;
+continue;
}
}
[GitHub] [camel] igarashitm merged pull request #8528: CAMEL-18607: camel-yaml-dsl - Should continue evaluating the rest of …
igarashitm merged PR #8528: URL: https://github.com/apache/camel/pull/8528 -- This is an automated message from the 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] github-actions[bot] commented on pull request #8528: CAMEL-18607: camel-yaml-dsl - Should continue evaluating the rest of …
github-actions[bot] commented on PR #8528: URL: https://github.com/apache/camel/pull/8528#issuecomment-1276172978 :no_entry_sign: There are (likely) no components to be tested in this 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
[GitHub] [camel] github-actions[bot] commented on pull request #8529: CAMEL-16030: camel-pulsar - Add async send to producer
github-actions[bot] commented on PR #8529: URL: https://github.com/apache/camel/pull/8529#issuecomment-1276163879 :warning: This PR changes Camel components and will be tested automatically. -- This is an automated message from the 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] essobedo opened a new pull request, #8529: CAMEL-16030: camel-pulsar - Add async send to producer
essobedo opened a new pull request, #8529: URL: https://github.com/apache/camel/pull/8529 Fix for https://issues.apache.org/jira/browse/CAMEL-16030 ## Motivation The producer is synchronous today. But pulsar allows sending asynchronously, where a `CompletableFuture` is returned. We can leverage this for async send, and call `AsyncCallback` from the future. ## Modifications: * Make `PulsarProducer` extend `DefaultAsyncProducer` and implement the corresponding `process` method * Ensure the thread safety of the producer initialization (not directly related to the initial issue) * Deprecate the option `maxPendingMessagesAcrossPartitions` as it is deprecated in the pulsar client -- This is an automated message from the 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] 01/01: CAMEL-16030: camel-pulsar - Add async send to producer
This is an automated email from the ASF dual-hosted git repository.
nfilotto pushed a commit to branch CAMEL-16030/async-producer
in repository https://gitbox.apache.org/repos/asf/camel.git
commit e58c997431a120a5d8b45d291a80d30955298977
Author: Nicolas Filotto
AuthorDate: Wed Oct 12 15:11:53 2022 +0200
CAMEL-16030: camel-pulsar - Add async send to producer
---
.../component/pulsar/PulsarConfiguration.java | 5 +-
.../camel/component/pulsar/PulsarProducer.java | 145 +
2 files changed, 96 insertions(+), 54 deletions(-)
diff --git
a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarConfiguration.java
b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarConfiguration.java
index 1d9aa490e71..8c475284911 100644
---
a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarConfiguration.java
+++
b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarConfiguration.java
@@ -312,12 +312,15 @@ public class PulsarConfiguration implements Cloneable {
}
/**
- * Set the number of max pending messages across all the partitions.
Default is 5.
+ * Set the number of max pending messages across all the partitions.
Default is 5. This option is deprecated and
+ * will be removed in a future version.
*/
+@Deprecated
public void setMaxPendingMessagesAcrossPartitions(int
maxPendingMessagesAcrossPartitions) {
this.maxPendingMessagesAcrossPartitions =
maxPendingMessagesAcrossPartitions;
}
+@Deprecated
public int getMaxPendingMessagesAcrossPartitions() {
return maxPendingMessagesAcrossPartitions;
}
diff --git
a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarProducer.java
b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarProducer.java
index 52dcdc14dfb..100340eef2e 100644
---
a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarProducer.java
+++
b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarProducer.java
@@ -16,30 +16,35 @@
*/
package org.apache.camel.component.pulsar;
+import java.io.IOException;
import java.util.Map;
import java.util.concurrent.TimeUnit;
+import org.apache.camel.AsyncCallback;
+import org.apache.camel.CamelExchangeException;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.NoTypeConversionAvailableException;
import org.apache.camel.TypeConversionException;
import org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders;
import org.apache.camel.component.pulsar.utils.message.PulsarMessageUtils;
-import org.apache.camel.support.DefaultProducer;
+import org.apache.camel.support.DefaultAsyncProducer;
import org.apache.camel.util.CastUtils;
import org.apache.camel.util.ObjectHelper;
import org.apache.pulsar.client.api.Producer;
import org.apache.pulsar.client.api.ProducerBuilder;
+import org.apache.pulsar.client.api.PulsarClientException;
import org.apache.pulsar.client.api.TypedMessageBuilder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class PulsarProducer extends DefaultProducer {
+public class PulsarProducer extends DefaultAsyncProducer {
private static final Logger LOG =
LoggerFactory.getLogger(PulsarProducer.class);
+private final Object mutex = new Object();
private final PulsarEndpoint pulsarEndpoint;
-private Producer producer;
+private volatile Producer producer;
public PulsarProducer(PulsarEndpoint pulsarEndpoint) {
super(pulsarEndpoint);
@@ -47,69 +52,103 @@ public class PulsarProducer extends DefaultProducer {
}
@Override
-public void process(final Exchange exchange) throws Exception {
-final Message message = exchange.getIn();
-
-TypedMessageBuilder messageBuilder = producer.newMessage();
-byte[] body;
+public boolean process(Exchange exchange, AsyncCallback callback) {
try {
-body = exchange.getContext().getTypeConverter()
-.mandatoryConvertTo(byte[].class, exchange,
message.getBody());
-} catch (NoTypeConversionAvailableException | TypeConversionException
exception) {
-// fallback to try to serialize the data
-body = PulsarMessageUtils.serialize(message.getBody());
-}
-messageBuilder.value(body);
+final Message message = exchange.getIn();
+byte[] body = serialize(exchange, message.getBody());
+TypedMessageBuilder messageBuilder = producer.newMessage();
+messageBuilder.value(body);
-String key = exchange.getIn().getHeader(PulsarMessageHeaders.KEY_OUT,
String.class);
-if (ObjectHelper.isNotEmpty(key)) {
-messageBuilder.key(key);
-}
+String key =
exchange.getIn().getHeader(Pulsa
[camel] branch CAMEL-16030/async-producer updated (5bf94a8f578 -> e58c997431a)
This is an automated email from the ASF dual-hosted git repository. nfilotto pushed a change to branch CAMEL-16030/async-producer in repository https://gitbox.apache.org/repos/asf/camel.git discard 5bf94a8f578 CAMEL-16030: camel-pulsar - Add async send to producer new e58c997431a CAMEL-16030: camel-pulsar - Add async send to producer 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 (5bf94a8f578) \ N -- N -- N refs/heads/CAMEL-16030/async-producer (e58c997431a) 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: .../java/org/apache/camel/component/pulsar/PulsarConfiguration.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[camel] 01/01: CAMEL-16030: camel-pulsar - Add async send to producer
This is an automated email from the ASF dual-hosted git repository.
nfilotto pushed a commit to branch CAMEL-16030/async-producer
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 5bf94a8f578a867531fb2f743c053b74e338f317
Author: Nicolas Filotto
AuthorDate: Wed Oct 12 15:11:53 2022 +0200
CAMEL-16030: camel-pulsar - Add async send to producer
---
.../component/pulsar/PulsarConfiguration.java | 5 +-
.../camel/component/pulsar/PulsarProducer.java | 145 +
2 files changed, 96 insertions(+), 54 deletions(-)
diff --git
a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarConfiguration.java
b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarConfiguration.java
index 1d9aa490e71..5fe9db9f06f 100644
---
a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarConfiguration.java
+++
b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarConfiguration.java
@@ -312,12 +312,15 @@ public class PulsarConfiguration implements Cloneable {
}
/**
- * Set the number of max pending messages across all the partitions.
Default is 5.
+ * Set the number of max pending messages across all the partitions.
Default is 5. This option is deprecated and
+ * will be removed in future version.
*/
+@Deprecated
public void setMaxPendingMessagesAcrossPartitions(int
maxPendingMessagesAcrossPartitions) {
this.maxPendingMessagesAcrossPartitions =
maxPendingMessagesAcrossPartitions;
}
+@Deprecated
public int getMaxPendingMessagesAcrossPartitions() {
return maxPendingMessagesAcrossPartitions;
}
diff --git
a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarProducer.java
b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarProducer.java
index 52dcdc14dfb..100340eef2e 100644
---
a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarProducer.java
+++
b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarProducer.java
@@ -16,30 +16,35 @@
*/
package org.apache.camel.component.pulsar;
+import java.io.IOException;
import java.util.Map;
import java.util.concurrent.TimeUnit;
+import org.apache.camel.AsyncCallback;
+import org.apache.camel.CamelExchangeException;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.NoTypeConversionAvailableException;
import org.apache.camel.TypeConversionException;
import org.apache.camel.component.pulsar.utils.message.PulsarMessageHeaders;
import org.apache.camel.component.pulsar.utils.message.PulsarMessageUtils;
-import org.apache.camel.support.DefaultProducer;
+import org.apache.camel.support.DefaultAsyncProducer;
import org.apache.camel.util.CastUtils;
import org.apache.camel.util.ObjectHelper;
import org.apache.pulsar.client.api.Producer;
import org.apache.pulsar.client.api.ProducerBuilder;
+import org.apache.pulsar.client.api.PulsarClientException;
import org.apache.pulsar.client.api.TypedMessageBuilder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class PulsarProducer extends DefaultProducer {
+public class PulsarProducer extends DefaultAsyncProducer {
private static final Logger LOG =
LoggerFactory.getLogger(PulsarProducer.class);
+private final Object mutex = new Object();
private final PulsarEndpoint pulsarEndpoint;
-private Producer producer;
+private volatile Producer producer;
public PulsarProducer(PulsarEndpoint pulsarEndpoint) {
super(pulsarEndpoint);
@@ -47,69 +52,103 @@ public class PulsarProducer extends DefaultProducer {
}
@Override
-public void process(final Exchange exchange) throws Exception {
-final Message message = exchange.getIn();
-
-TypedMessageBuilder messageBuilder = producer.newMessage();
-byte[] body;
+public boolean process(Exchange exchange, AsyncCallback callback) {
try {
-body = exchange.getContext().getTypeConverter()
-.mandatoryConvertTo(byte[].class, exchange,
message.getBody());
-} catch (NoTypeConversionAvailableException | TypeConversionException
exception) {
-// fallback to try to serialize the data
-body = PulsarMessageUtils.serialize(message.getBody());
-}
-messageBuilder.value(body);
+final Message message = exchange.getIn();
+byte[] body = serialize(exchange, message.getBody());
+TypedMessageBuilder messageBuilder = producer.newMessage();
+messageBuilder.value(body);
-String key = exchange.getIn().getHeader(PulsarMessageHeaders.KEY_OUT,
String.class);
-if (ObjectHelper.isNotEmpty(key)) {
-messageBuilder.key(key);
-}
+String key =
exchange.getIn().getHeader(PulsarM
[camel] branch CAMEL-16030/async-producer created (now 5bf94a8f578)
This is an automated email from the ASF dual-hosted git repository. nfilotto pushed a change to branch CAMEL-16030/async-producer in repository https://gitbox.apache.org/repos/asf/camel.git at 5bf94a8f578 CAMEL-16030: camel-pulsar - Add async send to producer This branch includes the following new commits: new 5bf94a8f578 CAMEL-16030: camel-pulsar - Add async send to producer The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[camel] branch main updated: CAMEL-18576: camel-base - Escape a placeholder (#8521)
This is an automated email from the ASF dual-hosted git repository.
nfilotto 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 2024ab9acc4 CAMEL-18576: camel-base - Escape a placeholder (#8521)
2024ab9acc4 is described below
commit 2024ab9acc42d25c61b9a5377a2bb07cc828fbf9
Author: Nicolas Filotto
AuthorDate: Wed Oct 12 15:06:56 2022 +0200
CAMEL-18576: camel-base - Escape a placeholder (#8521)
## Motivation
The elastic search queries can contain double curly braces which are seen
as a property placeholder by Camel, we need a way to escape it.
## Modifications:
* Propose to use the backslash character to escape double curly braces
---
.../src/main/docs/properties-component.adoc| 7
.../properties/DefaultPropertiesParser.java| 30 ---
.../component/properties/PropertiesComponent.java | 38 +++
...st.java => PropertiesComponentEscapedTest.java} | 43 --
.../PropertiesComponentLoadPropertiesTest.java | 6 +--
.../component/properties/myproperties.properties | 1 +
6 files changed, 97 insertions(+), 28 deletions(-)
diff --git a/core/camel-base/src/main/docs/properties-component.adoc
b/core/camel-base/src/main/docs/properties-component.adoc
index 2eceaa06d6f..186be6a4096 100644
--- a/core/camel-base/src/main/docs/properties-component.adoc
+++ b/core/camel-base/src/main/docs/properties-component.adoc
@@ -119,6 +119,13 @@ For fine grained configuration of the location, then this
can be done as follows
+=== Escape a placeholder
+
+The component allows to refer to the value of a property thanks to
placeholders of type `{{property-name}}` but sometimes it can be problematic if
the double curly braces are used by a third party library.
+
+To work around that it is possible to escape the double curly braces with a
backslash character like for example `\{{ property-name \}}`. This way, it
won't be interpreted as a placeholder to resolve and will be resolved as
`{{property-name}}`.
+
+If for some reason, the backslash character before the double curly braces
must not be interpreted as an escape character, it is possible to add another
backslash in front of it to escape it, it will then be seen as a backslash.
== Options
diff --git
a/core/camel-base/src/main/java/org/apache/camel/component/properties/DefaultPropertiesParser.java
b/core/camel-base/src/main/java/org/apache/camel/component/properties/DefaultPropertiesParser.java
index afb5b5c73f1..7cb0d895576 100644
---
a/core/camel-base/src/main/java/org/apache/camel/component/properties/DefaultPropertiesParser.java
+++
b/core/camel-base/src/main/java/org/apache/camel/component/properties/DefaultPropertiesParser.java
@@ -172,13 +172,18 @@ public class DefaultPropertiesParser implements
PropertiesParser {
Set newReplaced = new HashSet<>(replacedPropertyKeys);
newReplaced.add(property.getKey());
-String before = answer.substring(0, property.getBeginIndex());
+int beginIndex = property.getBeginIndex();
+if (beginIndex > 0 && answer.charAt(beginIndex - 1) == '\\') {
+// The escape character has been escaped, so we need to
restore it
+beginIndex--;
+}
+String before = answer.substring(0, beginIndex);
String after = answer.substring(property.getEndIndex());
String parsed = doParseNested(property.getValue(),
newReplaced);
if (parsed != null) {
answer = before + parsed + after;
} else {
-if (property.getBeginIndex() == 0 && input.length() ==
property.getEndIndex()) {
+if (beginIndex == 0 && input.length() ==
property.getEndIndex()) {
// its only a single placeholder which is parsed as
null
answer = null;
break;
@@ -229,7 +234,7 @@ public class DefaultPropertiesParser implements
PropertiesParser {
int index = -1;
do {
index = input.indexOf(SUFFIX_TOKEN, index + 1);
-} while (index != -1 && isQuoted(input, index, SUFFIX_TOKEN));
+} while (index != -1 && (isQuoted(input, index, SUFFIX_TOKEN) ||
isEscaped(input, index - 1)));
return index;
}
@@ -246,12 +251,12 @@ public class DefaultPropertiesParser implements
PropertiesParser {
int index = suffixIndex;
do {
index = input.lastIndexOf(PREFIX_TOKEN, index - 1);
-} while (index != -1 && isQuoted(input, index, PREFIX_TOKEN));
+} while (index != -1 && (isQuoted(input, index, PREFIX_TOKEN) ||
isEscaped(input, index - 1)));
return index;
[GitHub] [camel] essobedo merged pull request #8521: CAMEL-18576: camel-base - Escape a placeholder
essobedo merged PR #8521: URL: https://github.com/apache/camel/pull/8521 -- This is an automated message from the 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 (f2bbca4436a -> 526c0a13357)
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 f2bbca4436a Update camel-console.adoc add 526c0a13357 CAMEL-18608: camel-box - Fix the regression with shared connection (#8527) No new revisions were added by this update. Summary of changes: .../camel/component/box/BoxConfiguration.java | 7 +- .../component/box/BoxSharedConnectionTest.java | 89 ++ 2 files changed, 41 insertions(+), 55 deletions(-)
[GitHub] [camel] davsclaus commented on a diff in pull request #8492: CAMEL-18596: Use async checkpoint updating method from Azure EventCon…
davsclaus commented on code in PR #8492:
URL: https://github.com/apache/camel/pull/8492#discussion_r993434475
##
components/camel-azure/camel-azure-eventhubs/src/main/java/org/apache/camel/component/azure/eventhubs/EventHubsConsumer.java:
##
@@ -173,7 +173,12 @@ private void processCommit(final Exchange exchange, final
EventContext eventCont
try {
var completionCondition = processCheckpoint(exchange);
if (completionCondition.equals(COMPLETED_BY_SIZE)) {
-eventContext.updateCheckpoint();
+eventContext.updateCheckpointAsync()
+.subscribe(unused -> LOG.debug("Processed one
event..."), error -> {
+LOG.debug("Error when updating Checkpoint: {}",
error.getMessage());
+exchange.setException(error);
Review Comment:
Since the callback is async then in case of an error, then storing that on
the exchange does not make sense as the exchange would likely no longer be in
use. Instead the error should be logged, or better yet processed by exception
handler on the consumer - there should be a
getExceptionHandler.handleException(...)
--
This is an automated message from the 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] davsclaus commented on pull request #8521: CAMEL-18576: camel-base - Escape a placeholder
davsclaus commented on PR #8521: URL: https://github.com/apache/camel/pull/8521#issuecomment-1276138558 Good to see you found a way to avoid the regexp for unescaping -- This is an automated message from the 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] oscerd commented on issue #1085: Kafka SSL SCRAM Login
oscerd commented on issue #1085: URL: https://github.com/apache/camel-kamelets/issues/1085#issuecomment-1276131558 Thanks for your time. -- This is an automated message from the 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] rossdeane commented on issue #1085: Kafka SSL SCRAM Login
rossdeane commented on issue #1085: URL: https://github.com/apache/camel-kamelets/issues/1085#issuecomment-1276131119 Sure, I'll open a PR! 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-k] phantomjinx commented on pull request #3423: Minor updates for bundle generation
phantomjinx commented on PR #3423: URL: https://github.com/apache/camel-k/pull/3423#issuecomment-1276119584 Tests failing due to e2e compilation error fixed in #3527. -- This is an automated message from the 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] oscerd commented on issue #1085: Kafka SSL SCRAM Login
oscerd commented on issue #1085: URL: https://github.com/apache/camel-kamelets/issues/1085#issuecomment-1276111802 If you want to open a PR, we are happy to review it and merge it. -- This is an automated message from the 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] oscerd commented on issue #1085: Kafka SSL SCRAM Login
oscerd commented on issue #1085: URL: https://github.com/apache/camel-kamelets/issues/1085#issuecomment-1276110699 We could add it, it will be in the 0.10.0 release, targeting Camel 3.19.0 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. 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] rossdeane opened a new issue, #1085: Kafka SSL SCRAM Login
rossdeane opened a new issue, #1085: URL: https://github.com/apache/camel-kamelets/issues/1085 Hi, It doesn't seem to be possible to use a custom JAAS config with the Kafka-SSL Sink and Source. It should be possible to set `saslJaasConfig` in https://github.com/apache/camel-kamelets/blob/main/kamelets/kafka-ssl-source.kamelet.yaml -- This is an automated message from the 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.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] igarashitm commented on pull request #8528: CAMEL-18607: camel-yaml-dsl - Should continue evaluating the rest of …
igarashitm commented on PR #8528: URL: https://github.com/apache/camel/pull/8528#issuecomment-1276096111 Tested with the example and verified not-banned-expressions are now put as expected https://github.com/igarashitm/example-generate-yaml-schema/blob/main/src/generated/resources/schema/camel-yaml-dsl-restricted.json#L266-L277 -- This is an automated message from the 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 (035f42a5a3b -> f2bbca4436a)
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 035f42a5a3b CAMEL-18607: camel-yaml-dsl - bannedDefinition partially fails to exclude expression definition (#8523) add f2bbca4436a Update camel-console.adoc No new revisions were added by this update. Summary of changes: docs/user-manual/modules/ROOT/pages/camel-console.adoc | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[GitHub] [camel] igarashitm opened a new pull request, #8528: CAMEL-18607: camel-yaml-dsl - Should continue evaluating the rest of …
igarashitm opened a new pull request, #8528: URL: https://github.com/apache/camel/pull/8528 …the properties Sorry, I overlooked my previous fix for CAMEL-18607 had an issue, it stops evaluating the properties once banned one is found... -- This is an automated message from the 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-kamelets] branch regen_bot updated (0d1128f2 -> e181e511)
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-kamelets.git from 0d1128f2 Duplicate some of headers with a different name - Azure Storage Queue Source add e57bc823 Switch Azure Storage Blob Source from timer producer style to a pure consumer add fc278c93 Switch Azure Storage Blob Source from timer producer style to a pure consumer add e181e511 Switch Azure Storage Blob Source from timer producer style to a pure consumer No new revisions were added by this update. Summary of changes: kamelets/azure-storage-blob-source.kamelet.yaml| 47 +- .../azure-storage-blob-source.kamelet.yaml | 47 +- 2 files changed, 20 insertions(+), 74 deletions(-)
[GitHub] [camel-quarkus] osmman opened a new pull request, #4173: Fix assertion invocation in core extension tests
osmman opened a new pull request, #4173: URL: https://github.com/apache/camel-quarkus/pull/4173 It fixes bug in usage of assertThat in core extension's tests. The problem is that the invocation of assertion is missing this means that nothing is actually tested. Problem has been discovered by sonarcloud scanner [[1](https://sonarcloud.io/project/issues?issues=AYJn4gD9vQZIYxYYEQIW&open=AYJn4gD9vQZIYxYYEQIW&id=apache_camel_quarkus)][[2](https://sonarcloud.io/project/issues?issues=AYJn4gD3vQZIYxYYEQIT&open=AYJn4gD3vQZIYxYYEQIT&id=apache_camel_quarkus)]. -- This is an automated message from the 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-kamelets] 01/03: Switch Azure Storage Blob Source from timer producer style to a pure consumer
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-kamelets.git
commit e57bc823d72e9605f4097333841a70ebf52117fb
Author: Andrea Cosentino
AuthorDate: Wed Oct 12 14:07:32 2022 +0200
Switch Azure Storage Blob Source from timer producer style to a pure
consumer
---
kamelets/azure-storage-blob-source.kamelet.yaml| 41 ++
.../azure-storage-blob-source.kamelet.yaml | 41 ++
2 files changed, 20 insertions(+), 62 deletions(-)
diff --git a/kamelets/azure-storage-blob-source.kamelet.yaml
b/kamelets/azure-storage-blob-source.kamelet.yaml
index 01c333c5..d4ed8cd1 100644
--- a/kamelets/azure-storage-blob-source.kamelet.yaml
+++ b/kamelets/azure-storage-blob-source.kamelet.yaml
@@ -75,37 +75,16 @@ spec:
- "camel:timer"
template:
from:
- uri: "timer:azure-storage-blob-stream"
+ uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
parameters:
-period: "{{period}}"
+accessKey: "{{accessKey}}"
+credentialType: "{{credentialType}}"
steps:
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
-operation: "listBlobs"
-accessKey: "{{accessKey}}"
-credentialType: "{{credentialType}}"
- - split:
- jsonpath: "$.*"
- steps:
- - set-property:
- name: azureBlobName
- simple: ${body.name}
- - set-header:
- name: CamelAzureStorageBlobBlobName
- simple: ${exchangeProperty.azureBlobName}
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
-operation: "getBlob"
-accessKey: "{{accessKey}}"
- - to: "kamelet:sink"
- - set-header:
- name: CamelAzureStorageBlobBlobName
- simple: ${exchangeProperty.azureBlobName}
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
-operation: "deleteBlob"
-accessKey: "{{accessKey}}"
+- to: "kamelet:sink"
+- to:
+uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
+parameters:
+ operation: "deleteBlob"
+ accessKey: "{{accessKey}}"
+ credentialType: "{{credentialType}}"
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml
index 01c333c5..d4ed8cd1 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml
@@ -75,37 +75,16 @@ spec:
- "camel:timer"
template:
from:
- uri: "timer:azure-storage-blob-stream"
+ uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
parameters:
-period: "{{period}}"
+accessKey: "{{accessKey}}"
+credentialType: "{{credentialType}}"
steps:
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
-operation: "listBlobs"
-accessKey: "{{accessKey}}"
-credentialType: "{{credentialType}}"
- - split:
- jsonpath: "$.*"
- steps:
- - set-property:
- name: azureBlobName
- simple: ${body.name}
- - set-header:
- name: CamelAzureStorageBlobBlobName
- simple: ${exchangeProperty.azureBlobName}
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
-operation: "getBlob"
-accessKey: "{{accessKey}}"
- - to: "kamelet:sink"
- - set-header:
- name: CamelAzureStorageBlobBlobName
- simple: ${exchangeProperty.azureBlobName}
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
-operation: "deleteBlob"
-accessKey: "{{accessKey}}"
+- to: "kamelet:sink"
+- to:
+uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
+parameters:
+ operation: "deleteBlob"
+ accessKey: "{{accessKey}}"
+ credentialType: "{{credentialType}}"
[camel-kamelets] 02/03: Switch Azure Storage Blob Source from timer producer style to a pure consumer
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-kamelets.git commit fc278c93ab583c67a4e3511b2ce55d0cabcfee70 Author: Andrea Cosentino AuthorDate: Wed Oct 12 14:17:30 2022 +0200 Switch Azure Storage Blob Source from timer producer style to a pure consumer --- kamelets/azure-storage-blob-source.kamelet.yaml | 6 -- 1 file changed, 6 deletions(-) diff --git a/kamelets/azure-storage-blob-source.kamelet.yaml b/kamelets/azure-storage-blob-source.kamelet.yaml index d4ed8cd1..14eee2fb 100644 --- a/kamelets/azure-storage-blob-source.kamelet.yaml +++ b/kamelets/azure-storage-blob-source.kamelet.yaml @@ -33,17 +33,11 @@ spec: description: |- Consume files from Azure Storage Blob. required: - - period - accountName - containerName - accessKey type: object properties: - period: -title: Period between Polls -description: The interval (in milliseconds) between fetches to the Azure Storage Container. -type: integer -default: 1 accountName: title: Account Name description: The Azure Storage Blob account name.
[camel-kamelets] branch main updated (0d1128f2 -> e181e511)
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-kamelets.git from 0d1128f2 Duplicate some of headers with a different name - Azure Storage Queue Source new e57bc823 Switch Azure Storage Blob Source from timer producer style to a pure consumer new fc278c93 Switch Azure Storage Blob Source from timer producer style to a pure consumer new e181e511 Switch Azure Storage Blob Source from timer producer style to a pure consumer 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: kamelets/azure-storage-blob-source.kamelet.yaml| 47 +- .../azure-storage-blob-source.kamelet.yaml | 47 +- 2 files changed, 20 insertions(+), 74 deletions(-)
[camel-kamelets] 03/03: Switch Azure Storage Blob Source from timer producer style to a pure consumer
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-kamelets.git commit e181e511fdc0b640e46d07d25a93b28662b760b8 Author: Andrea Cosentino AuthorDate: Wed Oct 12 14:19:10 2022 +0200 Switch Azure Storage Blob Source from timer producer style to a pure consumer --- .../main/resources/kamelets/azure-storage-blob-source.kamelet.yaml | 6 -- 1 file changed, 6 deletions(-) diff --git a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml index d4ed8cd1..14eee2fb 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml @@ -33,17 +33,11 @@ spec: description: |- Consume files from Azure Storage Blob. required: - - period - accountName - containerName - accessKey type: object properties: - period: -title: Period between Polls -description: The interval (in milliseconds) between fetches to the Azure Storage Container. -type: integer -default: 1 accountName: title: Account Name description: The Azure Storage Blob account name.
[GitHub] [camel-kamelets] oscerd merged pull request #1084: Switch Azure Storage Blob Source from timer producer style to a pure consumer
oscerd merged PR #1084: URL: https://github.com/apache/camel-kamelets/pull/1084 -- This is an automated message from the 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] oscerd closed issue #1083: Azure Storage Blob Source Kamelet: Switch from the current implementation to real consumer
oscerd closed issue #1083: Azure Storage Blob Source Kamelet: Switch from the current implementation to real consumer URL: https://github.com/apache/camel-kamelets/issues/1083 -- This is an automated message from the 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-kamelets] 01/03: Switch Azure Storage Blob Source from timer producer style to a pure consumer
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch azure-storage-blob-source-pure-consumer
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 053478418a5f647665e4dbbd2f2658a2cd1651bf
Author: Andrea Cosentino
AuthorDate: Wed Oct 12 14:07:32 2022 +0200
Switch Azure Storage Blob Source from timer producer style to a pure
consumer
---
kamelets/azure-storage-blob-source.kamelet.yaml| 41 ++
.../azure-storage-blob-source.kamelet.yaml | 41 ++
2 files changed, 20 insertions(+), 62 deletions(-)
diff --git a/kamelets/azure-storage-blob-source.kamelet.yaml
b/kamelets/azure-storage-blob-source.kamelet.yaml
index 01c333c5..d4ed8cd1 100644
--- a/kamelets/azure-storage-blob-source.kamelet.yaml
+++ b/kamelets/azure-storage-blob-source.kamelet.yaml
@@ -75,37 +75,16 @@ spec:
- "camel:timer"
template:
from:
- uri: "timer:azure-storage-blob-stream"
+ uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
parameters:
-period: "{{period}}"
+accessKey: "{{accessKey}}"
+credentialType: "{{credentialType}}"
steps:
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
-operation: "listBlobs"
-accessKey: "{{accessKey}}"
-credentialType: "{{credentialType}}"
- - split:
- jsonpath: "$.*"
- steps:
- - set-property:
- name: azureBlobName
- simple: ${body.name}
- - set-header:
- name: CamelAzureStorageBlobBlobName
- simple: ${exchangeProperty.azureBlobName}
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
-operation: "getBlob"
-accessKey: "{{accessKey}}"
- - to: "kamelet:sink"
- - set-header:
- name: CamelAzureStorageBlobBlobName
- simple: ${exchangeProperty.azureBlobName}
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
-operation: "deleteBlob"
-accessKey: "{{accessKey}}"
+- to: "kamelet:sink"
+- to:
+uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
+parameters:
+ operation: "deleteBlob"
+ accessKey: "{{accessKey}}"
+ credentialType: "{{credentialType}}"
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml
index 01c333c5..d4ed8cd1 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml
@@ -75,37 +75,16 @@ spec:
- "camel:timer"
template:
from:
- uri: "timer:azure-storage-blob-stream"
+ uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
parameters:
-period: "{{period}}"
+accessKey: "{{accessKey}}"
+credentialType: "{{credentialType}}"
steps:
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
-operation: "listBlobs"
-accessKey: "{{accessKey}}"
-credentialType: "{{credentialType}}"
- - split:
- jsonpath: "$.*"
- steps:
- - set-property:
- name: azureBlobName
- simple: ${body.name}
- - set-header:
- name: CamelAzureStorageBlobBlobName
- simple: ${exchangeProperty.azureBlobName}
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
-operation: "getBlob"
-accessKey: "{{accessKey}}"
- - to: "kamelet:sink"
- - set-header:
- name: CamelAzureStorageBlobBlobName
- simple: ${exchangeProperty.azureBlobName}
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
-operation: "deleteBlob"
-accessKey: "{{accessKey}}"
+- to: "kamelet:sink"
+- to:
+uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
+parameters:
+ operation: "deleteBlob"
+ accessKey: "{{accessKey}}"
+ credentialType: "{{credentialType}}"
[camel-kamelets] 03/03: Switch Azure Storage Blob Source from timer producer style to a pure consumer
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch azure-storage-blob-source-pure-consumer in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git commit f977925712aa6209b1dfbabfb0c2737e99f15d80 Author: Andrea Cosentino AuthorDate: Wed Oct 12 14:19:10 2022 +0200 Switch Azure Storage Blob Source from timer producer style to a pure consumer --- .../main/resources/kamelets/azure-storage-blob-source.kamelet.yaml | 6 -- 1 file changed, 6 deletions(-) diff --git a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml index d4ed8cd1..14eee2fb 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml @@ -33,17 +33,11 @@ spec: description: |- Consume files from Azure Storage Blob. required: - - period - accountName - containerName - accessKey type: object properties: - period: -title: Period between Polls -description: The interval (in milliseconds) between fetches to the Azure Storage Container. -type: integer -default: 1 accountName: title: Account Name description: The Azure Storage Blob account name.
[GitHub] [camel-k] phantomjinx commented on a diff in pull request #3423: Minor updates for bundle generation
phantomjinx commented on code in PR #3423: URL: https://github.com/apache/camel-k/pull/3423#discussion_r993383658 ## config/manifests/bases/camel-k.clusterserviceversion.yaml: ## @@ -150,11 +150,11 @@ spec: - email: us...@camel.apache.org name: The Apache Software Foundation maturity: alpha - minKubeVersion: 1.11.0 + minKubeVersion: 1.14.0 Review Comment: Reverted. -- This is an automated message from the 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] oscerd opened a new pull request, #1084: Switch Azure Storage Blob Source from timer producer style to a pure consumer
oscerd opened a new pull request, #1084: URL: https://github.com/apache/camel-kamelets/pull/1084 Fixes #1083 -- This is an automated message from the 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-kamelets] 02/03: Switch Azure Storage Blob Source from timer producer style to a pure consumer
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch azure-storage-blob-source-pure-consumer in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git commit 01f59659a19f0b659571f610bff98c6266f1ad30 Author: Andrea Cosentino AuthorDate: Wed Oct 12 14:17:30 2022 +0200 Switch Azure Storage Blob Source from timer producer style to a pure consumer --- kamelets/azure-storage-blob-source.kamelet.yaml | 6 -- 1 file changed, 6 deletions(-) diff --git a/kamelets/azure-storage-blob-source.kamelet.yaml b/kamelets/azure-storage-blob-source.kamelet.yaml index d4ed8cd1..14eee2fb 100644 --- a/kamelets/azure-storage-blob-source.kamelet.yaml +++ b/kamelets/azure-storage-blob-source.kamelet.yaml @@ -33,17 +33,11 @@ spec: description: |- Consume files from Azure Storage Blob. required: - - period - accountName - containerName - accessKey type: object properties: - period: -title: Period between Polls -description: The interval (in milliseconds) between fetches to the Azure Storage Container. -type: integer -default: 1 accountName: title: Account Name description: The Azure Storage Blob account name.
