[GitHub] [camel-k-runtime] oscerd opened a new pull request #413: Upgrade Jackson to version 2.10.5
oscerd opened a new pull request #413: URL: https://github.com/apache/camel-k-runtime/pull/413 **Release Note** ```release-note NONE ``` This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-k-runtime] branch jackson-2.10.5 created (now 211fc9c)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch jackson-2.10.5 in repository https://gitbox.apache.org/repos/asf/camel-k-runtime.git. at 211fc9c Upgrade Jackson to version 2.10.5 This branch includes the following new commits: new 211fc9c Upgrade Jackson to version 2.10.5 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-k-runtime] 01/01: Upgrade Jackson to version 2.10.5
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch jackson-2.10.5 in repository https://gitbox.apache.org/repos/asf/camel-k-runtime.git commit 211fc9ca1557974bfa1138ca69cd8e96adc7f049 Author: Andrea Cosentino AuthorDate: Fri Jul 31 07:38:43 2020 +0200 Upgrade Jackson to version 2.10.5 --- pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pom.xml b/pom.xml index 0cca9f9..613e919 100644 --- a/pom.xml +++ b/pom.xml @@ -54,7 +54,7 @@ 1.3.72 1.26 2.0-M3-groovy-3.0 -2.10.4 +2.10.5 2.3.0 2.3.0.1 2.8.8
[GitHub] [camel] oscerd commented on pull request #4058: Camel 15349
oscerd commented on pull request #4058: URL: https://github.com/apache/camel/pull/4058#issuecomment-666934212 Thanks for the 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch camel-3.4.x updated: Camel 15349 (#4058) (#4060)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch camel-3.4.x in repository https://gitbox.apache.org/repos/asf/camel.git The following commit(s) were added to refs/heads/camel-3.4.x by this push: new 3dc4d4b Camel 15349 (#4058) (#4060) 3dc4d4b is described below commit 3dc4d4bc684ef76021bc1f4a64911e009a63b49a Author: Andrea Cosentino AuthorDate: Fri Jul 31 07:31:55 2020 +0200 Camel 15349 (#4058) (#4060) * Added function to resolve fully qualified JID for participants Changed the consumer to get the entityBareFrom the resolved participant JID * Fixed formatting issues outlined by sourcecheck Co-authored-by: vindiagram-ng <68953833+vindiagram...@users.noreply.github.com> --- .../java/org/apache/camel/component/xmpp/XmppConsumer.java | 2 +- .../java/org/apache/camel/component/xmpp/XmppEndpoint.java | 14 ++ 2 files changed, 15 insertions(+), 1 deletion(-) diff --git a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java index 37b643c..99be956 100644 --- a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java +++ b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java @@ -95,7 +95,7 @@ public class XmppConsumer extends DefaultConsumer implements IncomingChatMessage } if (endpoint.getRoom() == null) { -privateChat = chatManager.chatWith(JidCreate.entityBareFrom(endpoint.getChatId())); +privateChat = chatManager.chatWith(JidCreate.entityBareFrom(endpoint.resolveParticipant(connection))); } else { // add the presence packet listener to the connection so we only get packets that concerns us // we must add the listener before creating the muc diff --git a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java index baaed9c..8a5cdd6 100644 --- a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java +++ b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java @@ -234,6 +234,20 @@ public class XmppEndpoint extends DefaultEndpoint implements HeaderFilterStrateg return new XMPPTCPConnection(conf); } +/** + * If there is no "@" symbol in the participant, find the service domain + * JID and return the fully qualified JID for the participant as user@server.domain + */ +public String resolveParticipant(XMPPConnection connection) { +String participant = getParticipant(); + +if (participant.indexOf('@', 0) != -1) { +return participant; +} + +return participant + "@" + connection.getXMPPServiceDomain().toString(); +} + /* * If there is no "@" symbol in the room, find the chat service JID and * return fully qualified JID for the room as room@conference.server.domain
[GitHub] [camel] oscerd opened a new pull request #4060: Backport Camel-15349
oscerd opened a new pull request #4060: URL: https://github.com/apache/camel/pull/4060 * Added function to resolve fully qualified JID for participants Changed the consumer to get the entityBareFrom the resolved participant JID * Fixed formatting issues outlined by sourcecheck [ ] Make sure there is a [JIRA issue](https://issues.apache.org/jira/browse/CAMEL) filed for the change (usually before you start working on it). Trivial changes like typos do not require a JIRA issue. Your pull request should address just this issue, without pulling in other changes. [ ] Each commit in the pull request should have a meaningful subject line and body. [ ] If you're unsure, you can format the pull request title like `[CAMEL-XXX] Fixes bug in camel-file component`, where you replace `CAMEL-XXX` with the appropriate JIRA issue. [ ] Write a pull request description that is detailed enough to understand what the pull request does, how, and why. [ ] Run `mvn clean install -Psourcecheck` in your module with source check enabled to make sure basic checks pass and there are no checkstyle violations. A more thorough check will be performed on your pull request automatically. Below are the contribution guidelines: https://github.com/apache/camel/blob/master/CONTRIBUTING.md This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] oscerd merged pull request #4060: Backport Camel-15349
oscerd merged pull request #4060: URL: https://github.com/apache/camel/pull/4060 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch backport-camel-15349 updated (e76138f -> 7dc1a52)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch backport-camel-15349 in repository https://gitbox.apache.org/repos/asf/camel.git. discard e76138f Camel 15349 (#4058) discard 4327c32 Merge branch 'camel-3.4.x' of github.com:apache/camel into camel-3.4.x omit a2c3fa8 Regen and rebuild new 7dc1a52 Camel 15349 (#4058) 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 (e76138f) \ N -- N -- N refs/heads/backport-camel-15349 (7dc1a52) 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:
[camel] 01/01: Camel 15349 (#4058)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch backport-camel-15349 in repository https://gitbox.apache.org/repos/asf/camel.git commit 7dc1a52561fc340f7385c48b43d62b96e6887b0f Author: vindiagram-ng <68953833+vindiagram...@users.noreply.github.com> AuthorDate: Fri Jul 31 01:22:55 2020 -0400 Camel 15349 (#4058) * Added function to resolve fully qualified JID for participants Changed the consumer to get the entityBareFrom the resolved participant JID * Fixed formatting issues outlined by sourcecheck --- .../java/org/apache/camel/component/xmpp/XmppConsumer.java | 2 +- .../java/org/apache/camel/component/xmpp/XmppEndpoint.java | 14 ++ 2 files changed, 15 insertions(+), 1 deletion(-) diff --git a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java index 37b643c..99be956 100644 --- a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java +++ b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java @@ -95,7 +95,7 @@ public class XmppConsumer extends DefaultConsumer implements IncomingChatMessage } if (endpoint.getRoom() == null) { -privateChat = chatManager.chatWith(JidCreate.entityBareFrom(endpoint.getChatId())); +privateChat = chatManager.chatWith(JidCreate.entityBareFrom(endpoint.resolveParticipant(connection))); } else { // add the presence packet listener to the connection so we only get packets that concerns us // we must add the listener before creating the muc diff --git a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java index baaed9c..8a5cdd6 100644 --- a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java +++ b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java @@ -234,6 +234,20 @@ public class XmppEndpoint extends DefaultEndpoint implements HeaderFilterStrateg return new XMPPTCPConnection(conf); } +/** + * If there is no "@" symbol in the participant, find the service domain + * JID and return the fully qualified JID for the participant as user@server.domain + */ +public String resolveParticipant(XMPPConnection connection) { +String participant = getParticipant(); + +if (participant.indexOf('@', 0) != -1) { +return participant; +} + +return participant + "@" + connection.getXMPPServiceDomain().toString(); +} + /* * If there is no "@" symbol in the room, find the chat service JID and * return fully qualified JID for the room as room@conference.server.domain
[camel] branch backport-camel-15349 created (now e76138f)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch backport-camel-15349 in repository https://gitbox.apache.org/repos/asf/camel.git. at e76138f Camel 15349 (#4058) This branch includes the following new commits: new 4327c32 Merge branch 'camel-3.4.x' of github.com:apache/camel into camel-3.4.x new e76138f Camel 15349 (#4058) The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[camel] 02/02: Camel 15349 (#4058)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch backport-camel-15349 in repository https://gitbox.apache.org/repos/asf/camel.git commit e76138f7d1c49fef565010535ac8ebcc79f9277d Author: vindiagram-ng <68953833+vindiagram...@users.noreply.github.com> AuthorDate: Fri Jul 31 01:22:55 2020 -0400 Camel 15349 (#4058) * Added function to resolve fully qualified JID for participants Changed the consumer to get the entityBareFrom the resolved participant JID * Fixed formatting issues outlined by sourcecheck --- .../java/org/apache/camel/component/xmpp/XmppConsumer.java | 2 +- .../java/org/apache/camel/component/xmpp/XmppEndpoint.java | 14 ++ 2 files changed, 15 insertions(+), 1 deletion(-) diff --git a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java index 37b643c..99be956 100644 --- a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java +++ b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java @@ -95,7 +95,7 @@ public class XmppConsumer extends DefaultConsumer implements IncomingChatMessage } if (endpoint.getRoom() == null) { -privateChat = chatManager.chatWith(JidCreate.entityBareFrom(endpoint.getChatId())); +privateChat = chatManager.chatWith(JidCreate.entityBareFrom(endpoint.resolveParticipant(connection))); } else { // add the presence packet listener to the connection so we only get packets that concerns us // we must add the listener before creating the muc diff --git a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java index baaed9c..8a5cdd6 100644 --- a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java +++ b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java @@ -234,6 +234,20 @@ public class XmppEndpoint extends DefaultEndpoint implements HeaderFilterStrateg return new XMPPTCPConnection(conf); } +/** + * If there is no "@" symbol in the participant, find the service domain + * JID and return the fully qualified JID for the participant as user@server.domain + */ +public String resolveParticipant(XMPPConnection connection) { +String participant = getParticipant(); + +if (participant.indexOf('@', 0) != -1) { +return participant; +} + +return participant + "@" + connection.getXMPPServiceDomain().toString(); +} + /* * If there is no "@" symbol in the room, find the chat service JID and * return fully qualified JID for the room as room@conference.server.domain
[camel] 01/02: Merge branch 'camel-3.4.x' of github.com:apache/camel into camel-3.4.x
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch backport-camel-15349 in repository https://gitbox.apache.org/repos/asf/camel.git commit 4327c32eb37a60fe47bb66df269e24c3cef42573 Merge: a2c3fa8 b96cc3b Author: Andrea Cosentino AuthorDate: Fri Jul 31 07:27:12 2020 +0200 Merge branch 'camel-3.4.x' of github.com:apache/camel into camel-3.4.x .../camel/component/rabbitmq/RabbitMQConstants.java | 1 + .../camel/component/rabbitmq/RabbitMQDeclareSupport.java | 5 + .../camel/component/rabbitmq/RabbitMQEndpointTest.java | 16 .../rabbitmq/integration/RabbitMQConsumerIntTest.java| 2 +- 4 files changed, 23 insertions(+), 1 deletion(-)
[GitHub] [camel] oscerd commented on pull request #4058: Camel 15349
oscerd commented on pull request #4058: URL: https://github.com/apache/camel/pull/4058#issuecomment-666930325 Sadly the gh action for backporting doesn't work anymore. Need to dig a bit. Let me do this manually. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch master updated: Camel 15349 (#4058)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git The following commit(s) were added to refs/heads/master by this push: new 2d0a4ed Camel 15349 (#4058) 2d0a4ed is described below commit 2d0a4edc143031e516c276625435310368fac5fa Author: vindiagram-ng <68953833+vindiagram...@users.noreply.github.com> AuthorDate: Fri Jul 31 01:22:55 2020 -0400 Camel 15349 (#4058) * Added function to resolve fully qualified JID for participants Changed the consumer to get the entityBareFrom the resolved participant JID * Fixed formatting issues outlined by sourcecheck --- .../java/org/apache/camel/component/xmpp/XmppConsumer.java | 2 +- .../java/org/apache/camel/component/xmpp/XmppEndpoint.java | 14 ++ 2 files changed, 15 insertions(+), 1 deletion(-) diff --git a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java index 37b643c..99be956 100644 --- a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java +++ b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java @@ -95,7 +95,7 @@ public class XmppConsumer extends DefaultConsumer implements IncomingChatMessage } if (endpoint.getRoom() == null) { -privateChat = chatManager.chatWith(JidCreate.entityBareFrom(endpoint.getChatId())); +privateChat = chatManager.chatWith(JidCreate.entityBareFrom(endpoint.resolveParticipant(connection))); } else { // add the presence packet listener to the connection so we only get packets that concerns us // we must add the listener before creating the muc diff --git a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java index baaed9c..8a5cdd6 100644 --- a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java +++ b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java @@ -234,6 +234,20 @@ public class XmppEndpoint extends DefaultEndpoint implements HeaderFilterStrateg return new XMPPTCPConnection(conf); } +/** + * If there is no "@" symbol in the participant, find the service domain + * JID and return the fully qualified JID for the participant as user@server.domain + */ +public String resolveParticipant(XMPPConnection connection) { +String participant = getParticipant(); + +if (participant.indexOf('@', 0) != -1) { +return participant; +} + +return participant + "@" + connection.getXMPPServiceDomain().toString(); +} + /* * If there is no "@" symbol in the room, find the chat service JID and * return fully qualified JID for the room as room@conference.server.domain
[camel] branch master updated: Fixed CS
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git The following commit(s) were added to refs/heads/master by this push: new aeb9df5 Fixed CS aeb9df5 is described below commit aeb9df5c6dfd825d898b462d1e7ad0cfa93fe745 Author: Claus Ibsen AuthorDate: Fri Jul 31 07:23:33 2020 +0200 Fixed CS --- .../aws/kinesis/KinesisConsumerClosedShardWithSilentTest.java | 4 ++-- .../org/apache/camel/component/aws/kinesis/KinesisConsumerTest.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/components/camel-aws-kinesis/src/test/java/org/apache/camel/component/aws/kinesis/KinesisConsumerClosedShardWithSilentTest.java b/components/camel-aws-kinesis/src/test/java/org/apache/camel/component/aws/kinesis/KinesisConsumerClosedShardWithSilentTest.java index 89fa8c3..f5c6186 100644 --- a/components/camel-aws-kinesis/src/test/java/org/apache/camel/component/aws/kinesis/KinesisConsumerClosedShardWithSilentTest.java +++ b/components/camel-aws-kinesis/src/test/java/org/apache/camel/component/aws/kinesis/KinesisConsumerClosedShardWithSilentTest.java @@ -173,7 +173,7 @@ public class KinesisConsumerClosedShardWithSilentTest { .thenReturn(new GetRecordsResult() .withNextShardIterator("nextShardIterator") .withRecords(new Record().withSequenceNumber("1"), new Record().withSequenceNumber("2")) -); +); int messageCount = undertest.poll(); @@ -197,7 +197,7 @@ public class KinesisConsumerClosedShardWithSilentTest { .withApproximateArrivalTimestamp(new Date(42)) .withPartitionKey(partitionKey) ) -); +); undertest.poll(); diff --git a/components/camel-aws-kinesis/src/test/java/org/apache/camel/component/aws/kinesis/KinesisConsumerTest.java b/components/camel-aws-kinesis/src/test/java/org/apache/camel/component/aws/kinesis/KinesisConsumerTest.java index f9d8812..de531b4 100644 --- a/components/camel-aws-kinesis/src/test/java/org/apache/camel/component/aws/kinesis/KinesisConsumerTest.java +++ b/components/camel-aws-kinesis/src/test/java/org/apache/camel/component/aws/kinesis/KinesisConsumerTest.java @@ -173,7 +173,7 @@ public class KinesisConsumerTest { .thenReturn(new GetRecordsResult() .withNextShardIterator("nextShardIterator") .withRecords(new Record().withSequenceNumber("1"), new Record().withSequenceNumber("2")) -); +); int messageCount = undertest.poll(); @@ -197,7 +197,7 @@ public class KinesisConsumerTest { .withApproximateArrivalTimestamp(new Date(42)) .withPartitionKey(partitionKey) ) -); +); undertest.poll();
[GitHub] [camel] oscerd merged pull request #4058: Camel 15349
oscerd merged pull request #4058: URL: https://github.com/apache/camel/pull/4058 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] 02/02: Sync Properties
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit 8ef5d5a6fff0c069ca87681af4d832bab5b6c8f9 Author: Andrea Cosentino AuthorDate: Fri Jul 31 07:17:42 2020 +0200 Sync Properties --- camel-dependencies/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/camel-dependencies/pom.xml b/camel-dependencies/pom.xml index e2c2715..a2688fc 100644 --- a/camel-dependencies/pom.xml +++ b/camel-dependencies/pom.xml @@ -71,7 +71,7 @@ 4.0.3 1.11.22 1.11.714 -2.13.64 +2.13.65 2.6.1 1.2.14 12.7.0
[camel] branch master updated (09de4fc -> 8ef5d5a)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel.git. from 09de4fc Upgrade checkstyle plugin new d1bc1a3 Upgrade AWS SDK v2 to version 2.13.65 new 8ef5d5a Sync Properties The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: camel-dependencies/pom.xml | 2 +- parent/pom.xml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-)
[camel] 01/02: Upgrade AWS SDK v2 to version 2.13.65
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit d1bc1a3e10cdfb65e158ce07fbd00b8b82170da4 Author: Andrea Cosentino AuthorDate: Fri Jul 31 06:36:10 2020 +0200 Upgrade AWS SDK v2 to version 2.13.65 --- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parent/pom.xml b/parent/pom.xml index 1108e51..080d7cb 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -78,7 +78,7 @@ 1.9.1 4.0.3 1.11.714 -2.13.64 +2.13.65 1.11.22 2.6.1 1.2.14
[camel-kafka-connector] branch master updated: Update tags on github for camel-kafka-connector
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/master by this push: new 798efa2 Update tags on github for camel-kafka-connector 798efa2 is described below commit 798efa2d546b96b0543091975893848109d27428 Author: Claus Ibsen AuthorDate: Fri Jul 31 07:17:36 2020 +0200 Update tags on github for camel-kafka-connector --- .asf.yaml | 8 1 file changed, 8 insertions(+) diff --git a/.asf.yaml b/.asf.yaml new file mode 100644 index 000..f67fd4a --- /dev/null +++ b/.asf.yaml @@ -0,0 +1,8 @@ +github: + description: "Camel Kafka Connector allows you to use all Camel components as Kafka Connect connectors" + homepage: https://camel.apache.org + labels: +- camel +- integration +- kafka +- java \ No newline at end of file
[camel-k-runtime] branch master updated: Update tags on github for camel-k-runtime
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-k-runtime.git The following commit(s) were added to refs/heads/master by this push: new 036e9c1 Update tags on github for camel-k-runtime 036e9c1 is described below commit 036e9c1563f69dd3ea57dac8022329ba8cb8bc63 Author: Claus Ibsen AuthorDate: Fri Jul 31 07:15:33 2020 +0200 Update tags on github for camel-k-runtime --- .asf.yaml | 11 +++ 1 file changed, 11 insertions(+) diff --git a/.asf.yaml b/.asf.yaml new file mode 100644 index 000..8a25305 --- /dev/null +++ b/.asf.yaml @@ -0,0 +1,11 @@ +github: + description: "Apache Camel K runtime" + homepage: https://camel.apache.org + labels: +- camel +- integration +- kubernetes +- serverless +- knative +- openshift +- operator \ No newline at end of file
[camel-karaf] branch master updated: Update tags on github for camel-karaf
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-karaf.git The following commit(s) were added to refs/heads/master by this push: new 4910904 Update tags on github for camel-karaf 4910904 is described below commit 49109044b4b354121686efaa4c639f0663a1ec2e Author: Claus Ibsen AuthorDate: Fri Jul 31 07:12:22 2020 +0200 Update tags on github for camel-karaf --- .asf.yaml | 26 ++ 1 file changed, 26 insertions(+) diff --git a/.asf.yaml b/.asf.yaml new file mode 100644 index 000..6a8dcee --- /dev/null +++ b/.asf.yaml @@ -0,0 +1,26 @@ +# +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the "License"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. +# + +github: + description: "Apache Camel Karaf support" + homepage: https://camel.apache.org + labels: +- camel +- integration +- java +- karaf +- osgi
[camel-spring-boot] branch master updated: Update tags on github for camel-spring-boot
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git The following commit(s) were added to refs/heads/master by this push: new 5345983 Update tags on github for camel-spring-boot 5345983 is described below commit 5345983de68b7e316ddd9356b2ad9bb1572a732a Author: Claus Ibsen AuthorDate: Fri Jul 31 07:10:13 2020 +0200 Update tags on github for camel-spring-boot --- .asf.yaml | 10 +- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/.asf.yaml b/.asf.yaml index 8d78355..b6e8550 100644 --- a/.asf.yaml +++ b/.asf.yaml @@ -15,5 +15,13 @@ # limitations under the License. # +github: + description: "Apache Camel Spring Boot support" + homepage: https://camel.apache.org + labels: +- camel +- integration +- java +- spring-boot notifications: - pullrequests: commits@camel.apache.org \ No newline at end of file + pullrequests: commits@camel.apache.org
[camel-quarkus] branch master updated: Update tags on github for camel-quarkus
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git The following commit(s) were added to refs/heads/master by this push: new 2e04ba4 Update tags on github for camel-quarkus 2e04ba4 is described below commit 2e04ba485062293339a6540dd16eab771bff0e5f Author: Claus Ibsen AuthorDate: Fri Jul 31 07:06:45 2020 +0200 Update tags on github for camel-quarkus --- .asf.yaml | 26 ++ 1 file changed, 26 insertions(+) diff --git a/.asf.yaml b/.asf.yaml new file mode 100644 index 000..1fe41ad --- /dev/null +++ b/.asf.yaml @@ -0,0 +1,26 @@ +# +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the "License"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. +# + +github: + description: "Apache Camel Quarkus support" + homepage: https://camel.apache.org + labels: +- camel +- integration +- java +- quarkus +
[camel] branch master updated: Upgrade checkstyle plugin
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git The following commit(s) were added to refs/heads/master by this push: new 09de4fc Upgrade checkstyle plugin 09de4fc is described below commit 09de4fc67ad7d78106beb2ffa4589079fe2bbab1 Author: Claus Ibsen AuthorDate: Fri Jul 31 06:54:11 2020 +0200 Upgrade checkstyle plugin --- parent/pom.xml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/parent/pom.xml b/parent/pom.xml index 45e51a2..1108e51 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -386,8 +386,8 @@ 2.3 3.0.0 4.2.1 - 3.1.0 -8.26 + 3.1.1 +8.35 5.3.2 3.2.0 3.2.0
[GitHub] [camel-website] AemieJ opened a new pull request #444: CAMEL-15335: update the search layout design
AemieJ opened a new pull request #444: URL: https://github.com/apache/camel-website/pull/444 ### Search Layout Design * Version is separated from the title of the section to keep a neater look and easier to understand the search result. * The borders have been removed as they don't fit in with the theme of the website. * On hovering a particular link, the whole section will give a shade of #f5f5f5 providing a highlighting effect. * Algolia attribute has been at the bottom of the search result. ![search-result](https://user-images.githubusercontent.com/44139348/88996674-7b013880-d30b-11ea-9507-ae401508bfbb.png) * Changed the look for **Nothing found** for no results found on a search query. ![no-result](https://user-images.githubusercontent.com/44139348/88996679-7d639280-d30b-11ea-8468-dd8dda2b469c.png) This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch camel-2.25.x updated: Remove checkstyle check in Jenkinsfile (#4059)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch camel-2.25.x in repository https://gitbox.apache.org/repos/asf/camel.git The following commit(s) were added to refs/heads/camel-2.25.x by this push: new 86c5e51 Remove checkstyle check in Jenkinsfile (#4059) 86c5e51 is described below commit 86c5e5150b9a604bd6deeb9c9301a04ec7068898 Author: Andrea Cosentino AuthorDate: Fri Jul 31 06:48:30 2020 +0200 Remove checkstyle check in Jenkinsfile (#4059) --- Jenkinsfile | 5 - 1 file changed, 5 deletions(-) diff --git a/Jenkinsfile b/Jenkinsfile index a34301d..97f1bf6 100644 --- a/Jenkinsfile +++ b/Jenkinsfile @@ -66,11 +66,6 @@ pipeline { steps { sh "./mvnw $MAVEN_PARAMS -Psourcecheck -Dcheckstyle.failOnViolation=false checkstyle:check" } -post { -always { -checkstyle pattern: '**/checkstyle-result.xml', canRunOnFailed: true -} -} } stage('Test') {
[camel] branch checkstyle-jenkins created (now 77175c4)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch checkstyle-jenkins in repository https://gitbox.apache.org/repos/asf/camel.git. at 77175c4 Remove checkstyle check in Jenkinsfile No new revisions were added by this update.
[GitHub] [camel] oscerd merged pull request #4059: Remove checkstyle check in Jenkinsfile
oscerd merged pull request #4059: URL: https://github.com/apache/camel/pull/4059 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] oscerd opened a new pull request #4059: Remove checkstyle check in Jenkinsfile
oscerd opened a new pull request #4059: URL: https://github.com/apache/camel/pull/4059 [ ] Make sure there is a [JIRA issue](https://issues.apache.org/jira/browse/CAMEL) filed for the change (usually before you start working on it). Trivial changes like typos do not require a JIRA issue. Your pull request should address just this issue, without pulling in other changes. [ ] Each commit in the pull request should have a meaningful subject line and body. [ ] If you're unsure, you can format the pull request title like `[CAMEL-XXX] Fixes bug in camel-file component`, where you replace `CAMEL-XXX` with the appropriate JIRA issue. [ ] Write a pull request description that is detailed enough to understand what the pull request does, how, and why. [ ] Run `mvn clean install -Psourcecheck` in your module with source check enabled to make sure basic checks pass and there are no checkstyle violations. A more thorough check will be performed on your pull request automatically. Below are the contribution guidelines: https://github.com/apache/camel/blob/master/CONTRIBUTING.md This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-quarkus] branch quarkus-master updated (9c000f1 -> 3cde1b2)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch quarkus-master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git. discard 9c000f1 Fix #1403 quarkus-extension-processor race conditions when modules are built in parallel discard 2b1180c Upgrade to Quarkus 1.7.0 - WIP add fa44df0 Fix #1286 Pass deprecation info to quarkus-extension.yaml new 3444a0f Upgrade to Quarkus 1.7.0 - WIP new 3cde1b2 Fix #1403 quarkus-extension-processor race conditions when modules are built in parallel 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 (9c000f1) \ N -- N -- N refs/heads/quarkus-master (3cde1b2) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: docs/modules/ROOT/pages/extensions/ahc-ws.adoc | 2 +- docs/modules/ROOT/pages/extensions/ahc.adoc | 2 +- docs/modules/ROOT/pages/extensions/aws2-ec2.adoc | 2 +- docs/modules/ROOT/pages/extensions/aws2-ecs.adoc | 2 +- docs/modules/ROOT/pages/extensions/aws2-eks.adoc | 2 +- docs/modules/ROOT/pages/extensions/aws2-iam.adoc | 2 +- docs/modules/ROOT/pages/extensions/aws2-kms.adoc | 2 +- docs/modules/ROOT/pages/extensions/aws2-msk.adoc | 2 +- docs/modules/ROOT/pages/extensions/aws2-s3.adoc | 2 +- docs/modules/ROOT/pages/extensions/aws2-ses.adoc | 2 +- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../core/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../main/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../grpc/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../ognl/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ extensions/ahc-ws/deployment/pom.xml | 2 +- extensions/ahc-ws/pom.xml| 2 +- extensions/ahc-ws/runtime/pom.xml| 2 +- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 4 +++- extensions/ahc/deployment/pom.xml| 2 +- extensions/ahc/pom.xml | 2 +- extensions/ahc/runtime/pom.xml | 2 +- .../ahc/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 4 +++- .../amqp/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../avro/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++
[camel-quarkus] 02/02: Fix #1403 quarkus-extension-processor race conditions when modules are built in parallel
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a commit to branch quarkus-master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git commit 3cde1b294ecd2b5c029500c93c8edc10bd4fe950 Author: Peter Palaga AuthorDate: Thu Jun 25 14:35:20 2020 +0200 Fix #1403 quarkus-extension-processor race conditions when modules are built in parallel --- .../quarkus/maven/UpdateExtensionDocPageMojo.java | 22 +++--- 1 file changed, 7 insertions(+), 15 deletions(-) diff --git a/tooling/maven-plugin/src/main/java/org/apache/camel/quarkus/maven/UpdateExtensionDocPageMojo.java b/tooling/maven-plugin/src/main/java/org/apache/camel/quarkus/maven/UpdateExtensionDocPageMojo.java index debe16d..5563e21 100644 --- a/tooling/maven-plugin/src/main/java/org/apache/camel/quarkus/maven/UpdateExtensionDocPageMojo.java +++ b/tooling/maven-plugin/src/main/java/org/apache/camel/quarkus/maven/UpdateExtensionDocPageMojo.java @@ -17,7 +17,6 @@ package org.apache.camel.quarkus.maven; import java.io.IOException; -import java.io.InputStream; import java.io.StringWriter; import java.nio.charset.Charset; import java.nio.charset.StandardCharsets; @@ -29,7 +28,6 @@ import java.util.Collections; import java.util.HashMap; import java.util.List; import java.util.Map; -import java.util.Properties; import java.util.concurrent.ConcurrentHashMap; import java.util.stream.Collectors; import java.util.stream.Stream; @@ -42,6 +40,7 @@ import freemarker.template.TemplateModelException; import io.quarkus.annotation.processor.Constants; import io.quarkus.annotation.processor.generate_doc.ConfigDocItem; import io.quarkus.annotation.processor.generate_doc.DocGeneratorUtil; +import io.quarkus.annotation.processor.generate_doc.FsMap; import org.apache.camel.catalog.Kind; import org.apache.camel.tooling.model.ArtifactModel; import org.apache.camel.tooling.model.BaseModel; @@ -54,8 +53,6 @@ import org.apache.maven.plugins.annotations.Parameter; @Mojo(name = "update-extension-doc-page", threadSafe = true) public class UpdateExtensionDocPageMojo extends AbstractDocGeneratorMojo { -private static List list; -private static List list2; private static final Map nativeSslActivators = new ConcurrentHashMap<>(); @Parameter(defaultValue = "false", property = "camel-quarkus.update-extension-doc-page.skip") @@ -256,25 +253,20 @@ public class UpdateExtensionDocPageMojo extends AbstractDocGeneratorMojo { if (configRootClasses.isEmpty()) { return Collections.emptyList(); } -final Path configRootsModelsPath = multiModuleProjectDirectory - .resolve("target/asciidoc/generated/config/all-configuration-roots-generated-doc.properties"); -if (!Files.exists(configRootsModelsPath)) { +final Path configRootsModelsDir = multiModuleProjectDirectory + .resolve("target/asciidoc/generated/config/all-configuration-roots-generated-doc"); +if (!Files.exists(configRootsModelsDir)) { throw new IllegalStateException("You should run " + UpdateExtensionDocPageMojo.class.getSimpleName() + " after compileation with io.quarkus.annotation.processor.ExtensionAnnotationProcessor"); } -final Properties configRootsModels = new Properties(); -try (InputStream in = Files.newInputStream(configRootsModelsPath)) { -configRootsModels.load(in); -} catch (IOException e) { -throw new RuntimeException("Could not read from " + configRootsModelsPath); -} +final FsMap configRootsModels = new FsMap(configRootsModelsDir); final ObjectMapper mapper = new ObjectMapper(); final List configDocItems = new ArrayList(); for (String configRootClass : configRootClasses) { -final String rawModel = configRootsModels.getProperty(configRootClass); +final String rawModel = configRootsModels.get(configRootClass); if (rawModel == null) { -throw new IllegalStateException("Could not find " + configRootClass + " in " + configRootsModelsPath); +throw new IllegalStateException("Could not find " + configRootClass + " in " + configRootsModelsDir); } try { final List items = mapper.readValue(rawModel, Constants.LIST_OF_CONFIG_ITEMS_TYPE_REF);
[camel-quarkus] 01/02: Upgrade to Quarkus 1.7.0 - WIP
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a commit to branch quarkus-master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git commit 3444a0fa2d391c07ef2e6d2eb9f0715e2430bc39 Author: James Netherton AuthorDate: Mon Jul 6 12:26:55 2020 +0100 Upgrade to Quarkus 1.7.0 - WIP --- extensions/avro/deployment/pom.xml | 4 extensions/avro/runtime/pom.xml | 4 extensions/elasticsearch-rest/deployment/pom.xml | 4 extensions/elasticsearch-rest/runtime/pom.xml| 4 ++-- .../component/elasticsearch/rest/it/ElasticSearchTestResource.java | 4 ++-- pom.xml | 3 +-- poms/bom/pom.xml | 5 - 7 files changed, 17 insertions(+), 11 deletions(-) diff --git a/extensions/avro/deployment/pom.xml b/extensions/avro/deployment/pom.xml index 6194192..048d4ea 100644 --- a/extensions/avro/deployment/pom.xml +++ b/extensions/avro/deployment/pom.xml @@ -31,6 +31,10 @@ +io.quarkus +quarkus-avro-deployment + + org.apache.camel.quarkus camel-quarkus-core-deployment diff --git a/extensions/avro/runtime/pom.xml b/extensions/avro/runtime/pom.xml index 3825e0b..78f9469 100644 --- a/extensions/avro/runtime/pom.xml +++ b/extensions/avro/runtime/pom.xml @@ -47,6 +47,10 @@ +io.quarkus +quarkus-avro + + org.apache.camel.quarkus camel-quarkus-core diff --git a/extensions/elasticsearch-rest/deployment/pom.xml b/extensions/elasticsearch-rest/deployment/pom.xml index c576986..6c712b7 100644 --- a/extensions/elasticsearch-rest/deployment/pom.xml +++ b/extensions/elasticsearch-rest/deployment/pom.xml @@ -35,6 +35,10 @@ quarkus-elasticsearch-rest-client-deployment +io.quarkus + quarkus-elasticsearch-rest-high-level-client-deployment + + org.apache.camel.quarkus camel-quarkus-core-deployment diff --git a/extensions/elasticsearch-rest/runtime/pom.xml b/extensions/elasticsearch-rest/runtime/pom.xml index 5c9ff99..a66ff41 100644 --- a/extensions/elasticsearch-rest/runtime/pom.xml +++ b/extensions/elasticsearch-rest/runtime/pom.xml @@ -51,8 +51,8 @@ quarkus-elasticsearch-rest-client -org.elasticsearch.client -elasticsearch-rest-high-level-client +io.quarkus + quarkus-elasticsearch-rest-high-level-client org.apache.camel.quarkus diff --git a/integration-tests/elasticsearch-rest/src/test/java/org/apache/camel/quarkus/component/elasticsearch/rest/it/ElasticSearchTestResource.java b/integration-tests/elasticsearch-rest/src/test/java/org/apache/camel/quarkus/component/elasticsearch/rest/it/ElasticSearchTestResource.java index e2b42ee..763b5ba 100644 --- a/integration-tests/elasticsearch-rest/src/test/java/org/apache/camel/quarkus/component/elasticsearch/rest/it/ElasticSearchTestResource.java +++ b/integration-tests/elasticsearch-rest/src/test/java/org/apache/camel/quarkus/component/elasticsearch/rest/it/ElasticSearchTestResource.java @@ -30,7 +30,7 @@ import org.testcontainers.utility.TestcontainersConfiguration; public class ElasticSearchTestResource implements QuarkusTestResourceLifecycleManager { private static final Logger LOGGER = LoggerFactory.getLogger(ElasticSearchTestResource.class); -private static final String ELASTICSEARCH_IMAGE = "elasticsearch:7.6.1"; +private static final String ELASTICSEARCH_IMAGE = "elasticsearch:7.7.0"; private static final int ELASTICSEARCH_PORT = 9200; private GenericContainer container; @@ -49,7 +49,7 @@ public class ElasticSearchTestResource implements QuarkusTestResourceLifecycleMa container.start(); return CollectionHelper.mapOf( -"camel.component.elasticsearch-rest.host-addresses", +"quarkus.elasticsearch.hosts", String.format("localhost:%s", container.getMappedPort(ELASTICSEARCH_PORT))); } catch (Exception e) { diff --git a/pom.xml b/pom.xml index 6b24360..32019fb 100644 --- a/pom.xml +++ b/pom.xml @@ -48,7 +48,6 @@ 2.13.33 3.4.2 1.2.0.Final -7.6.1 2.3.30 1.111 1.22.0 @@ -67,7 +66,7 @@ 1.3.72 3.14.6 1.17.2 -1.6.1.Final +999-SNAPSHOT 0.16.0 3.11.1 2.5.0 diff --git a/poms/bom/pom.xml b/poms/bom/pom.xml index b03c9b3..ff125e1 100644 --- a/poms/bom/pom.xml +++ b/poms/bom/pom.xml @@ -3241,11 +3241,6 @@ ${stax2.version}
[GitHub] [camel-website] AemieJ edited a comment on pull request #442: CAMEL-15300: Update Front Page Design
AemieJ edited a comment on pull request #442: URL: https://github.com/apache/camel-website/pull/442#issuecomment-666890383 I would like to suggest a couple of changes - * Include a border-bottom & box-shadow in the navbar to show visible segregation between the body of page and navbar. * Reduce the height of the main image. It's extremely huge. * I would like to see the releases as soon as I land on the page ( in the case of the wider screen width ). * Increase the line spacing between the text below **Apache Camel** on the front page. * Increase the font-size for the complete date within releases. Also the link to **What is Camel?** is [here](https://camel.apache.org/manual/latest/faq/what-is-camel.html). ![frontpage-display](https://user-images.githubusercontent.com/44139348/88995819-41c7c900-d309-11ea-9db8-ce76eef0771e.png) This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] AemieJ edited a comment on pull request #442: CAMEL-15300: Update Front Page Design
AemieJ edited a comment on pull request #442: URL: https://github.com/apache/camel-website/pull/442#issuecomment-666890383 I would like to suggest a couple of changes - * Include a border-bottom & box-shadow in the navbar to show visible segregation between the body of page and navbar. * Reduce the height of the main image. It's extremely huge. * I would like to see the releases as soon as I land on the page ( in the case of the wider screen width ). * Increase the line spacing between the text below **Apache Camel** on the front page. * Increase the font-size for the complete date within releases. Also the link to **What is Camel?** is [here](https://camel.apache.org/manual/latest/faq/what-is-camel.html). ![frontpage-display](https://user-images.githubusercontent.com/44139348/88995819-41c7c900-d309-11ea-9db8-ce76eef0771e.png) This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] AemieJ edited a comment on pull request #438: CAMEL-15329: add the community section page
AemieJ edited a comment on pull request #438: URL: https://github.com/apache/camel-website/pull/438#issuecomment-664785314 @zregvart there is not a requirement to mention the authors of the SVG icons. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] AemieJ commented on a change in pull request #443: CAMEL-15360: fix HTML validation issues
AemieJ commented on a change in pull request #443: URL: https://github.com/apache/camel-website/pull/443#discussion_r463385398 ## File path: antora-ui-camel/src/css/footer.css ## @@ -182,59 +181,45 @@ input[type="checkbox"] { width: auto; } - footer .footer .context a { -font-size: 13.5px; - } - - footer .footer .context a::after { -width: 5px; -height: 5px; - } - footer .footer .footer-icons .brand-icon { height: 1.5rem; } - footer .footer .show-menu { -float: right; -height: 40px; -margin-top: -2.5rem; - } - - footer .footer .hide-menu { -float: right; -height: 35px; -margin-top: -2.5rem; + footer .footer input[type="checkbox"] { +display: inline; +position: relative; +top: 2rem; +left: 45vw; +width: 1.75rem; +height: 1.75rem; +transition: 0.2s; } - footer .footer .footer-menu { -margin-top: 1rem; + footer .footer input[type="checkbox"] { Review comment: Is this meant to be changed as `footer .footer input[type="checkbox"]:checked` as it's defined as the same as class as above and thus the preview is failing for the same? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] AemieJ commented on a change in pull request #443: CAMEL-15360: fix HTML validation issues
AemieJ commented on a change in pull request #443: URL: https://github.com/apache/camel-website/pull/443#discussion_r463385398 ## File path: antora-ui-camel/src/css/footer.css ## @@ -182,59 +181,45 @@ input[type="checkbox"] { width: auto; } - footer .footer .context a { -font-size: 13.5px; - } - - footer .footer .context a::after { -width: 5px; -height: 5px; - } - footer .footer .footer-icons .brand-icon { height: 1.5rem; } - footer .footer .show-menu { -float: right; -height: 40px; -margin-top: -2.5rem; - } - - footer .footer .hide-menu { -float: right; -height: 35px; -margin-top: -2.5rem; + footer .footer input[type="checkbox"] { +display: inline; +position: relative; +top: 2rem; +left: 45vw; +width: 1.75rem; +height: 1.75rem; +transition: 0.2s; } - footer .footer .footer-menu { -margin-top: 1rem; + footer .footer input[type="checkbox"] { Review comment: Is this meant to be changed as `footer .footer input[type="checkbox"]:checked` as it's the same as the stated class as above and thus the preview is failing for the same? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] AemieJ commented on pull request #442: CAMEL-15300: Update Front Page Design
AemieJ commented on pull request #442: URL: https://github.com/apache/camel-website/pull/442#issuecomment-666890383 I would like to suggest a couple of changes - * Include a border-bottom & box-shadow in the navbar to show visible segregation between the body of page and navbar. * Reduce the height of the main image. It's extremely huge. * I would like to see the releases as soon as I land on the page ( in the case of the wider screen width ). * Increase the line spacing between the text below **Apache Camel** on the front page. * Increase the font-size for the complete date within releases. ![frontpage-display](https://user-images.githubusercontent.com/44139348/88995819-41c7c900-d309-11ea-9db8-ce76eef0771e.png) This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] zregvart opened a new pull request #443: CAMEL-15360: fix HTML validation issues
zregvart opened a new pull request #443: URL: https://github.com/apache/camel-website/pull/443 This greatly simplifies the footer design and fixes HTML issues identified by `check:html` script. We're now using Unicode full width plus symbol so we don't need the SVG icons for show/hide menu. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-spring-boot] github-actions[bot] opened a new pull request #126: [Github Actions] Periodic Sync Camel Spring Boot Master Branch
github-actions[bot] opened a new pull request #126: URL: https://github.com/apache/camel-spring-boot/pull/126 Periodic Sync of Camel Spring Boot Master Branch with main Camel Master. see https://github.com/apache/camel-spring-boot/blob/master/.github/workflows/automatic-sync-master.yml This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-spring-boot] branch automatic-periodic-sync updated (a969948 -> 450e6cd)
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 a969948 [create-pull-request] automated change add 1df2ee9 [create-pull-request] automated change add 19700b2 Regen add 450e6cd [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 (a969948) \ N -- N -- N refs/heads/automatic-periodic-sync (450e6cd) 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: .../org/apache/camel/springboot/catalog/components/aws2-s3.json | 4 ++-- .../org/apache/camel/springboot/catalog/components/aws2-sqs.json | 4 ++-- .../camel-aws2-s3-starter/src/main/docs/aws2-s3-starter.adoc | 2 +- .../component/aws2/s3/springboot/AWS2S3ComponentConfiguration.java| 4 +++- docs/modules/ROOT/pages/aws2-s3-starter.adoc | 2 +- 5 files changed, 9 insertions(+), 7 deletions(-)
[GitHub] [camel-k] github-actions[bot] closed issue #674: kamel install not working - Error: cannot find automatically a registry where to push images
github-actions[bot] closed issue #674: URL: https://github.com/apache/camel-k/issues/674 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch master updated: let's hold on using the junit 5.x API
This is an automated email from the ASF dual-hosted git repository. bvahdat pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git The following commit(s) were added to refs/heads/master by this push: new 9ec61d7 let's hold on using the junit 5.x API 9ec61d7 is described below commit 9ec61d7b74f59ecf7e024507d2709a8c18287128 Author: Babak Vahdat AuthorDate: Fri Jul 31 00:29:42 2020 +0200 let's hold on using the junit 5.x API --- .../component/rabbitmq/RabbitMQEndpointTest.java | 20 ++-- .../rabbitmq/integration/RabbitMQInOutIntTest.java | 2 +- 2 files changed, 11 insertions(+), 11 deletions(-) diff --git a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java index 3c4e57d..a5005fa 100644 --- a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java +++ b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java @@ -38,7 +38,6 @@ import org.apache.camel.component.rabbitmq.integration.RabbitMQDeadLetterRouting import org.apache.camel.spi.Registry; import org.apache.camel.support.SimpleRegistry; import org.apache.camel.test.junit5.CamelTestSupport; -import org.junit.Assert; import org.junit.jupiter.api.Test; import org.mockito.Mockito; import org.slf4j.Logger; @@ -48,6 +47,7 @@ import static org.apache.camel.test.junit5.TestSupport.assertIsInstanceOf; import static org.junit.jupiter.api.Assertions.assertArrayEquals; import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertFalse; +import static org.junit.jupiter.api.Assertions.assertNotNull; import static org.junit.jupiter.api.Assertions.assertTrue; public class RabbitMQEndpointTest extends CamelTestSupport { @@ -61,15 +61,15 @@ public class RabbitMQEndpointTest extends CamelTestSupport { protected Registry createCamelRegistry() throws Exception { SimpleRegistry registry = new SimpleRegistry(); -HashMap args = new HashMap<>(); +Map args = new HashMap<>(); args.put("foo", "bar"); registry.bind("args", args); -HashMap moreArgs = new HashMap<>(); +Map moreArgs = new HashMap<>(); moreArgs.put("fizz", "buzz"); registry.bind("moreArgs", moreArgs); -HashMap evenMoreArgs = new HashMap<>(); +Map evenMoreArgs = new HashMap<>(); evenMoreArgs.put("ping", "pong"); registry.bind("evenMoreArgs", evenMoreArgs); @@ -308,12 +308,12 @@ public class RabbitMQEndpointTest extends CamelTestSupport { + "=testKey=me=mypwd=1=1=false" + "=myvhost=true=direct=x-delayed-message", RabbitMQEndpoint.class); -Assert.assertNotNull(endpoint1.getArgs()); -Assert.assertEquals(2, endpoint1.getArgs().size()); -Assert.assertNotNull(endpoint1.getExchangeArgs()); -Assert.assertEquals(1, endpoint1.getExchangeArgs().size()); -Assert.assertNotNull(endpoint1.getQueueArgs()); -Assert.assertEquals(1, endpoint1.getQueueArgs().size()); +assertNotNull(endpoint1.getArgs()); +assertEquals(2, endpoint1.getArgs().size()); +assertNotNull(endpoint1.getExchangeArgs()); +assertEquals(1, endpoint1.getExchangeArgs().size()); +assertNotNull(endpoint1.getQueueArgs()); +assertEquals(1, endpoint1.getQueueArgs().size()); } } diff --git a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/integration/RabbitMQInOutIntTest.java b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/integration/RabbitMQInOutIntTest.java index 605d477..05c7147 100644 --- a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/integration/RabbitMQInOutIntTest.java +++ b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/integration/RabbitMQInOutIntTest.java @@ -79,7 +79,7 @@ public class RabbitMQInOutIntTest extends AbstractRabbitMQIntTest { protected Registry createCamelRegistry() throws Exception { SimpleRegistry reg = new SimpleRegistry(); -HashMap args = new HashMap<>(); +Map args = new HashMap<>(); args.put(RabbitMQConstants.RABBITMQ_QUEUE_TTL_KEY, 6); reg.bind("args", args);
[GitHub] [camel-website] aashnajena opened a new pull request #442: CAMEL 15300: Update Front Page Design
aashnajena opened a new pull request #442: URL: https://github.com/apache/camel-website/pull/442 Changed the front page design for header, functionalities and projects section. I have implemented the design for all three- desktop, tablet and mobile (this may not be perfect as of now) view. As of now, I am featuring the 3 latest blogs from "releases" on the front page. All icons/images are self-made. I remember seeing a "What is Camel?" page somewhere on the website, but I can't find it now. Can someone point me to that page? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-website] zregvart commented on pull request #441: CAMEL-15185: Footer design
zregvart commented on pull request #441: URL: https://github.com/apache/camel-website/pull/441#issuecomment-88422 This is causing [HTML validation issues](https://issues.apache.org/jira/browse/CAMEL-15360), I'll try to fix those now. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] oscerd commented on pull request #343: Set default and doc config properties as private
oscerd commented on pull request #343: URL: https://github.com/apache/camel-kafka-connector/pull/343#issuecomment-666512200 Looking at @orpiske answer this could be reopen and we need to wait for @valdar pov This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] oscerd merged pull request #345: AWS Kinesis test fixes when in remote mode
oscerd merged pull request #345: URL: https://github.com/apache/camel-kafka-connector/pull/345 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-kafka-connector] branch master updated: AWS Kinesis test fixes when in remote mode
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/master by this push: new 61a497e AWS Kinesis test fixes when in remote mode new 94de150 Merge pull request #345 from orpiske/fix-kinesis-qa 61a497e is described below commit 61a497e069df96bd055da62f96a6d6e812c2346c Author: Otavio Rodolfo Piske AuthorDate: Wed Jul 29 13:24:09 2020 +0200 AWS Kinesis test fixes when in remote mode Includes: - Check for the stream presence before creating it - Adjusted the code to use a different stream every test - Removed unused test constants - Removes unecessary sleep after deletion --- .../camel/kafkaconnector/aws/common/AWSCommon.java | 10 --- .../source/CamelSourceAWSKinesisITCase.java| 90 +++--- 2 files changed, 64 insertions(+), 36 deletions(-) diff --git a/tests/itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws/common/AWSCommon.java b/tests/itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws/common/AWSCommon.java index f5abf42..98b2c4e 100644 --- a/tests/itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws/common/AWSCommon.java +++ b/tests/itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws/common/AWSCommon.java @@ -38,20 +38,10 @@ public final class AWSCommon { public static final String DEFAULT_SQS_QUEUE_FOR_SNS = "ckcsns"; /** - * The default SNS queue name used during the tests - */ -public static final String DEFAULT_SNS_QUEUE = "ckc-sns"; - -/** * The default S3 bucket name used during the tests */ public static final String DEFAULT_S3_BUCKET = "ckc-s3"; -/** - * The default Kinesis stream name used during the tests - */ -public static final String DEFAULT_KINESIS_STREAM = "ckc-kin-stream"; - private AWSCommon() { } diff --git a/tests/itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws/kinesis/source/CamelSourceAWSKinesisITCase.java b/tests/itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws/kinesis/source/CamelSourceAWSKinesisITCase.java index 7ed229b..d27bac1 100644 --- a/tests/itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws/kinesis/source/CamelSourceAWSKinesisITCase.java +++ b/tests/itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws/kinesis/source/CamelSourceAWSKinesisITCase.java @@ -27,10 +27,12 @@ import com.amazonaws.AmazonServiceException; import com.amazonaws.services.kinesis.AmazonKinesis; import com.amazonaws.services.kinesis.model.CreateStreamResult; import com.amazonaws.services.kinesis.model.DeleteStreamResult; +import com.amazonaws.services.kinesis.model.DescribeStreamResult; import com.amazonaws.services.kinesis.model.PutRecordsRequest; import com.amazonaws.services.kinesis.model.PutRecordsRequestEntry; import com.amazonaws.services.kinesis.model.PutRecordsResult; -import org.apache.camel.kafkaconnector.aws.common.AWSCommon; +import com.amazonaws.services.kinesis.model.ResourceInUseException; +import com.amazonaws.services.kinesis.model.ResourceNotFoundException; import org.apache.camel.kafkaconnector.aws.services.AWSService; import org.apache.camel.kafkaconnector.aws.services.AWSServiceFactory; import org.apache.camel.kafkaconnector.common.AbstractKafkaTest; @@ -54,9 +56,12 @@ import static org.junit.jupiter.api.Assertions.assertEquals; public class CamelSourceAWSKinesisITCase extends AbstractKafkaTest { @RegisterExtension public static AWSService service = AWSServiceFactory.createKinesisService(); - + private static final Logger LOG = LoggerFactory.getLogger(CamelSourceAWSKinesisITCase.class); +private static final String KINESIS_STREAM_BASE_NAME = "ckc-kin-stream"; +private String streamName; + private AmazonKinesis awsKinesisClient; private volatile int received; @@ -67,13 +72,8 @@ public class CamelSourceAWSKinesisITCase extends AbstractKafkaTest { return new String[] {"camel-aws-kinesis-kafka-connector"}; } - -@BeforeEach -public void setUp() { -awsKinesisClient = service.getClient(); -received = 0; - -CreateStreamResult result = awsKinesisClient.createStream(AWSCommon.DEFAULT_KINESIS_STREAM, 1); +private void doCreateStream() { +CreateStreamResult result = awsKinesisClient.createStream(streamName, 1); if (result.getSdkHttpMetadata().getHttpStatusCode() != 200) { fail("Failed to create the stream"); } else { @@ -81,30 +81,67 @@ public class CamelSourceAWSKinesisITCase extends AbstractKafkaTest { } } -@AfterEach -public void tearDown() { -DeleteStreamResult result = awsKinesisClient.deleteStream(AWSCommon.DEFAULT_KINESIS_STREAM); +private void createStream() { +try { +
[camel] 02/02: Sync Properties
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit 5b1b9c3d3cde4b39e18c2920d8e1d9d8bf7bf3f7 Author: Andrea Cosentino AuthorDate: Thu Jul 30 18:24:55 2020 +0200 Sync Properties --- camel-dependencies/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/camel-dependencies/pom.xml b/camel-dependencies/pom.xml index 832e592..e2c2715 100644 --- a/camel-dependencies/pom.xml +++ b/camel-dependencies/pom.xml @@ -480,7 +480,7 @@ 2.6.0 8.0.0 0.53.0 -0.33.5 +0.33.6 2.3.2 2.2.0 5.9.0
[camel] 01/02: Upgrade Proton J to version 0.33.6
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit f4c7d119cfb3d4c2ef61e0d2633e76f0c7c1432d Author: Andrea Cosentino AuthorDate: Thu Jul 30 18:24:23 2020 +0200 Upgrade Proton J to version 0.33.6 --- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parent/pom.xml b/parent/pom.xml index 38e2eb4..45e51a2 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -465,7 +465,7 @@ 4.25.0 2.6.0 8.0.0 -0.33.5 +0.33.6 0.53.0 2.3.2 2.2.0
[camel] branch master updated (b01f79a -> 5b1b9c3)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel.git. from b01f79a CAMEL-15359 - Added docs for Opentelemetry new f4c7d11 Upgrade Proton J to version 0.33.6 new 5b1b9c3 Sync Properties The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: camel-dependencies/pom.xml | 2 +- parent/pom.xml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-)
[camel] 03/03: CAMEL-15359 - Added docs for Opentelemetry
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit b01f79aee7c844226c6eb9e1c6df16398a3f1c54 Author: Andrea Cosentino AuthorDate: Thu Jul 30 18:23:48 2020 +0200 CAMEL-15359 - Added docs for Opentelemetry --- .../org/apache/camel/catalog/docs/opentelemetry.adoc| 15 +++ .../src/main/docs/opentelemetry.adoc| 15 +++ docs/components/modules/others/pages/opentelemetry.adoc | 17 + 3 files changed, 47 insertions(+) diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/opentelemetry.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/opentelemetry.adoc new file mode 100644 index 000..22ebed0 --- /dev/null +++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/opentelemetry.adoc @@ -0,0 +1,15 @@ +[[opentelemetry-component]] += OpenTelemetry Component +:docTitle: OpenTelemetry +:artifactId: camel-opentelemetry +:description: Distributed tracing using OpenTelemetry +:since: 3.5 +:supportLevel: Preview + +*Since Camel {since}* + +The OpenTelemetry component is used for tracing and timing incoming and +outgoing Camel messages using https://opentelemetry.io/[OpenTelemetry]. + +Events (spans) are captured for incoming and outgoing messages being sent +to/from Camel. diff --git a/components/camel-opentelemetry/src/main/docs/opentelemetry.adoc b/components/camel-opentelemetry/src/main/docs/opentelemetry.adoc new file mode 100644 index 000..22ebed0 --- /dev/null +++ b/components/camel-opentelemetry/src/main/docs/opentelemetry.adoc @@ -0,0 +1,15 @@ +[[opentelemetry-component]] += OpenTelemetry Component +:docTitle: OpenTelemetry +:artifactId: camel-opentelemetry +:description: Distributed tracing using OpenTelemetry +:since: 3.5 +:supportLevel: Preview + +*Since Camel {since}* + +The OpenTelemetry component is used for tracing and timing incoming and +outgoing Camel messages using https://opentelemetry.io/[OpenTelemetry]. + +Events (spans) are captured for incoming and outgoing messages being sent +to/from Camel. diff --git a/docs/components/modules/others/pages/opentelemetry.adoc b/docs/components/modules/others/pages/opentelemetry.adoc new file mode 100644 index 000..200f406 --- /dev/null +++ b/docs/components/modules/others/pages/opentelemetry.adoc @@ -0,0 +1,17 @@ +[[opentelemetry-component]] += OpenTelemetry Component +//THIS FILE IS COPIED: EDIT THE SOURCE FILE: +:page-source: components/camel-opentelemetry/src/main/docs/opentelemetry.adoc +:docTitle: OpenTelemetry +:artifactId: camel-opentelemetry +:description: Distributed tracing using OpenTelemetry +:since: 3.5 +:supportLevel: Preview + +*Since Camel {since}* + +The OpenTelemetry component is used for tracing and timing incoming and +outgoing Camel messages using https://opentelemetry.io/[OpenTelemetry]. + +Events (spans) are captured for incoming and outgoing messages being sent +to/from Camel.
[camel] 01/03: Upgrade Qpid JMS client to version 0.53.0
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit 7e16bf04c7af359ab198e31f0c75fc22a3cd064f Author: Andrea Cosentino AuthorDate: Thu Jul 30 17:47:39 2020 +0200 Upgrade Qpid JMS client to version 0.53.0 --- parent/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parent/pom.xml b/parent/pom.xml index 33d960b..38e2eb4 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -466,7 +466,7 @@ 2.6.0 8.0.0 0.33.5 -0.52.0 +0.53.0 2.3.2 2.2.0 5.9.0
[camel] 02/03: Sync Properties and regen catalog
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit 4d9a728deee890904a9b76bb551e6f58fce0a881 Author: Andrea Cosentino AuthorDate: Thu Jul 30 18:23:13 2020 +0200 Sync Properties and regen catalog --- camel-dependencies/pom.xml | 2 +- .../org/apache/camel/catalog/docs.properties | 1 + .../camel/catalog/docs/arangodb-component.adoc | 2 + .../camel/catalog/docs/aws2-sqs-component.adoc | 17 +++- .../catalog/docs/kubernetes-job-component.adoc | 111 + docs/components/modules/others/nav.adoc| 1 + 6 files changed, 130 insertions(+), 4 deletions(-) diff --git a/camel-dependencies/pom.xml b/camel-dependencies/pom.xml index 66adfea..832e592 100644 --- a/camel-dependencies/pom.xml +++ b/camel-dependencies/pom.xml @@ -479,7 +479,7 @@ 4.25.0 2.6.0 8.0.0 -0.52.0 +0.53.0 0.33.5 2.3.2 2.2.0 diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs.properties b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs.properties index 4d80a22..a866c73 100644 --- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs.properties +++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs.properties @@ -361,6 +361,7 @@ openstack-neutron-component openstack-nova-component openstack-summary openstack-swift-component +opentelemetry opentracing optaplanner-component otherwise-eip diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/arangodb-component.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/arangodb-component.adoc index 9b0be1a..d883a0d 100644 --- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/arangodb-component.adoc +++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/arangodb-component.adoc @@ -93,3 +93,5 @@ with the following path and query parameters: | *user* (security) | user if user and/or password different from default | | String |=== // endpoint options: END + +include::camel-spring-boot::page$arangodb-starter.adoc[] diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-sqs-component.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-sqs-component.adoc index 40693c5..19b69b7 100644 --- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-sqs-component.adoc +++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-sqs-component.adoc @@ -351,7 +351,7 @@ from("direct:start") .to("aws2-sqs://camel-1?accessKey=RAW(xxx)=RAW(xxx)=EU_WEST_1"); -- -As result you'll get an exchange containing a `SendMessageBatchResult` instance, that you can examinate to check what messages were successfull and what not. +As result you'll get an exchange containing a `SendMessageBatchResponse` instance, that you can examinate to check what messages were successfull and what not. The id set on each message of the batch will be a Random UUID. == Delete single Message @@ -365,7 +365,7 @@ from("direct:start") .to("aws2-sqs://camel-1?accessKey=RAW(xxx)=RAW(xxx)=EU_WEST_1"); -- -As result you'll get an exchange containing a `DeleteMessageResult` instance, that you can use to check if the message was deleted or not. +As result you'll get an exchange containing a `DeleteMessageResponse` instance, that you can use to check if the message was deleted or not. == List Queues @@ -376,7 +376,18 @@ from("direct:start") .setHeader(SqsConstants.SQS_OPERATION, constant("listQueues")).to("aws2-sqs://camel-1?accessKey=RAW(xxx)=RAW(xxx)=EU_WEST_1"); -- -As result you'll get an exchange containing a `ListQueuesResult` instance, that you can examinate to check the actual queues. +As result you'll get an exchange containing a `ListQueuesResponse` instance, that you can examinate to check the actual queues. + +== Purge Queue + +Use purgeQueue operation to purge queue. + +-- +from("direct:start") + .setHeader(SqsConstants.SQS_OPERATION, constant("purgeQueue")).to("aws2-sqs://camel-1?accessKey=RAW(xxx)=RAW(xxx)=EU_WEST_1"); +-- + +As result you'll get an exchange containing a `PurgeQueueResponse`
[camel] branch master updated (489b837 -> b01f79a)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel.git. from 489b837 CAMEL-15355: camel-rabbitmq fix arg.queue.x-single-active-consumer to be configured as boolean type for RabbitMQ to make it work. Thanks to Devansh Arora for reporting and suggested fix. new 7e16bf0 Upgrade Qpid JMS client to version 0.53.0 new 4d9a728 Sync Properties and regen catalog new b01f79a CAMEL-15359 - Added docs for Opentelemetry The 3 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: camel-dependencies/pom.xml | 2 +- .../org/apache/camel/catalog/docs.properties | 1 + .../camel/catalog/docs/arangodb-component.adoc | 2 + .../camel/catalog/docs/aws2-sqs-component.adoc | 17 +++- .../catalog/docs/kubernetes-job-component.adoc | 111 + .../apache/camel/catalog/docs/opentelemetry.adoc | 15 +++ .../src/main/docs/opentelemetry.adoc | 15 +++ docs/components/modules/others/nav.adoc| 1 + .../modules/others/pages/opentelemetry.adoc| 17 parent/pom.xml | 2 +- 10 files changed, 178 insertions(+), 5 deletions(-) create mode 100644 catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/opentelemetry.adoc create mode 100644 components/camel-opentelemetry/src/main/docs/opentelemetry.adoc create mode 100644 docs/components/modules/others/pages/opentelemetry.adoc
[camel-quarkus] branch camel-master updated (f63b185 -> 96f635c)
This is an automated email from the ASF dual-hosted git repository. ppalaga pushed a change to branch camel-master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git. omit f63b185 Upgrade to Camel 3.5.0-SNAPSHOT add 7015fc4 Correct bind type for OpenTracingTracer bean add 36c04ab Remove service exclude for ThreadPoolProfileConfigurationProperties add 72bc9bb Fixup #1244 Improve the docs about the default REST transport provider add 7a5a5b7 Added grok support #1466 new 96f635c Upgrade to Camel 3.5.0-SNAPSHOT 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 (f63b185) \ N -- N -- N refs/heads/camel-master (96f635c) 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: .../extensions/{openapi-java.adoc => grok.adoc}| 12 +- docs/modules/ROOT/pages/extensions/rest.adoc | 23 +++- .../pages/list-of-camel-quarkus-extensions.adoc| 4 +- .../quarkus/core/deployment/CamelProcessor.java| 6 - .../org/apache/camel/quarkus/main/CamelMain.java | 17 +++ extensions-jvm/cassandraql/runtime/pom.xml | 16 +++ .../grok/deployment/pom.xml| 14 +-- .../component/grok/deployment/GrokProcessor.java} | 13 +- extensions/{jpa => grok}/pom.xml | 4 +- .../couchbase => extensions/grok}/runtime/pom.xml | 15 ++- .../main/resources/META-INF/quarkus-extension.yaml | 6 +- .../deployment/OpenTracingProcessor.java | 6 +- extensions/pom.xml | 1 + .../rest/runtime/src/main/doc/configuration.adoc | 23 +++- integration-tests/{mock => grok}/pom.xml | 24 ++-- .../quarkus/component/grok/it/GrokResource.java| 136 + .../camel/quarkus/component/grok/it/GrokRoute.java | 58 + .../camel/quarkus/component/grok/it/GrokIT.java} | 4 +- .../camel/quarkus/component/grok/it/GrokTest.java | 118 ++ integration-tests/pom.xml | 1 + pom.xml| 2 +- poms/bom/pom.xml | 25 tooling/scripts/test-categories.yaml | 1 + 23 files changed, 472 insertions(+), 57 deletions(-) copy docs/modules/ROOT/pages/extensions/{openapi-java.adoc => grok.adoc} (64%) copy tooling/create-extension-templates/deployment-pom.xml => extensions/grok/deployment/pom.xml (84%) copy extensions/{kudu/deployment/src/main/java/org/apache/camel/quarkus/component/kudu/deployment/KuduProcessor.java => grok/deployment/src/main/java/org/apache/camel/quarkus/component/grok/deployment/GrokProcessor.java} (74%) copy extensions/{jpa => grok}/pom.xml (94%) copy {extensions-jvm/couchbase => extensions/grok}/runtime/pom.xml (84%) copy {extensions-core/core-cloud => extensions/grok}/runtime/src/main/resources/META-INF/quarkus-extension.yaml (89%) copy integration-tests/{mock => grok}/pom.xml (88%) create mode 100644 integration-tests/grok/src/main/java/org/apache/camel/quarkus/component/grok/it/GrokResource.java create mode 100644 integration-tests/grok/src/main/java/org/apache/camel/quarkus/component/grok/it/GrokRoute.java copy integration-tests/{csv/src/test/java/org/apache/camel/quarkus/component/csv/it/CsvIT.java => grok/src/test/java/org/apache/camel/quarkus/component/grok/it/GrokIT.java} (91%) create mode 100644 integration-tests/grok/src/test/java/org/apache/camel/quarkus/component/grok/it/GrokTest.java
[camel-quarkus] 01/01: Upgrade to Camel 3.5.0-SNAPSHOT
This is an automated email from the ASF dual-hosted git repository. ppalaga pushed a commit to branch camel-master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git commit 96f635c6aee7e7975c81300f9cfce052851dd21a Author: James Netherton AuthorDate: Thu Jun 18 16:30:49 2020 +0100 Upgrade to Camel 3.5.0-SNAPSHOT --- docs/modules/ROOT/pages/extensions/aws-s3.adoc | 2 +- docs/modules/ROOT/pages/extensions/aws2-s3.adoc| 2 +- docs/modules/ROOT/pages/extensions/azure.adoc | 4 +- .../pages/list-of-camel-quarkus-extensions.adoc| 10 +-- .../org/apache/camel/quarkus/core/BaseModel.java | 87 ++ .../core/DisabledXMLRoutesDefinitionLoader.java| 5 ++ .../camel/quarkus/core/FastCamelContext.java | 41 ++ .../org/apache/camel/quarkus/main/CamelMain.java | 17 + .../quarkus/main/CamelMainRoutesCollector.java | 26 +++ extensions-jvm/cassandraql/runtime/pom.xml | 16 .../deployment/DebeziumSupportProcessor.java | 14 +++- .../runtime/support/CustomRoutesCollector.java | 7 ++ pom.xml| 10 +-- poms/bom/pom.xml | 10 +++ 14 files changed, 234 insertions(+), 17 deletions(-) diff --git a/docs/modules/ROOT/pages/extensions/aws-s3.adoc b/docs/modules/ROOT/pages/extensions/aws-s3.adoc index 643d7fc..3d26d63 100644 --- a/docs/modules/ROOT/pages/extensions/aws-s3.adoc +++ b/docs/modules/ROOT/pages/extensions/aws-s3.adoc @@ -7,7 +7,7 @@ [.badges] [.badge-key]##Since Camel Quarkus##[.badge-version]##0.2.0## [.badge-key]##JVM##[.badge-supported]##supported## [.badge-key]##Native##[.badge-supported]##supported## -Store and retrie objects from AWS S3 Storage Service. +Store and retrieve objects from AWS S3 Storage Service. == What's inside diff --git a/docs/modules/ROOT/pages/extensions/aws2-s3.adoc b/docs/modules/ROOT/pages/extensions/aws2-s3.adoc index e69b401..d9aadc0 100644 --- a/docs/modules/ROOT/pages/extensions/aws2-s3.adoc +++ b/docs/modules/ROOT/pages/extensions/aws2-s3.adoc @@ -7,7 +7,7 @@ [.badges] [.badge-key]##Since Camel Quarkus##[.badge-version]##1.0.0-M7## [.badge-key]##JVM##[.badge-supported]##supported## [.badge-key]##Native##[.badge-supported]##supported## -Store and retrie objects from AWS S3 Storage Service using AWS SDK version 2.x. +Store and retrieve objects from AWS S3 Storage Service using AWS SDK version 2.x. == What's inside diff --git a/docs/modules/ROOT/pages/extensions/azure.adoc b/docs/modules/ROOT/pages/extensions/azure.adoc index 7be91ed..2606754 100644 --- a/docs/modules/ROOT/pages/extensions/azure.adoc +++ b/docs/modules/ROOT/pages/extensions/azure.adoc @@ -11,8 +11,8 @@ Store and retrieve blobs from Azure Storage Blob Service or store and retrieve m == What's inside -* https://camel.apache.org/components/latest/azure-blob-component.html[Azure Storage Blob Service (Legacy) component], URI syntax: `azure-blob:containerOrBlobUri` -* https://camel.apache.org/components/latest/azure-queue-component.html[Azure Storage Queue Service (Legacy) component], URI syntax: `azure-queue:containerAndQueueUri` +* https://camel.apache.org/components/latest/azure-blob-component.html[Azure Storage Blob Service (Deprecated) component], URI syntax: `azure-blob:containerOrBlobUri` +* https://camel.apache.org/components/latest/azure-queue-component.html[Azure Storage Queue Service (Deprecated) component], URI syntax: `azure-queue:containerAndQueueUri` Please refer to the above links for usage and configuration details. diff --git a/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc b/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc index a2e0a2c..70b1ab8 100644 --- a/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc +++ b/docs/modules/ROOT/pages/list-of-camel-quarkus-extensions.adoc @@ -18,7 +18,7 @@ In case you are missing some Camel feature in the list: == Camel Components // components: START -Number of Camel components: 155 in 120 JAR artifacts (0 deprecated) +Number of Camel components: 155 in 120 JAR artifacts (2 deprecated) [width="100%",cols="4,1,1,1,5",options="header"] |=== @@ -56,7 +56,7 @@ Number of Camel components: 155 in 120 JAR artifacts (0 deprecated) | xref:extensions/aws2-mq.adoc[AWS 2 MQ] | camel-quarkus-aws2-mq | Native + Stable | 1.0.0-M6 | Manage AWS MQ instances using AWS SDK version 2.x. -| xref:extensions/aws2-s3.adoc[AWS 2 S3 Storage Service] | camel-quarkus-aws2-s3 | Native + Stable | 1.0.0-M7 | Store and retrie objects from AWS S3 Storage Service using AWS SDK version 2.x. +| xref:extensions/aws2-s3.adoc[AWS 2 S3 Storage Service] | camel-quarkus-aws2-s3 | Native + Stable | 1.0.0-M7 | Store and retrieve objects from AWS S3 Storage Service using AWS SDK version 2.x. | xref:extensions/aws2-ses.adoc[AWS 2 Simple Email Service (SES)] | camel-quarkus-aws2-ses | Native + Stable | 1.0.0-M6 |
[GitHub] [camel-kafka-connector] orpiske opened a new pull request #345: AWS Kinesis test fixes when in remote mode
orpiske opened a new pull request #345: URL: https://github.com/apache/camel-kafka-connector/pull/345 Includes: - Check for the stream presence before creating it - Adjusted the code to use a different stream every test - Removed unused test constants - Removes unecessary sleep after deletion This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] davsclaus commented on pull request #4058: Camel 15349
davsclaus commented on pull request #4058: URL: https://github.com/apache/camel/pull/4058#issuecomment-666428249 Thanks for the PR. As @oscerd says then the code formatting need a little which you can run with mvn compile -P sourcecheck in the camel-xmpp folder. Then fix those errors reported and push to 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] ppalaga closed issue #1286: Pass deprecation info to quarkus-extension.yaml
ppalaga closed issue #1286: URL: https://github.com/apache/camel-quarkus/issues/1286 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] ppalaga merged pull request #1485: Fix #1286 Pass deprecation info to quarkus-extension.yaml
ppalaga merged pull request #1485: URL: https://github.com/apache/camel-quarkus/pull/1485 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-quarkus] branch master updated: Fix #1286 Pass deprecation info to quarkus-extension.yaml
This is an automated email from the ASF dual-hosted git repository. ppalaga pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git The following commit(s) were added to refs/heads/master by this push: new fa44df0 Fix #1286 Pass deprecation info to quarkus-extension.yaml fa44df0 is described below commit fa44df0b10c7902e867d879c65ee5c930f277645 Author: Peter Palaga AuthorDate: Fri Jul 17 12:08:02 2020 +0200 Fix #1286 Pass deprecation info to quarkus-extension.yaml --- docs/modules/ROOT/pages/extensions/ahc-ws.adoc | 2 +- docs/modules/ROOT/pages/extensions/ahc.adoc | 2 +- docs/modules/ROOT/pages/extensions/aws2-ec2.adoc | 2 +- docs/modules/ROOT/pages/extensions/aws2-ecs.adoc | 2 +- docs/modules/ROOT/pages/extensions/aws2-eks.adoc | 2 +- docs/modules/ROOT/pages/extensions/aws2-iam.adoc | 2 +- docs/modules/ROOT/pages/extensions/aws2-kms.adoc | 2 +- docs/modules/ROOT/pages/extensions/aws2-msk.adoc | 2 +- docs/modules/ROOT/pages/extensions/aws2-s3.adoc | 2 +- docs/modules/ROOT/pages/extensions/aws2-ses.adoc | 2 +- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../core/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../main/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../grpc/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../ognl/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 3 ++- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ extensions/ahc-ws/deployment/pom.xml | 2 +- extensions/ahc-ws/pom.xml| 2 +- extensions/ahc-ws/runtime/pom.xml| 2 +- .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 4 +++- extensions/ahc/deployment/pom.xml| 2 +- extensions/ahc/pom.xml | 2 +- extensions/ahc/runtime/pom.xml | 2 +- .../ahc/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 4 +++- .../amqp/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../avro/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++ .../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 2 ++
[GitHub] [camel] vindiagram-ng opened a new pull request #4058: Camel 15349
vindiagram-ng opened a new pull request #4058: URL: https://github.com/apache/camel/pull/4058 Updated the XmppConsumer to "chatWith" the Participant instead of the ChatId. This solves an error when configuring a route to consume from a participant with a domain id and without a room defined the call to 'JidCreate.entityBareFrom(endpoint.getChatId())' would throw and exception because of the ill-formed JID returned by getChatId. Added a function to XmppEndpoint to resolved the Fully qualified JID of the configured participant. This function when used by the XmppConsumer for direct chats will allow route participants to be defined without their domain and assume the domain of the server being connected too. This solves an error when configuring a route to consume from a participant without a domain id and without a room defined the call to 'JidCreate.entityBareFrom(endpoint.getChatId())' would throw and exception because of the ill-formed JID returned by getChatId. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-examples] branch camel-3.4.x updated: [CAMEL-15357]Add example for Karaf to demonstrate how REST endpoint using servlet secured by Karaf JAAS service
This is an automated email from the ASF dual-hosted git repository. ffang pushed a commit to branch camel-3.4.x in repository https://gitbox.apache.org/repos/asf/camel-examples.git The following commit(s) were added to refs/heads/camel-3.4.x by this push: new 50b843e [CAMEL-15357]Add example for Karaf to demonstrate how REST endpoint using servlet secured by Karaf JAAS service 50b843e is described below commit 50b843e2af3803e3c8399cccdfe133f318f41db2 Author: Freeman Fang AuthorDate: Thu Jul 30 10:17:39 2020 -0400 [CAMEL-15357]Add example for Karaf to demonstrate how REST endpoint using servlet secured by Karaf JAAS service (cherry picked from commit 3ebb9a9ac0b436510a9cbc7ef932620b6768) --- .../README.adoc| 90 + .../camel-example-servlet-rest-karaf-jaas/pom.xml | 109 +++ .../java/org/apache/camel/example/rest/User.java | 47 + .../org/apache/camel/example/rest/UserService.java | 63 +++ .../src/main/resources/META-INF/LICENSE.txt| 203 + .../src/main/resources/META-INF/NOTICE.txt | 11 ++ .../main/resources/OSGI-INF/blueprint/camel.xml| 81 .../src/main/resources/log4j2.properties | 23 +++ .../org.ops4j.pax.web.context-camelrestdsl.cfg | 7 + examples/pom.xml | 1 + 10 files changed, 635 insertions(+) diff --git a/examples/camel-example-servlet-rest-karaf-jaas/README.adoc b/examples/camel-example-servlet-rest-karaf-jaas/README.adoc new file mode 100644 index 000..d4e7e67 --- /dev/null +++ b/examples/camel-example-servlet-rest-karaf-jaas/README.adoc @@ -0,0 +1,90 @@ +== Camel Servlet REST and Karaf Jaas example + +=== Introduction + +This example shows how to use Servlet REST to define REST endpoints in Camel routes using the Rest DSL. REST endpoint protected by Basic Auth, delegate user/password authentication to Karaf Jaas Service + +=== Build + +You will need to compile this example first: + + +mvn install + + +=== Copy security configuration file +copy src/main/resources/org.ops4j.pax.web.context-camelrestdsl.cfg +to $KARAF_HOME/etc folder + +=== Run + +To install Apache Camel in Karaf you type in the shell (we use version +$\{camel.version}): + + +feature:repo-add camel ${camel.version} +feature:install camel + + +First you need to install the following features in Karaf/ServiceMix +with: + + +feature:install camel-servlet +feature:install camel-jackson +feature:install war + + +Then you can install the Camel example: + + +install -s mvn:org.apache.camel.example/camel-example-servlet-rest-karaf-jaas/${camel.version} + + +And you can see the application running by tailing the logs + + +log:tail + + +And you can use ctrl+c to stop tailing the log. + +There is a user REST service that supports the following operations + +* GET /user/\{id} - to view a user with the given id +* GET /user/final - to view all users +* PUT /user - to update/create an user + +The view operations are HTTP GET, and update is using HTTP PUT. + +From a web browser you can access the first two services using the +following links(need to input karaf/karaf as user/password in the pop up dialog) + + + http://localhost:8181/camel-example-servlet-rest-blueprint/rest/user/123 - to view the user with id 123 + http://localhost:8181/camel-example-servlet-rest-blueprint/rest/user/findAll - to list all users + + +From the command shell you can use curl to access the service as shown +below: + + +curl -X GET -H "Accept: application/json" --basic -u karaf:karaf http://localhost:8181/camel-example-servlet-rest-blueprint/rest/user/123 +curl -X GET -H "Accept: application/json" --basic -u karaf:karaf http://localhost:8181/camel-example-servlet-rest-blueprint/rest/user/findAll +curl -X PUT -d "{ \"id\": 666, \"name\": \"The devil\"}" -H "Accept: application/json" --basic -u karaf:karaf http://localhost:8181/camel-example-servlet-rest-blueprint/rest/user + + +=== Configuration + +This example is implemented in XML DSL in the +`+src/main/resources/OSGI-INF/blueprint/camel.xml+` file. + +=== Help and contributions + +If you hit any problem using Camel or have some feedback, then please +https://camel.apache.org/support.html[let us know]. + +We also love contributors, so +https://camel.apache.org/contributing.html[get involved] :-) + +The Camel riders! diff --git a/examples/camel-example-servlet-rest-karaf-jaas/pom.xml b/examples/camel-example-servlet-rest-karaf-jaas/pom.xml new file mode 100644 index 000..1b62472 --- /dev/null +++ b/examples/camel-example-servlet-rest-karaf-jaas/pom.xml @@ -0,0 +1,109 @@ + + +http://maven.apache.org/POM/4.0.0; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance; xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd;> + +4.0.0 + + +org.apache.camel.example +
[camel-examples] branch master updated: [CAMEL-15357]Add example for Karaf to demonstrate how REST endpoint using servlet secured by Karaf JAAS service
This is an automated email from the ASF dual-hosted git repository. ffang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-examples.git The following commit(s) were added to refs/heads/master by this push: new 3ebb9af [CAMEL-15357]Add example for Karaf to demonstrate how REST endpoint using servlet secured by Karaf JAAS service 3ebb9af is described below commit 3ebb9a9ac0b436510a9cbc7ef932620b6768 Author: Freeman Fang AuthorDate: Thu Jul 30 10:17:39 2020 -0400 [CAMEL-15357]Add example for Karaf to demonstrate how REST endpoint using servlet secured by Karaf JAAS service --- .../README.adoc| 90 + .../camel-example-servlet-rest-karaf-jaas/pom.xml | 109 +++ .../java/org/apache/camel/example/rest/User.java | 47 + .../org/apache/camel/example/rest/UserService.java | 63 +++ .../src/main/resources/META-INF/LICENSE.txt| 203 + .../src/main/resources/META-INF/NOTICE.txt | 11 ++ .../main/resources/OSGI-INF/blueprint/camel.xml| 81 .../src/main/resources/log4j2.properties | 23 +++ .../org.ops4j.pax.web.context-camelrestdsl.cfg | 7 + examples/pom.xml | 1 + 10 files changed, 635 insertions(+) diff --git a/examples/camel-example-servlet-rest-karaf-jaas/README.adoc b/examples/camel-example-servlet-rest-karaf-jaas/README.adoc new file mode 100644 index 000..d4e7e67 --- /dev/null +++ b/examples/camel-example-servlet-rest-karaf-jaas/README.adoc @@ -0,0 +1,90 @@ +== Camel Servlet REST and Karaf Jaas example + +=== Introduction + +This example shows how to use Servlet REST to define REST endpoints in Camel routes using the Rest DSL. REST endpoint protected by Basic Auth, delegate user/password authentication to Karaf Jaas Service + +=== Build + +You will need to compile this example first: + + +mvn install + + +=== Copy security configuration file +copy src/main/resources/org.ops4j.pax.web.context-camelrestdsl.cfg +to $KARAF_HOME/etc folder + +=== Run + +To install Apache Camel in Karaf you type in the shell (we use version +$\{camel.version}): + + +feature:repo-add camel ${camel.version} +feature:install camel + + +First you need to install the following features in Karaf/ServiceMix +with: + + +feature:install camel-servlet +feature:install camel-jackson +feature:install war + + +Then you can install the Camel example: + + +install -s mvn:org.apache.camel.example/camel-example-servlet-rest-karaf-jaas/${camel.version} + + +And you can see the application running by tailing the logs + + +log:tail + + +And you can use ctrl+c to stop tailing the log. + +There is a user REST service that supports the following operations + +* GET /user/\{id} - to view a user with the given id +* GET /user/final - to view all users +* PUT /user - to update/create an user + +The view operations are HTTP GET, and update is using HTTP PUT. + +From a web browser you can access the first two services using the +following links(need to input karaf/karaf as user/password in the pop up dialog) + + + http://localhost:8181/camel-example-servlet-rest-blueprint/rest/user/123 - to view the user with id 123 + http://localhost:8181/camel-example-servlet-rest-blueprint/rest/user/findAll - to list all users + + +From the command shell you can use curl to access the service as shown +below: + + +curl -X GET -H "Accept: application/json" --basic -u karaf:karaf http://localhost:8181/camel-example-servlet-rest-blueprint/rest/user/123 +curl -X GET -H "Accept: application/json" --basic -u karaf:karaf http://localhost:8181/camel-example-servlet-rest-blueprint/rest/user/findAll +curl -X PUT -d "{ \"id\": 666, \"name\": \"The devil\"}" -H "Accept: application/json" --basic -u karaf:karaf http://localhost:8181/camel-example-servlet-rest-blueprint/rest/user + + +=== Configuration + +This example is implemented in XML DSL in the +`+src/main/resources/OSGI-INF/blueprint/camel.xml+` file. + +=== Help and contributions + +If you hit any problem using Camel or have some feedback, then please +https://camel.apache.org/support.html[let us know]. + +We also love contributors, so +https://camel.apache.org/contributing.html[get involved] :-) + +The Camel riders! diff --git a/examples/camel-example-servlet-rest-karaf-jaas/pom.xml b/examples/camel-example-servlet-rest-karaf-jaas/pom.xml new file mode 100644 index 000..1b62472 --- /dev/null +++ b/examples/camel-example-servlet-rest-karaf-jaas/pom.xml @@ -0,0 +1,109 @@ + + +http://maven.apache.org/POM/4.0.0; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance; xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd;> + +4.0.0 + + +org.apache.camel.example +examples +3.5.0-SNAPSHOT + + +
[GitHub] [camel-quarkus] aldettinger opened a new issue #1505: @BindToRegistry not working with @ApplicationScoped route builders
aldettinger opened a new issue #1505: URL: https://github.com/apache/camel-quarkus/issues/1505 This behaviour could be reproduced in camel-grok itests route by attempting to replace [explicit `bindToRegistry` calls](https://github.com/apache/camel-quarkus/blob/master/integration-tests/grok/src/main/java/org/apache/camel/quarkus/component/grok/it/GrokRoute.java#L32..L34) with `@BindToRegistry`. The route can't start as @BindToRegistry Grok patterns are not present in the registry when GrokDataFormat.start() is called. As far as I could tell, it seems to me that bean post processing never occurs in this scenario. So we may have even more annotations that are not working. Would one agree it's an issue ? Would adding bean processing in this scenario be the solution ? where/when ? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] lburgazzoli commented on issue #1505: @BindToRegistry not working with @ApplicationScoped route builders
lburgazzoli commented on issue #1505: URL: https://github.com/apache/camel-quarkus/issues/1505#issuecomment-666386708 I think this is expected as back in the earlier days we decided that if you rely on CDi then you should use @Produces as it is more idiomatic This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch master updated: CAMEL-15355: camel-rabbitmq fix arg.queue.x-single-active-consumer to be configured as boolean type for RabbitMQ to make it work. Thanks to Devansh Arora for reporting a
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git The following commit(s) were added to refs/heads/master by this push: new 489b837 CAMEL-15355: camel-rabbitmq fix arg.queue.x-single-active-consumer to be configured as boolean type for RabbitMQ to make it work. Thanks to Devansh Arora for reporting and suggested fix. 489b837 is described below commit 489b837b590a5783c0de44505b37e32535624213 Author: Claus Ibsen AuthorDate: Thu Jul 30 15:16:50 2020 +0200 CAMEL-15355: camel-rabbitmq fix arg.queue.x-single-active-consumer to be configured as boolean type for RabbitMQ to make it work. Thanks to Devansh Arora for reporting and suggested fix. --- .../camel/component/rabbitmq/RabbitMQConstants.java | 1 + .../camel/component/rabbitmq/RabbitMQDeclareSupport.java | 5 + .../camel/component/rabbitmq/RabbitMQEndpointTest.java | 16 .../rabbitmq/integration/RabbitMQConsumerIntTest.java| 2 +- 4 files changed, 23 insertions(+), 1 deletion(-) diff --git a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConstants.java b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConstants.java index 1d26f9a..493c2d4 100644 --- a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConstants.java +++ b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConstants.java @@ -49,6 +49,7 @@ public final class RabbitMQConstants { public static final String RABBITMQ_QUEUE_MAX_PRIORITY_KEY = "x-max-priority"; public static final String RABBITMQ_QUEUE_MESSAGE_TTL_KEY = "x-message-ttl"; public static final String RABBITMQ_QUEUE_TTL_KEY = "x-expires"; +public static final String RABBITMQ_QUEUE_SINGLE_ACTIVE_CONSUMER_KEY = "x-single-active-consumer"; private RabbitMQConstants() { // Constants class diff --git a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java index 06c1021..4a7478c 100644 --- a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java +++ b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java @@ -86,6 +86,11 @@ public class RabbitMQDeclareSupport { if (queueExpiration instanceof String) { queueArgs.put(RabbitMQConstants.RABBITMQ_QUEUE_TTL_KEY, Long.parseLong((String)queueExpiration)); } + +Object singleConsumer = queueArgs.get(RabbitMQConstants.RABBITMQ_QUEUE_SINGLE_ACTIVE_CONSUMER_KEY); +if (singleConsumer instanceof String) { + queueArgs.put(RabbitMQConstants.RABBITMQ_QUEUE_SINGLE_ACTIVE_CONSUMER_KEY, Boolean.parseBoolean((String)singleConsumer)); +} } private void populateQueueArgumentsFromDeadLetterExchange(final Map queueArgs) { diff --git a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java index 1d20bef..3c4e57d 100644 --- a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java +++ b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java @@ -38,6 +38,7 @@ import org.apache.camel.component.rabbitmq.integration.RabbitMQDeadLetterRouting import org.apache.camel.spi.Registry; import org.apache.camel.support.SimpleRegistry; import org.apache.camel.test.junit5.CamelTestSupport; +import org.junit.Assert; import org.junit.jupiter.api.Test; import org.mockito.Mockito; import org.slf4j.Logger; @@ -300,4 +301,19 @@ public class RabbitMQEndpointTest extends CamelTestSupport { RabbitMQEndpoint endpoint = context.getEndpoint("rabbitmq:localhost/exchange?passive=true", RabbitMQEndpoint.class); assertTrue(endpoint.isPassive()); } + +@Test +public void testEndpointArgsIssue() throws Exception { +RabbitMQEndpoint endpoint1 = context.getEndpoint("rabbitmq://localhost:5672/mydirectdelayed?queue=testQ4" ++ "=testKey=me=mypwd=1=1=false" ++ "=myvhost=true=direct=x-delayed-message", RabbitMQEndpoint.class); + +Assert.assertNotNull(endpoint1.getArgs()); +Assert.assertEquals(2, endpoint1.getArgs().size()); +Assert.assertNotNull(endpoint1.getExchangeArgs()); +Assert.assertEquals(1, endpoint1.getExchangeArgs().size()); +Assert.assertNotNull(endpoint1.getQueueArgs()); +Assert.assertEquals(1, endpoint1.getQueueArgs().size()); +} + } diff --git
[camel] branch camel-3.4.x updated: CAMEL-15355: camel-rabbitmq fix arg.queue.x-single-active-consumer to be configured as boolean type for RabbitMQ to make it work. Thanks to Devansh Arora for report
This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch camel-3.4.x in repository https://gitbox.apache.org/repos/asf/camel.git The following commit(s) were added to refs/heads/camel-3.4.x by this push: new b96cc3b CAMEL-15355: camel-rabbitmq fix arg.queue.x-single-active-consumer to be configured as boolean type for RabbitMQ to make it work. Thanks to Devansh Arora for reporting and suggested fix. b96cc3b is described below commit b96cc3bf0dd884c46ee70a8f80e5cdd7522af6a3 Author: Claus Ibsen AuthorDate: Thu Jul 30 15:16:50 2020 +0200 CAMEL-15355: camel-rabbitmq fix arg.queue.x-single-active-consumer to be configured as boolean type for RabbitMQ to make it work. Thanks to Devansh Arora for reporting and suggested fix. --- .../camel/component/rabbitmq/RabbitMQConstants.java | 1 + .../camel/component/rabbitmq/RabbitMQDeclareSupport.java | 5 + .../camel/component/rabbitmq/RabbitMQEndpointTest.java | 16 .../rabbitmq/integration/RabbitMQConsumerIntTest.java| 2 +- 4 files changed, 23 insertions(+), 1 deletion(-) diff --git a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConstants.java b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConstants.java index 1d26f9a..493c2d4 100644 --- a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConstants.java +++ b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConstants.java @@ -49,6 +49,7 @@ public final class RabbitMQConstants { public static final String RABBITMQ_QUEUE_MAX_PRIORITY_KEY = "x-max-priority"; public static final String RABBITMQ_QUEUE_MESSAGE_TTL_KEY = "x-message-ttl"; public static final String RABBITMQ_QUEUE_TTL_KEY = "x-expires"; +public static final String RABBITMQ_QUEUE_SINGLE_ACTIVE_CONSUMER_KEY = "x-single-active-consumer"; private RabbitMQConstants() { // Constants class diff --git a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java index 23324a2..d04f6c3 100644 --- a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java +++ b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQDeclareSupport.java @@ -85,6 +85,11 @@ public class RabbitMQDeclareSupport { if (queueExpiration instanceof String) { queueArgs.put(RabbitMQConstants.RABBITMQ_QUEUE_TTL_KEY, Long.parseLong((String)queueExpiration)); } + +Object singleConsumer = queueArgs.get(RabbitMQConstants.RABBITMQ_QUEUE_SINGLE_ACTIVE_CONSUMER_KEY); +if (singleConsumer instanceof String) { + queueArgs.put(RabbitMQConstants.RABBITMQ_QUEUE_SINGLE_ACTIVE_CONSUMER_KEY, Boolean.parseBoolean((String)singleConsumer)); +} } private void populateQueueArgumentsFromDeadLetterExchange(final Map queueArgs) { diff --git a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java index 3fdb624..45d86f5 100644 --- a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java +++ b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQEndpointTest.java @@ -38,6 +38,7 @@ import org.apache.camel.spi.Registry; import org.apache.camel.support.SimpleRegistry; import org.apache.camel.test.junit4.CamelTestSupport; import org.junit.Test; +import org.junit.Assert; import org.mockito.Mockito; public class RabbitMQEndpointTest extends CamelTestSupport { @@ -286,4 +287,19 @@ public class RabbitMQEndpointTest extends CamelTestSupport { RabbitMQEndpoint endpoint = context.getEndpoint("rabbitmq:localhost/exchange?passive=true", RabbitMQEndpoint.class); assertTrue(endpoint.isPassive()); } + +@Test +public void testEndpointArgsIssue() throws Exception { +RabbitMQEndpoint endpoint1 = context.getEndpoint("rabbitmq://localhost:5672/mydirectdelayed?queue=testQ4" ++ "=testKey=me=mypwd=1=1=false" ++ "=myvhost=true=direct=x-delayed-message", RabbitMQEndpoint.class); + +Assert.assertNotNull(endpoint1.getArgs()); +Assert.assertEquals(2, endpoint1.getArgs().size()); +Assert.assertNotNull(endpoint1.getExchangeArgs()); +Assert.assertEquals(1, endpoint1.getExchangeArgs().size()); +Assert.assertNotNull(endpoint1.getQueueArgs()); +Assert.assertEquals(1, endpoint1.getQueueArgs().size()); +} + } diff --git
[camel] 02/02: Regen website docs
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit 99636e0a3632159f4d9b90ad0fe0d93ec3a1be19 Author: Andrea Cosentino AuthorDate: Thu Jul 30 15:07:56 2020 +0200 Regen website docs --- .../modules/ROOT/pages/arangodb-component.adoc | 2 + .../ROOT/pages/kubernetes-job-component.adoc | 111 + 2 files changed, 113 insertions(+) diff --git a/docs/components/modules/ROOT/pages/arangodb-component.adoc b/docs/components/modules/ROOT/pages/arangodb-component.adoc index d7ca783..510a5ee 100644 --- a/docs/components/modules/ROOT/pages/arangodb-component.adoc +++ b/docs/components/modules/ROOT/pages/arangodb-component.adoc @@ -95,3 +95,5 @@ with the following path and query parameters: | *user* (security) | user if user and/or password different from default | | String |=== // endpoint options: END + +include::camel-spring-boot::page$arangodb-starter.adoc[] diff --git a/docs/components/modules/ROOT/pages/kubernetes-job-component.adoc b/docs/components/modules/ROOT/pages/kubernetes-job-component.adoc index 88a37da..f280fe1 100644 --- a/docs/components/modules/ROOT/pages/kubernetes-job-component.adoc +++ b/docs/components/modules/ROOT/pages/kubernetes-job-component.adoc @@ -138,5 +138,116 @@ from("direct:listByLabels").process(new Processor() { This operation return a List of Jobs from your cluster, using a label selector (with key1 and key2, with value value1 and value2) +- createJob: This operation create a job on a Kubernetes Cluster + +We have a wonderful example of this operation thanks to https://github.com/Emmerson-Miranda[Emmerson Miranda] from this https://github.com/Emmerson-Miranda/camel/blob/master/camel3-cdi/cdi-k8s-pocs/src/main/java/edu/emmerson/camel/k8s/jobs/camel_k8s_jobs/KubernetesCreateJob.java[Java test] + +[source,java] + +import java.util.ArrayList; +import java.util.Date; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +import javax.inject.Inject; + +import org.apache.camel.Endpoint; +import org.apache.camel.builder.RouteBuilder; +import org.apache.camel.cdi.Uri; +import org.apache.camel.component.kubernetes.KubernetesConstants; +import org.apache.camel.component.kubernetes.KubernetesOperations; + +import io.fabric8.kubernetes.api.model.Container; +import io.fabric8.kubernetes.api.model.ObjectMeta; +import io.fabric8.kubernetes.api.model.PodSpec; +import io.fabric8.kubernetes.api.model.PodTemplateSpec; +import io.fabric8.kubernetes.api.model.batch.JobSpec; + +/** + * + */ +public class KubernetesCreateJob extends RouteBuilder { + +@Inject +@Uri("timer:foo?delay=1000=1") +private Endpoint inputEndpoint; + +@Inject +@Uri("log:output") +private Endpoint resultEndpoint; + +@Override +public void configure() { +// you can configure the route rule with Java DSL here + +from(inputEndpoint) + .routeId("kubernetes-jobcreate-client") + .process(exchange -> { + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_JOB_NAME, "camel-job"); //DNS-1123 subdomain must consist of lower case alphanumeric characters, '-' or '.', and must start and end with an alphanumeric character (e.g. 'example.com', regex used for validation is '[a-z0-9]([-a-z0-9]*[a-z0-9])?(\.[a-z0-9]([-a-z0-9]*[a-z0-9])?)*') + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, "default"); + +Map joblabels = new HashMap(); +joblabels.put("jobLabelKey1", "value1"); +joblabels.put("jobLabelKey2", "value2"); +joblabels.put("app", "jobFromCamelApp"); + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_JOB_LABELS, joblabels); + + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_JOB_SPEC, generateJobSpec()); + }) + .toF("kubernetes-job:///{{kubernetes-master-url}}?oauthToken={{kubernetes-oauth-token:}}=" + KubernetesOperations.CREATE_JOB_OPERATION) + .log("Job created:") + .process(exchange -> { + System.out.println(exchange.getIn().getBody()); + }) +.to(resultEndpoint); +} + +/** + * Create a new JobSpec + * @return + */ + private JobSpec generateJobSpec() { + JobSpec js = new JobSpec(); + + PodTemplateSpec pts = new PodTemplateSpec(); + + PodSpec ps = new PodSpec(); + ps.setRestartPolicy("Never"); + ps.setContainers(generateContainers()); + pts.setSpec(ps); + + ObjectMeta metadata = new ObjectMeta(); +
[camel] branch master updated (42d16b0 -> 99636e0)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel.git. from 42d16b0 Camel-Arangodb: Removed System.out.println statement new e4e2455 CAMEL-15340 - create kubernetes job example new 99636e0 Regen website docs The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../src/main/docs/kubernetes-job-component.adoc| 111 + .../modules/ROOT/pages/arangodb-component.adoc | 2 + .../ROOT/pages/kubernetes-job-component.adoc | 111 + 3 files changed, 224 insertions(+)
[camel] 01/02: CAMEL-15340 - create kubernetes job example
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit e4e245516451074c0ed405d1c588ab2528ed334d Author: Andrea Cosentino AuthorDate: Thu Jul 30 15:07:16 2020 +0200 CAMEL-15340 - create kubernetes job example --- .../src/main/docs/kubernetes-job-component.adoc| 111 + 1 file changed, 111 insertions(+) diff --git a/components/camel-kubernetes/src/main/docs/kubernetes-job-component.adoc b/components/camel-kubernetes/src/main/docs/kubernetes-job-component.adoc index b2f6b90..bb3aa85 100644 --- a/components/camel-kubernetes/src/main/docs/kubernetes-job-component.adoc +++ b/components/camel-kubernetes/src/main/docs/kubernetes-job-component.adoc @@ -136,5 +136,116 @@ from("direct:listByLabels").process(new Processor() { This operation return a List of Jobs from your cluster, using a label selector (with key1 and key2, with value value1 and value2) +- createJob: This operation create a job on a Kubernetes Cluster + +We have a wonderful example of this operation thanks to https://github.com/Emmerson-Miranda[Emmerson Miranda] from this https://github.com/Emmerson-Miranda/camel/blob/master/camel3-cdi/cdi-k8s-pocs/src/main/java/edu/emmerson/camel/k8s/jobs/camel_k8s_jobs/KubernetesCreateJob.java[Java test] + +[source,java] + +import java.util.ArrayList; +import java.util.Date; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +import javax.inject.Inject; + +import org.apache.camel.Endpoint; +import org.apache.camel.builder.RouteBuilder; +import org.apache.camel.cdi.Uri; +import org.apache.camel.component.kubernetes.KubernetesConstants; +import org.apache.camel.component.kubernetes.KubernetesOperations; + +import io.fabric8.kubernetes.api.model.Container; +import io.fabric8.kubernetes.api.model.ObjectMeta; +import io.fabric8.kubernetes.api.model.PodSpec; +import io.fabric8.kubernetes.api.model.PodTemplateSpec; +import io.fabric8.kubernetes.api.model.batch.JobSpec; + +/** + * + */ +public class KubernetesCreateJob extends RouteBuilder { + +@Inject +@Uri("timer:foo?delay=1000=1") +private Endpoint inputEndpoint; + +@Inject +@Uri("log:output") +private Endpoint resultEndpoint; + +@Override +public void configure() { +// you can configure the route rule with Java DSL here + +from(inputEndpoint) + .routeId("kubernetes-jobcreate-client") + .process(exchange -> { + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_JOB_NAME, "camel-job"); //DNS-1123 subdomain must consist of lower case alphanumeric characters, '-' or '.', and must start and end with an alphanumeric character (e.g. 'example.com', regex used for validation is '[a-z0-9]([-a-z0-9]*[a-z0-9])?(\.[a-z0-9]([-a-z0-9]*[a-z0-9])?)*') + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_NAMESPACE_NAME, "default"); + +Map joblabels = new HashMap(); +joblabels.put("jobLabelKey1", "value1"); +joblabels.put("jobLabelKey2", "value2"); +joblabels.put("app", "jobFromCamelApp"); + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_JOB_LABELS, joblabels); + + exchange.getIn().setHeader(KubernetesConstants.KUBERNETES_JOB_SPEC, generateJobSpec()); + }) + .toF("kubernetes-job:///{{kubernetes-master-url}}?oauthToken={{kubernetes-oauth-token:}}=" + KubernetesOperations.CREATE_JOB_OPERATION) + .log("Job created:") + .process(exchange -> { + System.out.println(exchange.getIn().getBody()); + }) +.to(resultEndpoint); +} + +/** + * Create a new JobSpec + * @return + */ + private JobSpec generateJobSpec() { + JobSpec js = new JobSpec(); + + PodTemplateSpec pts = new PodTemplateSpec(); + + PodSpec ps = new PodSpec(); + ps.setRestartPolicy("Never"); + ps.setContainers(generateContainers()); + pts.setSpec(ps); + + ObjectMeta metadata = new ObjectMeta(); + Map annotations = new HashMap(); + annotations.put("jobMetadataAnnotation1", "random value"); + metadata.setAnnotations(annotations); + + Map podlabels = new HashMap(); + podlabels.put("podLabelKey1", "value1"); + podlabels.put("podLabelKey2", "value2"); + podlabels.put("app", "podFromCamelApp"); + metadata.setLabels(podlabels); + + pts.setMetadata(metadata); + js.setTemplate(pts); +
[GitHub] [camel-kafka-connector] fvaleri edited a comment on pull request #343: Set default and doc config properties as private
fvaleri edited a comment on pull request #343: URL: https://github.com/apache/camel-kafka-connector/pull/343#issuecomment-666305336 OK, I will reopen it and fix the checkstyle issue if we reach consensus. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] orpiske edited a comment on pull request #343: Set default and doc config properties as private
orpiske edited a comment on pull request #343: URL: https://github.com/apache/camel-kafka-connector/pull/343#issuecomment-666340690 > > I agree that moving to private would follow generally accepted good practices (for lack of a better "term"). However, I still feel -1 towards making it `private`. My feeling towards this comes from the fact that Kafka seems to also use [public visibility](https://github.com/apache/kafka/blob/trunk/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java#L98) on their code base. > > Even though these are separate projects, I believe that maintaining them as `public` would be consistent to how it is done right now on the Kafka Connect code base. I believe that maintaining this consistency could simplify the job for developers looking to extend the Camel Kafka Connector connectors. > > Therefore, my suggestion is -1. > > Well, I see a mixed approach in that class. There are some `_DOC` and `_DISPALY` properties that are actually private, which is what I'm proposing here (make private every metadata associated with a given key). The `_CONF` properties would remain public, because they are actually needed outside of this class. > > That said, I understand that this is more a matter of good practices than a real need, so I'm ok with whatever we choose. Thanks for the clarification. I had initially thought that this would change the _CONF ones too. With your explanation I see that's not the case. So, given that with this change it would be consistent with the way Kafka Connect code base is doing ... That's +1 from me. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] orpiske commented on pull request #343: Set default and doc config properties as private
orpiske commented on pull request #343: URL: https://github.com/apache/camel-kafka-connector/pull/343#issuecomment-666340690 > > I agree that moving to private would follow generally accepted good practices (for lack of a better "term"). However, I still feel -1 towards making it `private`. My feeling towards this comes from the fact that Kafka seems to also use [public visibility](https://github.com/apache/kafka/blob/trunk/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java#L98) on their code base. > > Even though these are separate projects, I believe that maintaining them as `public` would be consistent to how it is done right now on the Kafka Connect code base. I believe that maintaining this consistency could simplify the job for developers looking to extend the Camel Kafka Connector connectors. > > Therefore, my suggestion is -1. > > Well, I see a mixed approach in that class. There are some `_DOC` and `_DISPALY` properties that are actually private, which is what I'm proposing here (make private every metadata associated with a given key). The `_CONF` properties would remain public, because they are actually needed outside of this class. > > That said, I understand that this is more a matter of good practices than a real need, so I'm ok with whatever we choose. Thanks for the clarification. I had initially thought that this would change the _CONF ones too. With your explanation I see that's not the case. So, given that it - with this change - it would be consistent with the way Kafka Connect code base is doing ... That's +1 from me. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-spring-boot] branch master updated: Regen
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git The following commit(s) were added to refs/heads/master by this push: new 19700b2 Regen 19700b2 is described below commit 19700b2bea2cf79ea6664c287637215b36c1ea3b Author: Andrea Cosentino AuthorDate: Thu Jul 30 14:39:45 2020 +0200 Regen --- .../apache/camel/springboot/catalog/components/aws2-s3.json | 4 ++-- .../apache/camel/springboot/catalog/components/aws2-sqs.json | 4 ++-- .../camel-aws2-s3-starter/src/main/docs/aws2-s3-starter.adoc | 2 +- .../aws2/s3/springboot/AWS2S3ComponentConfiguration.java | 4 +++- components-starter/camel-corda-starter/pom.xml | 12 components-starter/camel-iota-starter/pom.xml| 12 docs/modules/ROOT/pages/aws2-s3-starter.adoc | 2 +- 7 files changed, 33 insertions(+), 7 deletions(-) diff --git a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-s3.json b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-s3.json index 05b5cb6..161da14 100644 --- a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-s3.json +++ b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/aws2-s3.json @@ -22,7 +22,7 @@ }, "componentProperties": { "amazonS3Client": { "kind": "property", "displayName": "Amazon S3 Client", "group": "common", "label": "", "required": false, "type": "object", "javaType": "software.amazon.awssdk.services.s3.S3Client", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField": "configuration", "description": "Reference to a com.amazonaws.services.s3.AmazonS3 in the registry." }, -"autoCreateBucket": { "kind": "property", "displayName": "Auto Create Bucket", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "true", "configurationClass": "org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField": "configuration", "description": "Setting the autocreation of the bucket" }, +"autoCreateBucket": { "kind": "property", "displayName": "Auto Create Bucket", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "true", "configurationClass": "org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField": "configuration", "description": "Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enable [...] "autoDiscoverClient": { "kind": "property", "displayName": "Auto Discover Client", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "true", "configurationClass": "org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField": "configuration", "description": "Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the regis [...] "configuration": { "kind": "property", "displayName": "Configuration", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.aws2.s3.AWS2S3Configuration", "deprecated": false, "secret": false, "description": "The component configuration" }, "overrideEndpoint": { "kind": "property", "displayName": "Override Endpoint", "group": "common", "label": "", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false, "defaultValue": "false", "configurationClass": "org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField": "configuration", "description": "Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option" }, @@ -65,7 +65,7 @@ "properties": { "bucketNameOrArn": { "kind": "path", "displayName": "Bucket Name Or Arn", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "secret": false, "description": "Bucket name or ARN" }, "amazonS3Client": { "kind": "parameter", "displayName": "Amazon S3 Client", "group": "common", "label": "", "required": false, "type": "object", "javaType": "software.amazon.awssdk.services.s3.S3Client", "deprecated": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
[GitHub] [camel-kafka-connector] fvaleri commented on pull request #343: Set default and doc config properties as private
fvaleri commented on pull request #343: URL: https://github.com/apache/camel-kafka-connector/pull/343#issuecomment-666336202 > I agree that moving to private would follow generally accepted good practices (for lack of a better "term"). However, I still feel -1 towards making it `private`. My feeling towards this comes from the fact that Kafka seems to also use [public visibility](https://github.com/apache/kafka/blob/trunk/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java#L98) on their code base. > > Even though these are separate projects, I believe that maintaining them as `public` would be consistent to how it is done right now on the Kafka Connect code base. I believe that maintaining this consistency could simplify the job for developers looking to extend the Camel Kafka Connector connectors. > > Therefore, my suggestion is -1. Well, I see a mixed approach in that class. There are some `_DOC` and `_DISPALY` properties that are actually private, which is what I'm proposing here (make private every metadata associated with a given key). The `_CONF` properties would remain public, because they are actually needed outside of this class. That said, I understand that this is more a matter of good practices than a real need, so I'm ok with whatever we choose. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch master updated (0dea4ff -> 42d16b0)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel.git. from 0dea4ff Added Camel-arangodb SB starter docs new 043b110 Camel-Arangodb: Fixed log configuration for tests new 42d16b0 Camel-Arangodb: Removed System.out.println statement The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../org/apache/camel/component/arangodb/ArangoDbProducer.java| 1 - components/camel-arangodb/src/test/resources/log4j2.properties | 9 - 2 files changed, 8 insertions(+), 2 deletions(-)
[camel] 01/02: Camel-Arangodb: Fixed log configuration for tests
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit 043b110e941937590ae0948b8234705371c005ba Author: Andrea Cosentino AuthorDate: Thu Jul 30 14:23:34 2020 +0200 Camel-Arangodb: Fixed log configuration for tests --- components/camel-arangodb/src/test/resources/log4j2.properties | 9 - 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/components/camel-arangodb/src/test/resources/log4j2.properties b/components/camel-arangodb/src/test/resources/log4j2.properties index f87b4d4..99275ad 100644 --- a/components/camel-arangodb/src/test/resources/log4j2.properties +++ b/components/camel-arangodb/src/test/resources/log4j2.properties @@ -14,9 +14,16 @@ ## See the License for the specific language governing permissions and ## limitations under the License. ## --- +appender.file.type = File +appender.file.name = file +appender.file.fileName = target/camel-arangodb-test.log +appender.file.layout.type = PatternLayout +appender.file.layout.pattern = %d [%-15.15t] %-5p %-30.30c{1} - %m%n appender.out.type = Console appender.out.name = out appender.out.layout.type = PatternLayout appender.out.layout.pattern = [%30.30t] %-30.30c{1} %-5p %m%n + rootLogger.level = INFO -rootLogger.appenderRef.out.ref = out +rootLogger.appenderRef.file.ref = file +#rootLogger.appenderRef.out.ref = out
[GitHub] [camel-k] bfitzpat closed issue #1645: When creating a new tag, make sure it's strictly numeric (i.e. 1.1.0 instead of v1.1.0)
bfitzpat closed issue #1645: URL: https://github.com/apache/camel-k/issues/1645 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] 02/02: Camel-Arangodb: Removed System.out.println statement
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit 42d16b0d2ea24162bbf9c3dd2246a349726f16c5 Author: Andrea Cosentino AuthorDate: Thu Jul 30 14:25:09 2020 +0200 Camel-Arangodb: Removed System.out.println statement --- .../main/java/org/apache/camel/component/arangodb/ArangoDbProducer.java | 1 - 1 file changed, 1 deletion(-) diff --git a/components/camel-arangodb/src/main/java/org/apache/camel/component/arangodb/ArangoDbProducer.java b/components/camel-arangodb/src/main/java/org/apache/camel/component/arangodb/ArangoDbProducer.java index 3c4957e..57ab71c 100644 --- a/components/camel-arangodb/src/main/java/org/apache/camel/component/arangodb/ArangoDbProducer.java +++ b/components/camel-arangodb/src/main/java/org/apache/camel/component/arangodb/ArangoDbProducer.java @@ -62,7 +62,6 @@ public class ArangoDbProducer extends DefaultProducer { } public void process(Exchange exchange) throws Exception { -System.out.println(exchange.getIn().getBody()); ArangoDbOperation operation = endpoint.getConfiguration().getOperation(); invokeOperation(operation, exchange); }
[GitHub] [camel-k] bfitzpat commented on issue #1645: When creating a new tag, make sure it's strictly numeric (i.e. 1.1.0 instead of v1.1.0)
bfitzpat commented on issue #1645: URL: https://github.com/apache/camel-k/issues/1645#issuecomment-666333256 Looks like this is a necessary change. I was not aware of apache/camel-k#1603 and apache/camel-k#1601. Will close and we are adapting the version checking to be better in the tooling This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch master updated: Added Camel-arangodb SB starter docs
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git The following commit(s) were added to refs/heads/master by this push: new 0dea4ff Added Camel-arangodb SB starter docs 0dea4ff is described below commit 0dea4ffdcd340e1b155e378538a9b7826c68d355 Author: Andrea Cosentino AuthorDate: Thu Jul 30 14:20:15 2020 +0200 Added Camel-arangodb SB starter docs --- components/camel-arangodb/src/main/docs/arangodb-component.adoc | 2 ++ 1 file changed, 2 insertions(+) diff --git a/components/camel-arangodb/src/main/docs/arangodb-component.adoc b/components/camel-arangodb/src/main/docs/arangodb-component.adoc index 9b0be1a..d883a0d 100644 --- a/components/camel-arangodb/src/main/docs/arangodb-component.adoc +++ b/components/camel-arangodb/src/main/docs/arangodb-component.adoc @@ -93,3 +93,5 @@ with the following path and query parameters: | *user* (security) | user if user and/or password different from default | | String |=== // endpoint options: END + +include::camel-spring-boot::page$arangodb-starter.adoc[]
[camel] branch master updated (0b627c0 -> 327f33a)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel.git. from 0b627c0 Regen website docs new 42442bf Camel-AWS2-SQS: Fixed class returned from producer operation in docs new 327f33a Regen docs The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: components/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc | 6 +++--- docs/components/modules/ROOT/pages/aws2-sqs-component.adoc | 6 +++--- 2 files changed, 6 insertions(+), 6 deletions(-)
[camel] 01/02: Camel-AWS2-SQS: Fixed class returned from producer operation in docs
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit 42442bf01f43615413c04ebd1a6ccd663edf60d6 Author: Andrea Cosentino AuthorDate: Thu Jul 30 14:11:41 2020 +0200 Camel-AWS2-SQS: Fixed class returned from producer operation in docs --- components/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/components/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc b/components/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc index 733c372..19b69b7 100644 --- a/components/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc +++ b/components/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc @@ -351,7 +351,7 @@ from("direct:start") .to("aws2-sqs://camel-1?accessKey=RAW(xxx)=RAW(xxx)=EU_WEST_1"); -- -As result you'll get an exchange containing a `SendMessageBatchResult` instance, that you can examinate to check what messages were successfull and what not. +As result you'll get an exchange containing a `SendMessageBatchResponse` instance, that you can examinate to check what messages were successfull and what not. The id set on each message of the batch will be a Random UUID. == Delete single Message @@ -365,7 +365,7 @@ from("direct:start") .to("aws2-sqs://camel-1?accessKey=RAW(xxx)=RAW(xxx)=EU_WEST_1"); -- -As result you'll get an exchange containing a `DeleteMessageResult` instance, that you can use to check if the message was deleted or not. +As result you'll get an exchange containing a `DeleteMessageResponse` instance, that you can use to check if the message was deleted or not. == List Queues @@ -376,7 +376,7 @@ from("direct:start") .setHeader(SqsConstants.SQS_OPERATION, constant("listQueues")).to("aws2-sqs://camel-1?accessKey=RAW(xxx)=RAW(xxx)=EU_WEST_1"); -- -As result you'll get an exchange containing a `ListQueuesResult` instance, that you can examinate to check the actual queues. +As result you'll get an exchange containing a `ListQueuesResponse` instance, that you can examinate to check the actual queues. == Purge Queue
[camel] 02/02: Regen docs
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit 327f33a580c7a822a592ded08b3e73221e16cdbd Author: Andrea Cosentino AuthorDate: Thu Jul 30 14:13:30 2020 +0200 Regen docs --- docs/components/modules/ROOT/pages/aws2-sqs-component.adoc | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/docs/components/modules/ROOT/pages/aws2-sqs-component.adoc b/docs/components/modules/ROOT/pages/aws2-sqs-component.adoc index 1b5400c..9e4a0ac 100644 --- a/docs/components/modules/ROOT/pages/aws2-sqs-component.adoc +++ b/docs/components/modules/ROOT/pages/aws2-sqs-component.adoc @@ -353,7 +353,7 @@ from("direct:start") .to("aws2-sqs://camel-1?accessKey=RAW(xxx)=RAW(xxx)=EU_WEST_1"); -- -As result you'll get an exchange containing a `SendMessageBatchResult` instance, that you can examinate to check what messages were successfull and what not. +As result you'll get an exchange containing a `SendMessageBatchResponse` instance, that you can examinate to check what messages were successfull and what not. The id set on each message of the batch will be a Random UUID. == Delete single Message @@ -367,7 +367,7 @@ from("direct:start") .to("aws2-sqs://camel-1?accessKey=RAW(xxx)=RAW(xxx)=EU_WEST_1"); -- -As result you'll get an exchange containing a `DeleteMessageResult` instance, that you can use to check if the message was deleted or not. +As result you'll get an exchange containing a `DeleteMessageResponse` instance, that you can use to check if the message was deleted or not. == List Queues @@ -378,7 +378,7 @@ from("direct:start") .setHeader(SqsConstants.SQS_OPERATION, constant("listQueues")).to("aws2-sqs://camel-1?accessKey=RAW(xxx)=RAW(xxx)=EU_WEST_1"); -- -As result you'll get an exchange containing a `ListQueuesResult` instance, that you can examinate to check the actual queues. +As result you'll get an exchange containing a `ListQueuesResponse` instance, that you can examinate to check the actual queues. == Purge Queue
[camel] branch master updated (c9bc4a7 -> 0b627c0)
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel.git. from c9bc4a7 CAMEL-15353: Add CamelK as category to the component fixed set of known categories new 7deb2a5 Camel-AWS2-SQS: Added PurgeQueue example new 0b627c0 Regen website docs The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc | 11 +++ docs/components/modules/ROOT/pages/aws2-sqs-component.adoc| 11 +++ 2 files changed, 22 insertions(+)
[camel] 01/02: Camel-AWS2-SQS: Added PurgeQueue example
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit 7deb2a5c775fa3651ff79f550d6894e544c3574a Author: Andrea Cosentino AuthorDate: Thu Jul 30 14:06:12 2020 +0200 Camel-AWS2-SQS: Added PurgeQueue example --- .../camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc | 11 +++ 1 file changed, 11 insertions(+) diff --git a/components/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc b/components/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc index 40693c5..733c372 100644 --- a/components/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc +++ b/components/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc @@ -378,6 +378,17 @@ from("direct:start") As result you'll get an exchange containing a `ListQueuesResult` instance, that you can examinate to check the actual queues. +== Purge Queue + +Use purgeQueue operation to purge queue. + +-- +from("direct:start") + .setHeader(SqsConstants.SQS_OPERATION, constant("purgeQueue")).to("aws2-sqs://camel-1?accessKey=RAW(xxx)=RAW(xxx)=EU_WEST_1"); +-- + +As result you'll get an exchange containing a `PurgeQueueResponse` instance. + == Queue Autocreation With the option `autoCreateQueue` users are able to avoid the autocreation of an SQS Queue in case it doesn't exist. The default for this option is `true`.
[camel] 02/02: Regen website docs
This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit 0b627c0b6f858bf072d49caae964d204a41536c1 Author: Andrea Cosentino AuthorDate: Thu Jul 30 14:06:57 2020 +0200 Regen website docs --- docs/components/modules/ROOT/pages/aws2-sqs-component.adoc | 11 +++ 1 file changed, 11 insertions(+) diff --git a/docs/components/modules/ROOT/pages/aws2-sqs-component.adoc b/docs/components/modules/ROOT/pages/aws2-sqs-component.adoc index 61ce33c..1b5400c 100644 --- a/docs/components/modules/ROOT/pages/aws2-sqs-component.adoc +++ b/docs/components/modules/ROOT/pages/aws2-sqs-component.adoc @@ -380,6 +380,17 @@ from("direct:start") As result you'll get an exchange containing a `ListQueuesResult` instance, that you can examinate to check the actual queues. +== Purge Queue + +Use purgeQueue operation to purge queue. + +-- +from("direct:start") + .setHeader(SqsConstants.SQS_OPERATION, constant("purgeQueue")).to("aws2-sqs://camel-1?accessKey=RAW(xxx)=RAW(xxx)=EU_WEST_1"); +-- + +As result you'll get an exchange containing a `PurgeQueueResponse` instance. + == Queue Autocreation With the option `autoCreateQueue` users are able to avoid the autocreation of an SQS Queue in case it doesn't exist. The default for this option is `true`.
[GitHub] [camel-quarkus] ppalaga commented on pull request #1419: DO NOT MERGE! Upgrading maven surefire plugin before fix
ppalaga commented on pull request #1419: URL: https://github.com/apache/camel-quarkus/pull/1419#issuecomment-666322876 @JiriOndrusek do we still need 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] ogomezdi edited a comment on issue #814: Can camel-k accept camel context definition?
ogomezdi edited a comment on issue #814: URL: https://github.com/apache/camel-k/issues/814#issuecomment-666288645 Notice that also in the examples came-k folder there is an [example ](https://github.com/apache/camel-k/blob/master/examples/polyglot/JavaRoute.java) of using @BindToRegistry in conjunction of using multiple files for deploying one integration. I want also to mention I wan't able to use "packages" for language "java" that will be helpful to have better organization of code supporting logical needed for each integration. I mean, what I'm trying to do is separe the logic from the route itself, so I've created two different java files, one containing only the route, and other implementing the utils (for example), the first one I want to place it in a "package org.something.integrations.route" and the other in a "package org.something.integrations.utils" if I did it in this way and execute this command: `kamel run ExampleRoute.java ExampleUtils.java --dev` I got this error: `[1] Monitoring pod example-route-57664f98f9-6pkkw [1] exec java -cp ./resources:/etc/camel/resources:/etc/camel/sources/i-source-000:/etc/camel/sources/i-source-001:dependencies/org.apache.camel.camel-api-3.4.0.jar:dependencies/org.apache.camel.camel-base-3.4.0.jar:dependencies/org.apache.camel.camel-bean-3.4.0.jar:dependencies/org.apache.camel.camel-core-engine-3.4.0.jar:dependencies/org.apache.camel.camel-core-languages-3.4.0.jar:dependencies/org.apache.camel.camel-endpointdsl-3.4.0.jar:dependencies/org.apache.camel.camel-log-3.4.0.jar:dependencies/org.apache.camel.camel-main-3.4.0.jar:dependencies/org.apache.camel.camel-management-api-3.4.0.jar:dependencies/org.apache.camel.camel-support-3.4.0.jar:dependencies/org.apache.camel.camel-timer-3.4.0.jar:dependencies/org.apache.camel.camel-util-3.4.0.jar:dependencies/org.apache.camel.k.camel-k-loader-java-1.4.1.jar:dependencies/org.apache.camel.k.camel-k-runtime-core-1.4.1.jar:dependencies/org.apache.camel.k.camel-k-runtime-main-1.4.1.jar:dependencies/org.apache.logging.log4j.log4j- api-2.13.3.jar:dependencies/org.apache.logging.log4j.log4j-core-2.13.3.jar:dependencies/org.apache.logging.log4j.log4j-slf4j-impl-2.13.3.jar:dependencies/org.jooq.joor-0.9.13.jar:dependencies/org.slf4j.slf4j-api-1.7.30.jar org.apache.camel.k.main.Application Condition "Ready" is "True" for Integration example-route [1] 2020-07-30 11:36:22.187 INFO [main] ApplicationRuntime - Add listener: org.apache.camel.k.listener.ContextConfigurer@503ecb24 [1] 2020-07-30 11:36:22.192 INFO [main] ApplicationRuntime - Add listener: org.apache.camel.k.listener.RoutesConfigurer@5d12a356 [1] 2020-07-30 11:36:22.195 INFO [main] ApplicationRuntime - Add listener: org.apache.camel.k.listener.PropertiesConfigurer@4fad9bb2 [1] 2020-07-30 11:36:22.216 INFO [main] ApplicationRuntime - Listener org.apache.camel.k.listener.PropertiesConfigurer@4fad9bb2 executed in phase ConfigureProperties [1] 2020-07-30 11:36:22.233 INFO [main] RuntimeSupport - Looking up loader for language: java [1] 2020-07-30 11:36:22.237 INFO [main] RuntimeSupport - Found loader org.apache.camel.k.loader.java.JavaSourceLoader@35f26e72 for language java from service definition [1] Exception in thread "main" org.apache.camel.RuntimeCamelException: org.joor.ReflectException: Compilation error: /org/something/integrations/route/ExampleRoute.java:6: error: package org.something.integrations.utils does not exist [1] import org.something.integrations.utils.ExampleUtils; [1]^ [1] 1 error [1] [1] at org.apache.camel.RuntimeCamelException.wrapRuntimeCamelException(RuntimeCamelException.java:52) [1] at org.apache.camel.k.listener.RoutesConfigurer.load(RoutesConfigurer.java:102) [1] at org.apache.camel.k.listener.RoutesConfigurer.load(RoutesConfigurer.java:63) [1] at org.apache.camel.k.listener.RoutesConfigurer.accept(RoutesConfigurer.java:53) [1] at org.apache.camel.k.listener.AbstractPhaseListener.accept(AbstractPhaseListener.java:32) [1] at org.apache.camel.k.main.ApplicationRuntime$MainListenerAdapter.lambda$invokeListeners$0(ApplicationRuntime.java:178) [1] at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) [1] at java.base/java.util.stream.SortedOps$SizedRefSortingSink.end(SortedOps.java:357) [1] at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:485) [1] at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) [1] at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) [1] at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) [1] at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) [1] at
[GitHub] [camel-kafka-connector] orpiske edited a comment on pull request #343: Set default and doc config properties as private
orpiske edited a comment on pull request #343: URL: https://github.com/apache/camel-kafka-connector/pull/343#issuecomment-666311561 I agree that moving to private would follow generally accepted good practices (for lack of a better "term"). However, I still feel -1 towards making it `private`. My feeling towards this comes from the fact that Kafka seems to also use [public visibility](https://github.com/apache/kafka/blob/trunk/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java#L98) on their code base. Even though these are separate projects, I believe that maintaining them as `public` would be consistent to how it is done right now on the Kafka Connect code base. I believe that maintaining this consistency could simplify the job for developers looking to extend the Camel Kafka Connector connectors. Therefore, my suggestion is -1. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] orpiske commented on pull request #343: Set default and doc config properties as private
orpiske commented on pull request #343: URL: https://github.com/apache/camel-kafka-connector/pull/343#issuecomment-666311561 I agree that moving to private would follow generally accepted good practices (for lack of a better "term"). Howev er, I still feel -1 towards making it private. My feeling towards this comes from the fact that Kafka seems to also use [public visibility](https://github.com/apache/kafka/blob/trunk/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java#L98) on their code base. Even though these are separate projects, I believe that maintaining them as `public` would be consistent to how it is done right now on the Kafka Connect code base. I believe that maintaining this consistency could simplify the job for developers looking to extend the Camel Kafka Connect connectors. Therefore, my suggestion is -1. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] orpiske edited a comment on pull request #343: Set default and doc config properties as private
orpiske edited a comment on pull request #343: URL: https://github.com/apache/camel-kafka-connector/pull/343#issuecomment-666311561 I agree that moving to private would follow generally accepted good practices (for lack of a better "term"). However, I still feel -1 towards making it private. My feeling towards this comes from the fact that Kafka seems to also use [public visibility](https://github.com/apache/kafka/blob/trunk/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java#L98) on their code base. Even though these are separate projects, I believe that maintaining them as `public` would be consistent to how it is done right now on the Kafka Connect code base. I believe that maintaining this consistency could simplify the job for developers looking to extend the Camel Kafka Connect connectors. Therefore, my suggestion is -1. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] fvaleri commented on pull request #343: Set default and doc config properties as private
fvaleri commented on pull request #343: URL: https://github.com/apache/camel-kafka-connector/pull/343#issuecomment-666305336 OK, I'm reopening it to wait for more feedback, but will fix the checkstyle issue only if there is consensus. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] oscerd commented on pull request #343: Set default and doc config properties as private
oscerd commented on pull request #343: URL: https://github.com/apache/camel-kafka-connector/pull/343#issuecomment-666302843 Wait, for @valdar and @orpiske too. I'm not the only here.if this is something they vote for, we'll 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] lburgazzoli commented on issue #814: Can camel-k accept camel context definition?
lburgazzoli commented on issue #814: URL: https://github.com/apache/camel-k/issues/814#issuecomment-666302745 > > I want also to mention I wan't able to use "packages" for language "java" that will be helpful to have better organization of code supporting logical needed for each integration. can you rephrase it ? I don't get what you are trying to describe This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] fvaleri commented on pull request #343: Set default and doc config properties as private
fvaleri commented on pull request #343: URL: https://github.com/apache/camel-kafka-connector/pull/343#issuecomment-666302137 Hi @oscerd , there are no main advantages, so I'm ok to close 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-kafka-connector] fvaleri closed pull request #343: Set default and doc config properties as private
fvaleri closed pull request #343: URL: https://github.com/apache/camel-kafka-connector/pull/343 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org