[GitHub] [camel] oscerd closed pull request #4697: [CAMEL-15341] Create camel-azure-storage-datalake to serve Azure DataLakes Gen2
oscerd closed pull request #4697: URL: https://github.com/apache/camel/pull/4697 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] oscerd commented on pull request #4697: [CAMEL-15341] Create camel-azure-storage-datalake to serve Azure DataLakes Gen2
oscerd commented on pull request #4697: URL: https://github.com/apache/camel/pull/4697#issuecomment-768105571 Merged with some modification. Thanks This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel-spring-boot] branch master updated: Fixed test for camel-atlasmap
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 159f10e Fixed test for camel-atlasmap
159f10e is described below
commit 159f10e6b7735f3119032aff43a9dffb86e84a03
Author: Andrea Cosentino
AuthorDate: Wed Jan 27 08:54:39 2021 +0100
Fixed test for camel-atlasmap
---
.../test/java/org/apache/camel/itest/springboot/CamelAtlasmapTest.java | 2 ++
.../org/apache/camel/itest/springboot/util/ArquillianPackager.java | 3 +++
2 files changed, 5 insertions(+)
diff --git
a/tests/camel-itest-spring-boot/src/test/java/org/apache/camel/itest/springboot/CamelAtlasmapTest.java
b/tests/camel-itest-spring-boot/src/test/java/org/apache/camel/itest/springboot/CamelAtlasmapTest.java
index ccbfde4..d3310c2 100644
---
a/tests/camel-itest-spring-boot/src/test/java/org/apache/camel/itest/springboot/CamelAtlasmapTest.java
+++
b/tests/camel-itest-spring-boot/src/test/java/org/apache/camel/itest/springboot/CamelAtlasmapTest.java
@@ -35,6 +35,8 @@ public class CamelAtlasmapTest extends
AbstractSpringBootTestSupport {
public static ITestConfig createTestConfig() {
return new ITestConfigBuilder()
.module(inferModuleName(CamelAtlasmapTest.class))
+
.dependency("org.scala-lang.modules:scala-parser-combinators_2.12:1.1.2")
+.dependency("org.scala-lang.modules:scala-xml_2.12:1.3.0")
.build();
}
diff --git
a/tests/camel-itest-spring-boot/src/test/java/org/apache/camel/itest/springboot/util/ArquillianPackager.java
b/tests/camel-itest-spring-boot/src/test/java/org/apache/camel/itest/springboot/util/ArquillianPackager.java
index d145569..38e1270 100644
---
a/tests/camel-itest-spring-boot/src/test/java/org/apache/camel/itest/springboot/util/ArquillianPackager.java
+++
b/tests/camel-itest-spring-boot/src/test/java/org/apache/camel/itest/springboot/util/ArquillianPackager.java
@@ -341,6 +341,8 @@ public final class ArquillianPackager {
ignore.add("net.java.dev.jna:jna-platform"); // PR to spring-boot
ignore.add("net.openhft");
ignore.add("org.scala-lang.modules:scala-java8-compat_2.11");
+ignore.add("org.scala-lang.modules:scala-parser-combinators_2.12");
+ignore.add("org.scala-lang.modules:scala-xml_2.12");
ignore.add("net.sourceforge.htmlunit:htmlunit-core-js"); // v 2.21
does not exist
ignore.add("org.springframework.cloud"); // too many different versions
ignore.add("org.springframework.data");
@@ -372,6 +374,7 @@ public final class ArquillianPackager {
// google grpc is a mix of all sort of different versions
ignore.add("com.google.api.grpc");
+
Map> status = new TreeMap<>();
Set mismatches = new TreeSet<>();
[GitHub] [camel] lburgazzoli merged pull request #4935: CAMEL-16080: Migrate camel-kamelet component from camel-k-runtime to camel
lburgazzoli merged pull request #4935: URL: https://github.com/apache/camel/pull/4935 This is an automated message from the 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 closed pull request #4941: Generated sources regen
oscerd closed pull request #4941: URL: https://github.com/apache/camel/pull/4941 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch regen_bot updated (7519e1b -> f3dd282)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. omit 7519e1b Regen for commit 3f5fbd4d5480c4f00d616d6db599c451e44fd414 add 987084c Upgrade AWS SDK v2 to version 2.15.70 add 3b49128 Sync deps and regen add 8c49517 Regen add f3dd282 Regen for commit 8c495178780cb2bf956907abf8041b70ac80a630 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 (7519e1b) \ N -- N -- N refs/heads/regen_bot (f3dd282) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: camel-dependencies/pom.xml | 2 +- parent/pom.xml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-)
[GitHub] [camel] github-actions[bot] opened a new pull request #4941: Generated sources regen
github-actions[bot] opened a new pull request #4941: URL: https://github.com/apache/camel/pull/4941 Regen bot :robot: found some uncommited changes after running build on :camel: master. Please do not delete `regen_bot` branch after merge/rebase. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch master updated (8c49517 -> cee7e01)
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 8c49517 Regen add 763fafd Upgrade Infinispan to version 12.0.0.Final add 73a1440 Camel-Infinispan test infra module: Upgrade to 12.0.0.Final-1 image add cee7e01 Camel-Infinispan Test infra module: Infinispan now uses quay.io No new revisions were added by this update. Summary of changes: parent/pom.xml | 2 +- .../test/infra/infinispan/services/InfinispanLocalContainerService.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-)
[GitHub] [camel] oscerd closed pull request #4940: Generated sources regen
oscerd closed pull request #4940: URL: https://github.com/apache/camel/pull/4940 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] oscerd commented on pull request #4940: Generated sources regen
oscerd commented on pull request #4940: URL: https://github.com/apache/camel/pull/4940#issuecomment-768087450 Already done. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch regen_bot updated (376ec61 -> 7519e1b)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. from 376ec61 Regen for commit ae2c79dcd64424acc82a29c9a46620809ea6414c (#4934) add 573ae84 CAMEL-12489 - camel-infinspan: split remote and embedded components add 37f2ec4 CAMEL-12489 - camel-infinspan: split remote and embedded components (split) add b334a5e CAMEL-12489 - camel-infinspan: split remote and embedded components (fix findings) add c9cdc67 CAMEL-12489 - camel-infinspan: split remote and embedded components (docs) add 8618eba CAMEL-12489 - camel-infinspan: split remote and embedded components (cleanup) add 3f5fbd4 CAMEL-12489 - camel-infinspan: split remote and embedded components (migration guide) add 7519e1b Regen for commit 3f5fbd4d5480c4f00d616d6db599c451e44fd414 No new revisions were added by this update. Summary of changes: bom/camel-bom/pom.xml | 15 + .../org/apache/camel/catalog/components.properties |1 + .../catalog/components/infinispan-embedded.json| 69 ++ .../camel/catalog/components/infinispan.json | 98 +- .../org/apache/camel/catalog/docs.properties |1 + .../camel/catalog/docs/infinispan-component.adoc | 853 -- .../docs/infinispan-embedded-component.adoc| 490 .../camel-infinispan-common/pom.xml| 107 ++ .../InfinispanAggregationRepository.java} | 120 +- .../component/infinispan/InfinispanComponent.java} | 14 +- .../infinispan/InfinispanConfiguration.java| 136 +++ .../component/infinispan/InfinispanConstants.java |5 + .../component/infinispan/InfinispanConsumer.java | 80 ++ .../component/infinispan/InfinispanEndpoint.java} | 13 +- .../infinispan/InfinispanEventListener.java| 38 +- .../infinispan/InfinispanEventProcessor.java} |8 +- .../infinispan/InfinispanIdempotentRepository.java | 85 ++ .../component/infinispan/InfinispanManager.java| 55 + .../component/infinispan/InfinispanOperation.java |0 .../component/infinispan/InfinispanProducer.java | 335 ++ .../infinispan/InfinispanQueryBuilder.java |5 + .../infinispan/InfinispanRoutePolicy.java | 246 .../camel/component/infinispan/InfinispanUtil.java | 69 ++ .../infinispan/InfinispanConsumerTestSupport.java} | 15 +- .../InfinispanIdempotentRepositoryTestSupport.java | 103 ++ .../infinispan/InfinispanProducerTestSupport.java | 868 +++ .../InfinispanRoutePolicyTestSupport.java | 58 + .../infinispan/InfinispanTestSupport.java} | 21 +- .../camel-infinispan-embedded/pom.xml | 134 +++ .../InfinispanEmbeddedComponentConfigurer.java}| 82 +- .../InfinispanEmbeddedEndpointConfigurer.java} | 74 +- .../InfinispanEmbeddedEndpointUriFactory.java} | 39 +- .../services/org/apache/camel/component.properties |7 + .../org/apache/camel/component/infinispan-embedded |2 + .../camel/configurer/infinispan-embedded-component |2 + .../camel/configurer/infinispan-embedded-endpoint |2 + .../camel/urifactory/infinispan-embedded-endpoint |2 + .../infinispan/embedded/infinispan-embedded.json | 69 ++ .../main/docs/infinispan-embedded-component.adoc | 490 .../InfinispanEmbeddedAggregationRepository.java | 81 ++ .../embedded/InfinispanEmbeddedComponent.java | 57 + .../embedded/InfinispanEmbeddedConfiguration.java | 155 +++ .../embedded/InfinispanEmbeddedConsumer.java | 156 +++ .../InfinispanEmbeddedCustomListener.java} | 26 +- .../embedded/InfinispanEmbeddedEndpoint.java} | 33 +- .../embedded/InfinispanEmbeddedEventListener.java | 193 .../embedded/InfinispanEmbeddedEventListeners.java | 67 ++ .../InfinispanEmbeddedIdempotentRepository.java| 96 ++ .../embedded/InfinispanEmbeddedManager.java| 147 +++ .../embedded/InfinispanEmbeddedProducer.java | 57 + .../embedded/InfinispanEmbeddedRoutePolicy.java| 150 +++ .../embedded/InfinispanEmbeddedUtil.java} | 40 +- ...beddedAggregationRepositoryOperationsTest.java} | 106 +- ...nfinispanEmbeddedAggregationRepositoryTest.java | 72 ++ .../InfinispanEmbeddedClusteredConsumerTest.java} | 36 +- .../InfinispanEmbeddedClusteredTestSupport.java} | 67 +- .../InfinispanEmbeddedConfigurationTest.java | 52 + .../embedded/InfinispanEmbeddedConsumerTest.java | 192 .../InfinispanEmbeddedCustomListenerTest.java | 110 ++ ...InfinispanEmbeddedIdempotentRepositoryTest.java | 79 ++ .../embedded/InfinispanEmbeddedProducerTest.java | 111 ++ .../InfinispanEmbeddedQueryConsumerTest.java | 130 +++ .../InfinispanEmbeddedQueryProducerTest.java} | 126 +-- .../InfinispanEmbeddedQueryTestSupport.java} |9 +-
[GitHub] [camel] github-actions[bot] opened a new pull request #4940: Generated sources regen
github-actions[bot] opened a new pull request #4940: URL: https://github.com/apache/camel/pull/4940 Regen bot :robot: found some uncommited changes after running build on :camel: master. Please do not delete `regen_bot` branch after merge/rebase. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch regen_bot updated (77650fc -> 376ec61)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. omit 77650fc Regen for commit 4d3c860f362c5c679de142d16add5d5db3ea1acf add 376ec61 Regen for commit ae2c79dcd64424acc82a29c9a46620809ea6414c (#4934) 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 (77650fc) \ N -- N -- N refs/heads/regen_bot (376ec61) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes:
[camel] branch master updated (3f5fbd4 -> 8c49517)
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 3f5fbd4 CAMEL-12489 - camel-infinspan: split remote and embedded
components (migration guide)
add 987084c Upgrade AWS SDK v2 to version 2.15.70
add 3b49128 Sync deps and regen
add 8c49517 Regen
No new revisions were added by this update.
Summary of changes:
camel-dependencies/pom.xml| 2 +-
.../resources/org/apache/camel/catalog/components.properties | 2 ++
.../org/apache/camel/catalog/components}/infinispan-embedded.json | 0
.../org/apache/camel/catalog/components}/infinispan.json | 0
.../generated/resources/org/apache/camel/catalog/docs.properties | 2 ++
.../resources/org/apache/camel/catalog/schemas/camel-spring.xsd | 8
parent/pom.xml| 2 +-
7 files changed, 6 insertions(+), 10 deletions(-)
copy
{components/camel-infinispan/camel-infinispan-embedded/src/generated/resources/org/apache/camel/component/infinispan/embedded
=>
catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components}/infinispan-embedded.json
(100%)
copy
{components/camel-infinispan/camel-infinispan/src/generated/resources/org/apache/camel/component/infinispan/remote
=>
catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components}/infinispan.json
(100%)
[camel] branch master created (now 3f5fbd4)
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. at 3f5fbd4 CAMEL-12489 - camel-infinspan: split remote and embedded components (migration guide) No new revisions were added by this update.
[GitHub] [camel] oscerd merged pull request #4939: Generated sources regen
oscerd merged pull request #4939: URL: https://github.com/apache/camel/pull/4939 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[camel] branch regen_bot updated (349973b -> 77650fc)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch regen_bot in repository https://gitbox.apache.org/repos/asf/camel.git. omit 349973b Regen for commit ae2c79dcd64424acc82a29c9a46620809ea6414c add b6bf2b7 [Camel-15341] Created camel-azure-storage-datalake component add 8dc7115 CAMEL-15341 - Regen add 6d7a474 code refractor add cc7343a CAMEL-15341 - Full regen add 84ee9f2 Regen add 988bdbb CAMEL-15341 - Regen and added back profile for skipping IT Test add 86fea84 CAMEL-15341 - Renamed IT test classes add 4d3c860 CAMEL-15341 - Fixed logging configuration add 77650fc Regen for commit 4d3c860f362c5c679de142d16add5d5db3ea1acf 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 (349973b) \ N -- N -- N refs/heads/regen_bot (77650fc) 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: bom/camel-bom/pom.xml |5 + camel-dependencies/pom.xml |2 + .../org/apache/camel/catalog/components.properties |1 + .../catalog/components/azure-storage-datalake.json | 97 + .../org/apache/camel/catalog/docs.properties |1 + .../docs/azure-storage-datalake-component.adoc | 553 + components/camel-azure-storage-datalake/pom.xml| 139 ++ .../datalake/DataLakeComponentConfigurer.java | 229 ++ .../datalake/DataLakeEndpointConfigurer.java | 231 ++ .../datalake/DataLakeEndpointUriFactory.java | 97 + .../services/org/apache/camel/component.properties |7 + .../apache/camel/component/azure-storage-datalake |2 + .../configurer/azure-storage-datalake-component|2 + .../configurer/azure-storage-datalake-endpoint |2 + .../urifactory/azure-storage-datalake-endpoint |2 + .../storage/datalake/azure-storage-datalake.json | 97 + .../docs/azure-storage-datalake-component.adoc | 553 + .../azure/storage/datalake/DataLakeComponent.java | 112 + .../storage/datalake/DataLakeConfiguration.java| 356 +++ .../DataLakeConfigurationOptionsProxy.java | 267 +++ .../azure/storage/datalake/DataLakeConstants.java | 86 + .../azure/storage/datalake/DataLakeConsumer.java | 165 ++ .../azure/storage/datalake/DataLakeEndpoint.java | 97 + .../storage/datalake/DataLakeExchangeHeaders.java | 414 .../datalake/DataLakeOperationsDefinition.java | 35 + .../azure/storage/datalake/DataLakeProducer.java | 172 ++ .../azure/storage/datalake/DataLakeUtils.java | 48 + .../storage/datalake/FileCommonRequestOptions.java | 78 + .../storage/datalake/FileStreamAndLength.java | 78 + .../datalake/client/DataLakeClientFactory.java | 94 + .../client/DataLakeDirectoryClientWrapper.java | 56 + .../datalake/client/DataLakeFileClientWrapper.java | 130 ++ .../client/DataLakeFileSystemClientWrapper.java| 70 + .../client/DataLakeServiceClientWrapper.java | 47 + .../operations/DataLakeDirectoryOperations.java| 69 + .../operations/DataLakeFileOperations.java | 240 ++ .../operations/DataLakeFileSystemOperations.java | 85 + .../operations/DataLakeOperationResponse.java | 53 + .../operations/DataLakeServiceOperations.java | 42 + .../datalake/component/DataLakeComponentTest.java | 86 + .../azure/storage/datalake/integration/BaseIT.java | 94 + .../datalake/integration/DataLakeConsumerIT.java | 224 ++ .../integration/DataLakeFileOperationIT.java | 135 ++ .../integration/DataLakeFileSystemOperationIT.java | 81 + .../operations/DataLakeDirectoryOperationTest.java | 81 + .../operations/DataLakeFileOperationTest.java | 110 + .../DataLakeFileSystemOperationTest.java | 172 ++ .../src/test/resources/log4j2.properties | 27 + components/pom.xml |1 + core/camel-allcomponents/pom.xml |4 + .../component/ComponentsBuilderFactory.java| 13 + ...zureStorageDatalakeComponentBuilderFactory.java | 641 + .../src/generated/resources/metadata.json | 22 + .../builder/endpoint/EndpointBuilderFactory.java |1 + .../camel/builder/endpoint/EndpointBuilders.java |1 + .../builder/endpoint/StaticEndpointBuilders.java | 49 + .../dsl/DataLakeEndpointBuilderFactory.java
[GitHub] [camel] github-actions[bot] opened a new pull request #4939: Generated sources regen
github-actions[bot] opened a new pull request #4939: URL: https://github.com/apache/camel/pull/4939 Regen bot :robot: found some uncommited changes after running build on :camel: master. Please do not delete `regen_bot` branch after merge/rebase. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] davsclaus opened a new issue #2171: CamelBeanPostProcessor that does not use reflection
davsclaus opened a new issue #2171: URL: https://github.com/apache/camel-quarkus/issues/2171 The DefaultCamelBeanPostProcessors does dependency injection where it via reflection gets the list of fields/methods and does annotation lookup for various annotations to do dependency injection. We should build a CamelQuarkusBeanPostProcessors that does this at build time and other means to do this in a more optimal way. This is an automated message from the 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] 05/06: CAMEL-12489 - camel-infinspan: split remote and embedded components (cleanup)
This is an automated email from the ASF dual-hosted git repository.
lburgazzoli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 8618ebae22c94f2ce601e9111cffbcdcbbdb2ab5
Author: Luca Burgazzoli
AuthorDate: Tue Jan 26 11:50:05 2021 +0100
CAMEL-12489 - camel-infinspan: split remote and embedded components
(cleanup)
---
.../apache/camel/component/infinispan/InfinispanUtil.java| 9 +
.../infinispan/embedded/InfinispanEmbeddedProducerTest.java | 12 +---
.../infinispan/embedded/InfinispanEmbeddedTestSupport.java | 1 +
3 files changed, 11 insertions(+), 11 deletions(-)
diff --git
a/components/camel-infinispan/camel-infinispan-common/src/main/java/org/apache/camel/component/infinispan/InfinispanUtil.java
b/components/camel-infinispan/camel-infinispan-common/src/main/java/org/apache/camel/component/infinispan/InfinispanUtil.java
index 95e6e1e..f9f0ebc 100644
---
a/components/camel-infinispan/camel-infinispan-common/src/main/java/org/apache/camel/component/infinispan/InfinispanUtil.java
+++
b/components/camel-infinispan/camel-infinispan-common/src/main/java/org/apache/camel/component/infinispan/InfinispanUtil.java
@@ -27,20 +27,13 @@ import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.support.ResourceHelper;
import org.apache.camel.util.ObjectHelper;
-import org.infinispan.AdvancedCache;
-import org.infinispan.commons.api.BasicCache;
public class InfinispanUtil {
protected InfinispanUtil() {
}
-@SuppressWarnings("unchecked")
-public static AdvancedCache asAdvanced(BasicCache
cache) {
-return (AdvancedCache) cache;
-}
-
public static boolean isInHeaderEmpty(Exchange exchange, String header) {
-return isHeaderEmpty(exchange.getIn(), header);
+return isHeaderEmpty(exchange.getMessage(), header);
}
public static boolean isHeaderEmpty(Message message, String header) {
diff --git
a/components/camel-infinispan/camel-infinispan-embedded/src/test/java/org/apache/camel/component/infinispan/embedded/InfinispanEmbeddedProducerTest.java
b/components/camel-infinispan/camel-infinispan-embedded/src/test/java/org/apache/camel/component/infinispan/embedded/InfinispanEmbeddedProducerTest.java
index 46a4a1c..3f0acc8 100644
---
a/components/camel-infinispan/camel-infinispan-embedded/src/test/java/org/apache/camel/component/infinispan/embedded/InfinispanEmbeddedProducerTest.java
+++
b/components/camel-infinispan/camel-infinispan-embedded/src/test/java/org/apache/camel/component/infinispan/embedded/InfinispanEmbeddedProducerTest.java
@@ -23,8 +23,8 @@ import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.infinispan.InfinispanConstants;
import org.apache.camel.component.infinispan.InfinispanOperation;
import org.apache.camel.component.infinispan.InfinispanProducerTestSupport;
-import org.apache.camel.component.infinispan.InfinispanUtil;
import org.infinispan.commons.api.BasicCache;
+import org.infinispan.configuration.cache.ConfigurationBuilder;
import org.infinispan.stats.Stats;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
@@ -37,10 +37,16 @@ public class InfinispanEmbeddedProducerTest extends
InfinispanEmbeddedTestSuppor
return (k, v) -> v + "replay";
}
+@Override
+protected ConfigurationBuilder getConfiguration() {
+ConfigurationBuilder builder = super.getConfiguration();
+builder.statistics().enable();
+
+return builder;
+}
+
@Test
public void statsOperation() {
-
InfinispanUtil.asAdvanced(getCache()).getStats().setStatisticsEnabled(true);
-
fluentTemplate()
.to("direct:start")
.withHeader(InfinispanConstants.KEY,
InfinispanProducerTestSupport.KEY_ONE)
diff --git
a/components/camel-infinispan/camel-infinispan-embedded/src/test/java/org/apache/camel/component/infinispan/embedded/InfinispanEmbeddedTestSupport.java
b/components/camel-infinispan/camel-infinispan-embedded/src/test/java/org/apache/camel/component/infinispan/embedded/InfinispanEmbeddedTestSupport.java
index e887c9c..f99da99 100644
---
a/components/camel-infinispan/camel-infinispan-embedded/src/test/java/org/apache/camel/component/infinispan/embedded/InfinispanEmbeddedTestSupport.java
+++
b/components/camel-infinispan/camel-infinispan-embedded/src/test/java/org/apache/camel/component/infinispan/embedded/InfinispanEmbeddedTestSupport.java
@@ -65,6 +65,7 @@ public class InfinispanEmbeddedTestSupport extends
InfinispanTestSupport {
protected ConfigurationBuilder getConfiguration() {
ConfigurationBuilder builder = new ConfigurationBuilder();
builder.clustering().cacheMode(CacheMode.LOCAL);
+
return builder;
}
[camel] 03/06: CAMEL-12489 - camel-infinspan: split remote and embedded components (fix findings)
This is an automated email from the ASF dual-hosted git repository.
lburgazzoli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit b334a5ed1e948ca77daaab22b271cf9d1d148e1f
Author: Luca Burgazzoli
AuthorDate: Mon Jan 25 11:03:51 2021 +0100
CAMEL-12489 - camel-infinspan: split remote and embedded components (fix
findings)
---
.../camel/catalog/docs/infinispan-component.adoc | 495
.../docs/infinispan-embedded-component.adoc| 843 +
.../component/infinispan/InfinispanConsumer.java | 6 +-
.../remote/InfinispanRemoteProducerTest.java | 2 +-
.../remote/InfinispanRemoteTestSupport.java| 6 +-
...inispanRemoteIdempotentRepositoryCamelTest.java | 4 +-
...nispanRemoteIdempotentRepositorySpringTest.java | 1 +
...ispanRemoteIdempotentRepositoryTestSupport.java | 3 +-
.../camel/maven/packaging/PrepareCatalogMojo.java | 113 +--
9 files changed, 1410 insertions(+), 63 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/infinispan-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/infinispan-component.adoc
new file mode 100644
index 000..0ba396c
--- /dev/null
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/infinispan-component.adoc
@@ -0,0 +1,495 @@
+[[infinispan-component]]
+= Infinispan Component
+:docTitle: Infinispan
+:artifactId: camel-infinispan
+:description: Read and write from/to Infinispan distributed key/value store
and data grid.
+:since: 2.13
+:supportLevel: Stable
+:component-header: Both producer and consumer are supported
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/components/infinispan.adoc[opts=optional]
+
+*Since Camel {since}*
+
+*{component-header}*
+
+This component allows you to interact with http://infinispan.org/[Infinispan]
distributed data grid / cache using the Hot Rod procol.
+Infinispan is an extremely scalable, highly available key/value data store and
data grid platform written in Java.
+
+Infinispan requires at least Java 8.
+
+If you use Maven, you must add the following dependency to your `pom.xml`:
+
+[source,xml]
+
+
+org.apache.camel
+camel-infinispan
+x.x.x
+
+
+
+
+== URI format
+
+[source,java]
+---
+infinispan://cacheName?[options]
+---
+
+== URI Options
+
+The producer allows sending messages to a remote cache using the HotRod
protocol.
+The consumer allows listening for events from a remote cache using the HotRod
protocol.
+
+// component options: START
+The Infinispan component supports 26 options, which are listed below.
+
+
+
+[width="100%",cols="2,5,^1,2",options="header"]
+|===
+| Name | Description | Default | Type
+| *configuration* (common) | Component configuration | |
InfinispanRemoteConfiguration
+| *hosts* (common) | Specifies the host of the cache on Infinispan instance |
| String
+| *queryBuilder* (common) | Specifies the query builder. | |
InfinispanQueryBuilder
+| *secure* (common) | Define if we are connecting to a secured Infinispan
instance | false | boolean
+| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions occurred while the
consumer is trying to pickup incoming messages, or the likes, will now be
processed as a message and handled by the routing Error Handler. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored. | false |
boolean
+| *customListener* (consumer) | Returns the custom listener in use, if
provided | | InfinispanRemoteCustomListener
+| *eventTypes* (consumer) | Specifies the set of event types to register by
the consumer.Multiple event can be separated by comma. The possible event types
are: CLIENT_CACHE_ENTRY_CREATED, CLIENT_CACHE_ENTRY_MODIFIED,
CLIENT_CACHE_ENTRY_REMOVED, CLIENT_CACHE_ENTRY_EXPIRED, CLIENT_CACHE_FAILOVER |
| String
+| *defaultValue* (producer) | Set a specific default value for some producer
operations | | Object
+| *key* (producer) | Set a specific key for producer operations | | Object
+| *lazyStartProducer* (producer) | Whether the producer should be started lazy
(on the first message). By starting lazy you can use this to allow CamelContext
and routes to startup in situations where a producer may otherwise fail during
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
+| *oldValue* (producer) | Set a specific old value for some
[camel] 06/06: CAMEL-12489 - camel-infinspan: split remote and embedded components (migration guide)
This is an automated email from the ASF dual-hosted git repository. lburgazzoli pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git commit 3f5fbd4d5480c4f00d616d6db599c451e44fd414 Author: Luca Burgazzoli AuthorDate: Tue Jan 26 17:39:15 2021 +0100 CAMEL-12489 - camel-infinspan: split remote and embedded components (migration guide) --- .../ROOT/pages/camel-3x-upgrade-guide-3_8.adoc| 19 +++ 1 file changed, 19 insertions(+) diff --git a/docs/user-manual/modules/ROOT/pages/camel-3x-upgrade-guide-3_8.adoc b/docs/user-manual/modules/ROOT/pages/camel-3x-upgrade-guide-3_8.adoc index 30ee669..b381567 100644 --- a/docs/user-manual/modules/ROOT/pages/camel-3x-upgrade-guide-3_8.adoc +++ b/docs/user-manual/modules/ROOT/pages/camel-3x-upgrade-guide-3_8.adoc @@ -75,3 +75,22 @@ Other information has been stored in headers declared in GitHubConstants class: * GITHUB_EVENT_PAYLOAD - "CamelGitHubEventPayload" - The event payload + +=== camel-infinispan + +There are now two components for Infinispan: + +- *camel-infinispan* to integrate with remote caches through the Hot Rod protocol (scheme: *infinispan*). +- *camel-infinispan-embedded* to integrate with local/embedded caches (scheme: *infinispan-embedded*). + +As conseguence of the refactor + +- the remote and embedded endpoints provide support the same capabilities, as example queries were only possible on a remote cache and now they are suported on both remote and local/embedded caches +- the configuration options for the endpoint are now specific to the context which remove the possibility to mix unrelated propertis +- some classes have been relocated, as example, indempotent and aggregation repositories have been moved from `org.apache.camel.component.infinispan.processor.*` to `org.apache.camel.component.infinispan.embedded` or `org.apache.camel.component.infinispan.remote`: ++ +org.apache.camel.component.infinispan.embedded.InfinispanEmbeddedAggregationRepository +org.apache.camel.component.infinispan.embedded.InfinispanEmbeddedIdempotentRepository +org.apache.camel.component.infinispan.remote.InfinispanRemoteAggregationRepository +org.apache.camel.component.infinispan.remote.InfinispanRemoteIdempotentRepository +
[camel] branch master updated (376ec61 -> 3f5fbd4)
This is an automated email from the ASF dual-hosted git repository. lburgazzoli pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/camel.git. from 376ec61 Regen for commit ae2c79dcd64424acc82a29c9a46620809ea6414c (#4934) new 573ae84 CAMEL-12489 - camel-infinspan: split remote and embedded components new 37f2ec4 CAMEL-12489 - camel-infinspan: split remote and embedded components (split) new b334a5e CAMEL-12489 - camel-infinspan: split remote and embedded components (fix findings) new c9cdc67 CAMEL-12489 - camel-infinspan: split remote and embedded components (docs) new 8618eba CAMEL-12489 - camel-infinspan: split remote and embedded components (cleanup) new 3f5fbd4 CAMEL-12489 - camel-infinspan: split remote and embedded components (migration guide) The 6 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: bom/camel-bom/pom.xml | 15 + .../org/apache/camel/catalog/components.properties |1 - .../camel/catalog/components/infinispan.json | 87 -- .../org/apache/camel/catalog/docs.properties |1 - .../camel/catalog/docs/infinispan-component.adoc | 853 -- .../docs/infinispan-embedded-component.adoc| 490 .../camel-infinispan-common/pom.xml| 107 ++ .../InfinispanAggregationRepository.java} | 120 +- .../component/infinispan/InfinispanComponent.java} | 14 +- .../infinispan/InfinispanConfiguration.java| 136 +++ .../component/infinispan/InfinispanConstants.java |5 + .../component/infinispan/InfinispanConsumer.java | 80 ++ .../component/infinispan/InfinispanEndpoint.java} | 13 +- .../infinispan/InfinispanEventListener.java| 38 +- .../infinispan/InfinispanEventProcessor.java} |8 +- .../infinispan/InfinispanIdempotentRepository.java | 85 ++ .../component/infinispan/InfinispanManager.java| 55 + .../component/infinispan/InfinispanOperation.java |0 .../component/infinispan/InfinispanProducer.java | 335 ++ .../infinispan/InfinispanQueryBuilder.java |5 + .../infinispan/InfinispanRoutePolicy.java | 246 .../camel/component/infinispan/InfinispanUtil.java | 69 ++ .../infinispan/InfinispanConsumerTestSupport.java} | 15 +- .../InfinispanIdempotentRepositoryTestSupport.java | 103 ++ .../infinispan/InfinispanProducerTestSupport.java | 868 +++ .../InfinispanRoutePolicyTestSupport.java | 58 + .../infinispan/InfinispanTestSupport.java} | 21 +- .../camel-infinispan-embedded/pom.xml | 134 +++ .../InfinispanEmbeddedComponentConfigurer.java}| 82 +- .../InfinispanEmbeddedEndpointConfigurer.java} | 74 +- .../InfinispanEmbeddedEndpointUriFactory.java} | 39 +- .../services/org/apache/camel/component.properties |7 + .../org/apache/camel/component/infinispan-embedded |2 + .../camel/configurer/infinispan-embedded-component |2 + .../camel/configurer/infinispan-embedded-endpoint |2 + .../camel/urifactory/infinispan-embedded-endpoint |2 + .../infinispan/embedded/infinispan-embedded.json | 69 ++ .../main/docs/infinispan-embedded-component.adoc | 490 .../InfinispanEmbeddedAggregationRepository.java | 81 ++ .../embedded/InfinispanEmbeddedComponent.java | 57 + .../embedded/InfinispanEmbeddedConfiguration.java | 155 +++ .../embedded/InfinispanEmbeddedConsumer.java | 156 +++ .../InfinispanEmbeddedCustomListener.java} | 26 +- .../embedded/InfinispanEmbeddedEndpoint.java} | 33 +- .../embedded/InfinispanEmbeddedEventListener.java | 193 .../embedded/InfinispanEmbeddedEventListeners.java | 67 ++ .../InfinispanEmbeddedIdempotentRepository.java| 96 ++ .../embedded/InfinispanEmbeddedManager.java| 147 +++ .../embedded/InfinispanEmbeddedProducer.java | 57 + .../embedded/InfinispanEmbeddedRoutePolicy.java| 150 +++ .../embedded/InfinispanEmbeddedUtil.java} | 40 +- ...beddedAggregationRepositoryOperationsTest.java} | 106 +- ...nfinispanEmbeddedAggregationRepositoryTest.java | 72 ++ .../InfinispanEmbeddedClusteredConsumerTest.java} | 36 +- .../InfinispanEmbeddedClusteredTestSupport.java} | 67 +- .../InfinispanEmbeddedConfigurationTest.java | 52 + .../embedded/InfinispanEmbeddedConsumerTest.java | 192 .../InfinispanEmbeddedCustomListenerTest.java | 110 ++ ...InfinispanEmbeddedIdempotentRepositoryTest.java | 79 ++ .../embedded/InfinispanEmbeddedProducerTest.java | 111 ++ .../InfinispanEmbeddedQueryConsumerTest.java | 130 +++ .../InfinispanEmbeddedQueryProducerTest.java} | 126 +--
[GitHub] [camel] lburgazzoli merged pull request #4913: CAMEL-12489 - camel-infinspan: split remote and embedded components
lburgazzoli merged pull request #4913: URL: https://github.com/apache/camel/pull/4913 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] lburgazzoli commented on pull request #4935: CAMEL-16080: Migrate camel-kamelet component from camel-k-runtime to camel
lburgazzoli commented on pull request #4935: URL: https://github.com/apache/camel/pull/4935#issuecomment-768062146 > And it would be nice with an example at camel-examples git repo will create one once merged This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] lburgazzoli commented on pull request #4935: CAMEL-16080: Migrate camel-kamelet component from camel-k-runtime to camel
lburgazzoli commented on pull request #4935: URL: https://github.com/apache/camel/pull/4935#issuecomment-768061998 > I can only find some bits in the doc page. I tend to like that things are named myXXX when its something that the end user can freely choose. fixed This is an automated message from the 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] WillemJiang commented on a change in pull request #4900: [CAMEL-16001] Camel component for HuaweiCloud Simple Notification Services (SMN) se…
WillemJiang commented on a change in pull request #4900:
URL: https://github.com/apache/camel/pull/4900#discussion_r565053683
##
File path:
components/camel-huaweicloud-smn/src/main/java/org/apache/camel/component/huaweicloud/smn/SimpleNotificationUtils.java
##
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.huaweicloud.smn;
+
+import com.huaweicloud.sdk.core.region.Region;
+import com.huaweicloud.sdk.smn.v2.region.SmnRegion;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * utility functions for the component
+ */
+public class SimpleNotificationUtils {
+private static final Logger LOG =
LoggerFactory.getLogger(SimpleNotificationUtils.class.getName());
+
+/**
+ * resolves endpoint url for the given region
+ *
+ * @param region
+ * @return
+ */
+public static String resolveSmnServiceEndpoint(String region) {
+if (region == null) {
+return null;
+}
+
+String result = null;
+
+try {
+String formattedEndpointKey = formatEndpointKey(region);
Review comment:
@mathewsreji you are still use getField() method.
This is an automated message from the 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] WillemJiang commented on a change in pull request #4900: [CAMEL-16001] Camel component for HuaweiCloud Simple Notification Services (SMN) se…
WillemJiang commented on a change in pull request #4900: URL: https://github.com/apache/camel/pull/4900#discussion_r565051872 ## File path: components/camel-huaweicloud-smn/pom.xml ## @@ -0,0 +1,121 @@ + +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;> Review comment: Please add ASF license header here. This is an automated message from the 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: Regen for commit ae2c79dcd64424acc82a29c9a46620809ea6414c (#4934)
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 376ec61 Regen for commit ae2c79dcd64424acc82a29c9a46620809ea6414c (#4934) 376ec61 is described below commit 376ec619e3caab6b7958505d485127bf711dc97b Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Wed Jan 27 06:58:06 2021 +0100 Regen for commit ae2c79dcd64424acc82a29c9a46620809ea6414c (#4934) Signed-off-by: GitHub Co-authored-by: oscerd --- .../resources/org/apache/camel/catalog/schemas/camel-spring.xsd | 8 1 file changed, 8 insertions(+) diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd index 2167e5e..efd3087 100644 --- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd +++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd @@ -2609,6 +2609,14 @@ this and can report the Camel application as DOWN. Default value: false ]]> + + + + +
[GitHub] [camel] davsclaus merged pull request #4934: Generated sources regen
davsclaus merged pull request #4934: URL: https://github.com/apache/camel/pull/4934 This is an automated message from the 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 a change in pull request #4936: CAMEL-15933: Add Stitch component to Camel
davsclaus commented on a change in pull request #4936:
URL: https://github.com/apache/camel/pull/4936#discussion_r565044051
##
File path:
components/camel-stitch/src/main/java/org/apache/camel/component/stitch/StitchConfiguration.java
##
@@ -0,0 +1,163 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.stitch;
+
+import java.util.Collection;
+import java.util.HashSet;
+
+import org.apache.camel.RuntimeCamelException;
+import org.apache.camel.component.stitch.client.StitchClient;
+import org.apache.camel.component.stitch.client.StitchRegion;
+import org.apache.camel.component.stitch.client.models.StitchSchema;
+import org.apache.camel.spi.Metadata;
+import org.apache.camel.spi.UriParam;
+import org.apache.camel.spi.UriParams;
+import org.apache.camel.spi.UriPath;
+import reactor.netty.http.client.HttpClient;
+import reactor.netty.resources.ConnectionProvider;
+
+@UriParams
+public class StitchConfiguration implements Cloneable {
+
+@UriPath
+private String tableName;
+@UriParam(label = "security", secret = true)
+@Metadata(required = true)
+private String token;
+@UriParam(label = "producer", defaultValue = "europe")
+private StitchRegion region = StitchRegion.EUROPE;
+@UriParam(label = "producer")
+@Metadata(autowired = true)
+private StitchSchema stitchSchema;
+@UriParam(label = "producer")
+private Collection keyNames = new HashSet<>();
Review comment:
It would be good to also allow to set keyNames as a string value, where
they keys are seperated with comma, then its easier to configure in endpoint
uri. Some components offer that.
##
File path:
components/camel-stitch/src/main/java/org/apache/camel/component/stitch/StitchEndpoint.java
##
@@ -0,0 +1,102 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.stitch;
+
+import org.apache.camel.Category;
+import org.apache.camel.Component;
+import org.apache.camel.Consumer;
+import org.apache.camel.Processor;
+import org.apache.camel.Producer;
+import org.apache.camel.component.stitch.client.StitchClient;
+import org.apache.camel.component.stitch.client.StitchClientBuilder;
+import org.apache.camel.spi.UriEndpoint;
+import org.apache.camel.spi.UriParam;
+import org.apache.camel.support.DefaultEndpoint;
+
+/**
+ * Stitch is a cloud ETL service, developer-focused platform for rapidly
moving and replicates data from more than 90
Review comment:
All this becomes a too long description. Can you make a shorter one
sentence in the top and end it with a dot. Then the tooling with grab the first
sentence and use as description summary in the metadata.
Too long makes the component table looks bad etc.
##
File path:
components/camel-stitch/src/main/java/org/apache/camel/component/stitch/StitchConfiguration.java
##
@@ -0,0 +1,163 @@
+/*
+ * 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
[camel] 06/08: CAMEL-15341 - Regen and added back profile for skipping IT Test
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 988bdbbc5a3f6a13d8a2b57dbc9c9dff24b21e7c
Author: Andrea Cosentino
AuthorDate: Wed Jan 27 06:40:08 2021 +0100
CAMEL-15341 - Regen and added back profile for skipping IT Test
---
.../docs/azure-storage-datalake-component.adoc | 1 +
components/camel-azure-storage-datalake/pom.xml| 29 ++
.../pages/azure-storage-datalake-component.adoc| 1 +
3 files changed, 31 insertions(+)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-storage-datalake-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-storage-datalake-component.adoc
index bc6f3e6..aafb47d 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-storage-datalake-component.adoc
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-storage-datalake-component.adoc
@@ -550,3 +550,4 @@ You can also skip the integration test, and run only basic
unit test by using th
mvn test
+
diff --git a/components/camel-azure-storage-datalake/pom.xml
b/components/camel-azure-storage-datalake/pom.xml
index b4ecd6b..1c5fba3 100644
--- a/components/camel-azure-storage-datalake/pom.xml
+++ b/components/camel-azure-storage-datalake/pom.xml
@@ -106,5 +106,34 @@
test
+
+
+fullTests
+
+
+
+maven-surefire-plugin
+${maven-surefire-plugin-version}
+
+
+integration-test
+
+test
+
+
+
+none
+
+
+**/*IT
+
+
+
+
+
+
+
+
+
diff --git
a/docs/components/modules/ROOT/pages/azure-storage-datalake-component.adoc
b/docs/components/modules/ROOT/pages/azure-storage-datalake-component.adoc
index fffe00e..11f651a 100644
--- a/docs/components/modules/ROOT/pages/azure-storage-datalake-component.adoc
+++ b/docs/components/modules/ROOT/pages/azure-storage-datalake-component.adoc
@@ -552,3 +552,4 @@ You can also skip the integration test, and run only basic
unit test by using th
mvn test
+
[camel] 05/08: 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.git
commit 84ee9f26b9dadebf581410fb711d497be9192041
Author: Andrea Cosentino
AuthorDate: Tue Jan 26 19:18:03 2021 +0100
Regen
---
components/camel-azure-storage-datalake/pom.xml| 29 --
.../azure/storage/datalake/integration/BaseIT.java | 2 ++
...ConsumerIT.java => DataLakeConsumerITTest.java} | 4 +--
...ionIT.java => DataLakeFileOperationITTest.java} | 4 ++-
...java => DataLakeFileSystemOperationITTest.java} | 4 ++-
5 files changed, 10 insertions(+), 33 deletions(-)
diff --git a/components/camel-azure-storage-datalake/pom.xml
b/components/camel-azure-storage-datalake/pom.xml
index 1c5fba3..b4ecd6b 100644
--- a/components/camel-azure-storage-datalake/pom.xml
+++ b/components/camel-azure-storage-datalake/pom.xml
@@ -106,34 +106,5 @@
test
-
-
-fullTests
-
-
-
-maven-surefire-plugin
-${maven-surefire-plugin-version}
-
-
-integration-test
-
-test
-
-
-
-none
-
-
-**/*IT
-
-
-
-
-
-
-
-
-
diff --git
a/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/BaseIT.java
b/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/BaseIT.java
index dea734f..ceaa970 100644
---
a/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/BaseIT.java
+++
b/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/BaseIT.java
@@ -33,10 +33,12 @@ import
org.apache.camel.test.infra.azure.storage.datalake.services.AzureStorageD
import org.apache.camel.test.junit5.CamelTestSupport;
import org.apache.commons.lang3.RandomStringUtils;
import org.apache.commons.lang3.StringUtils;
+import org.junit.Ignore;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.TestInstance;
import org.junit.jupiter.api.extension.RegisterExtension;
+@Ignore
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
public class BaseIT extends CamelTestSupport {
diff --git
a/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeConsumerIT.java
b/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeConsumerITTest.java
similarity index 99%
rename from
components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeConsumerIT.java
rename to
components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeConsumerITTest.java
index 4bd0062..5ce5afb 100644
---
a/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeConsumerIT.java
+++
b/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeConsumerITTest.java
@@ -50,11 +50,11 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
-public class DataLakeConsumerIT extends BaseIT {
+public class DataLakeConsumerITTest extends BaseIT {
@TempDir
static Path testDir;
-private static final Logger LOG =
LoggerFactory.getLogger(DataLakeConsumerIT.class);
+private static final Logger LOG =
LoggerFactory.getLogger(DataLakeConsumerITTest.class);
@EndpointInject("direct:createFile")
private ProducerTemplate templateStart;
diff --git
a/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeFileOperationIT.java
b/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeFileOperationITTest.java
similarity index 98%
rename from
[camel] 08/08: CAMEL-15341 - Fixed logging configuration
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 4d3c860f362c5c679de142d16add5d5db3ea1acf
Author: Andrea Cosentino
AuthorDate: Wed Jan 27 06:42:50 2021 +0100
CAMEL-15341 - Fixed logging configuration
---
.../src/test/resources/log4j2.properties | 20 +++-
1 file changed, 11 insertions(+), 9 deletions(-)
diff --git
a/components/camel-azure-storage-datalake/src/test/resources/log4j2.properties
b/components/camel-azure-storage-datalake/src/test/resources/log4j2.properties
index ff832d3..b2c5e71 100644
---
a/components/camel-azure-storage-datalake/src/test/resources/log4j2.properties
+++
b/components/camel-azure-storage-datalake/src/test/resources/log4j2.properties
@@ -14,12 +14,14 @@
## See the License for the specific language governing permissions and
## limitations under the License.
## ---
-appender.out.layout.pattern=%d [%15.15t] %highlight{%-5p} %-30.30c - %m%n
-appender.out.layout.type=PatternLayout
-appender.out.name=out
-appender.out.type=Console
-logger.mine.level=INFO
-logger.mine.name=org.apache.camel.component.chuck
-loggers=mine
-rootLogger.appenderRef.out.ref=out
-rootLogger.level=INFO
+appender.file.type = File
+appender.file.name = file
+appender.file.fileName = target/camel-azure-storage-datalake-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 = %d [%-15.15t] %-5p %-30.30c{1} - %m%n
+rootLogger.level = INFO
+rootLogger.appenderRef.file.ref = file
[camel] 07/08: CAMEL-15341 - Renamed IT test classes
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 86fea848310ce46c859586d62431d77bbdd97cfc
Author: Andrea Cosentino
AuthorDate: Wed Jan 27 06:41:55 2021 +0100
CAMEL-15341 - Renamed IT test classes
---
.../{DataLakeConsumerITTest.java => DataLakeConsumerIT.java} | 4 ++--
...{DataLakeFileOperationITTest.java => DataLakeFileOperationIT.java} | 2 +-
...eSystemOperationITTest.java => DataLakeFileSystemOperationIT.java} | 2 +-
3 files changed, 4 insertions(+), 4 deletions(-)
diff --git
a/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeConsumerITTest.java
b/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeConsumerIT.java
similarity index 99%
rename from
components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeConsumerITTest.java
rename to
components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeConsumerIT.java
index 5ce5afb..4bd0062 100644
---
a/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeConsumerITTest.java
+++
b/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeConsumerIT.java
@@ -50,11 +50,11 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
-public class DataLakeConsumerITTest extends BaseIT {
+public class DataLakeConsumerIT extends BaseIT {
@TempDir
static Path testDir;
-private static final Logger LOG =
LoggerFactory.getLogger(DataLakeConsumerITTest.class);
+private static final Logger LOG =
LoggerFactory.getLogger(DataLakeConsumerIT.class);
@EndpointInject("direct:createFile")
private ProducerTemplate templateStart;
diff --git
a/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeFileOperationITTest.java
b/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeFileOperationIT.java
similarity index 99%
rename from
components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeFileOperationITTest.java
rename to
components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeFileOperationIT.java
index 7189c20..c51233c 100644
---
a/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeFileOperationITTest.java
+++
b/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeFileOperationIT.java
@@ -47,7 +47,7 @@ import org.junit.jupiter.api.io.TempDir;
import static org.junit.jupiter.api.Assertions.*;
@Ignore
-public class DataLakeFileOperationITTest extends BaseIT {
+public class DataLakeFileOperationIT extends BaseIT {
private DataLakeFileSystemClientWrapper fileSystemClientWrapper;
private String randomFileName;
diff --git
a/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeFileSystemOperationITTest.java
b/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeFileSystemOperationIT.java
similarity index 98%
rename from
components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeFileSystemOperationITTest.java
rename to
components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeFileSystemOperationIT.java
index 99d02e8..72bd016 100644
---
a/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeFileSystemOperationITTest.java
+++
b/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeFileSystemOperationIT.java
@@ -33,7 +33,7 @@ import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.*;
@Ignore
-public class DataLakeFileSystemOperationITTest extends BaseIT {
+public class DataLakeFileSystemOperationIT extends BaseIT {
private DataLakeServiceClientWrapper serviceClientWrapper;
[camel] 02/08: CAMEL-15341 - 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.git
commit 8dc711564af34eb60bb290c405e980f66d136567
Author: Andrea Cosentino
AuthorDate: Tue Jan 26 17:17:59 2021 +0100
CAMEL-15341 - Regen
---
bom/camel-bom/pom.xml | 5 ++
camel-dependencies/pom.xml | 4 +
.../org/apache/camel/catalog/components.properties | 1 +
.../catalog/components/azure-storage-datalake.json | 97 ++
.../org/apache/camel/catalog/docs.properties | 1 +
docs/components/modules/ROOT/nav.adoc | 1 +
6 files changed, 109 insertions(+)
diff --git a/bom/camel-bom/pom.xml b/bom/camel-bom/pom.xml
index 9092713..23eac32 100644
--- a/bom/camel-bom/pom.xml
+++ b/bom/camel-bom/pom.xml
@@ -343,6 +343,11 @@
org.apache.camel
+camel-azure-storage-datalake
+${project.version}
+
+
+org.apache.camel
camel-azure-storage-queue
${project.version}
diff --git a/camel-dependencies/pom.xml b/camel-dependencies/pom.xml
index 092a28d..f981164 100644
--- a/camel-dependencies/pom.xml
+++ b/camel-dependencies/pom.xml
@@ -1,17 +1,21 @@
http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd;
xmlns="http://maven.apache.org/POM/4.0.0;
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;>
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
index cd3174c..8773a62 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
@@ -63,6 +63,7 @@ azure-blob
azure-eventhubs
azure-queue
azure-storage-blob
+azure-storage-datalake
azure-storage-queue
bean
bean-validator
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/azure-storage-datalake.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/azure-storage-datalake.json
new file mode 100644
index 000..344bc7b
--- /dev/null
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/azure-storage-datalake.json
@@ -0,0 +1,97 @@
+{
+ "component": {
+"kind": "component",
+"name": "azure-storage-datalake",
+"title": "Azure storage datalake service",
+"description": "Camel Azure Datalake Gen2 Component",
+"deprecated": false,
+"firstVersion": "3.8.0",
+"label": "cloud,file",
+"javaType":
"org.apache.camel.component.azure.storage.datalake.DataLakeComponent",
+"supportLevel": "Preview",
+"groupId": "org.apache.camel",
+"artifactId": "camel-azure-storage-datalake",
+"version": "3.8.0-SNAPSHOT",
+"scheme": "azure-storage-datalake",
+"extendsScheme": "",
+"syntax": "azure-storage-datalake:accountName\/fileSystemName",
+"async": false,
+"api": false,
+"consumerOnly": false,
+"producerOnly": false,
+"lenientProperties": false
+ },
+ "componentProperties": {
+"accountKey": { "kind": "property", "displayName": "Account Key", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "account key for
authentication" },
+"clientId": { "kind": "property", "displayName": "Client Id", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client id for azure
account" },
+"clientSecret": { "kind": "property", "displayName": "Client Secret",
"group": "common", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField": "configuration", "description": "client secret for azure
account" },
+"clientSecretCredential": { "kind": "property", "displayName": "Client
Secret Credential", "group": "common", "label": "", "required": false, "type":
"object", "javaType": "com.azure.identity.ClientSecretCredential",
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.azure.storage.datalake.DataLakeConfiguration",
"configurationField":
[camel] 03/08: code refractor
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 6d7a4742e366fce32df9d48c3adc2d6f882bd154
Author: aryankoul
AuthorDate: Tue Jan 26 23:18:13 2021 +0530
code refractor
---
components/camel-azure-storage-datalake/pom.xml| 29 ++
.../docs/azure-storage-datalake-component.adoc | 9 ++-
...keConsumerTest.java => DataLakeConsumerIT.java} | 4 +--
...ationTest.java => DataLakeFileOperationIT.java} | 2 +-
...est.java => DataLakeFileSystemOperationIT.java} | 2 +-
5 files changed, 41 insertions(+), 5 deletions(-)
diff --git a/components/camel-azure-storage-datalake/pom.xml
b/components/camel-azure-storage-datalake/pom.xml
index b4ecd6b..1c5fba3 100644
--- a/components/camel-azure-storage-datalake/pom.xml
+++ b/components/camel-azure-storage-datalake/pom.xml
@@ -106,5 +106,34 @@
test
+
+
+fullTests
+
+
+
+maven-surefire-plugin
+${maven-surefire-plugin-version}
+
+
+integration-test
+
+test
+
+
+
+none
+
+
+**/*IT
+
+
+
+
+
+
+
+
+
diff --git
a/components/camel-azure-storage-datalake/src/main/docs/azure-storage-datalake-component.adoc
b/components/camel-azure-storage-datalake/src/main/docs/azure-storage-datalake-component.adoc
index e6fcd5e..aafb47d 100644
---
a/components/camel-azure-storage-datalake/src/main/docs/azure-storage-datalake-component.adoc
+++
b/components/camel-azure-storage-datalake/src/main/docs/azure-storage-datalake-component.adoc
@@ -541,6 +541,13 @@ For running all the test in the component, you will need
to obtain azure account
can run the full test, on this component directory, by running the following
maven command
-mvn test -Dazure.storage.account.name=accountName
-Dazure.storage.account.key=accountKey
+mvn verify -PfullTests -Dazure.storage.account.name=
-Dazure.storage.account.key=
+You can also skip the integration test, and run only basic unit test by using
the command
+
+
+mvn test
+
+
+
diff --git
a/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeConsumerTest.java
b/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeConsumerIT.java
similarity index 99%
rename from
components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeConsumerTest.java
rename to
components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeConsumerIT.java
index 53bb232..4bd0062 100644
---
a/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeConsumerTest.java
+++
b/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeConsumerIT.java
@@ -50,11 +50,11 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
-public class DataLakeConsumerTest extends BaseIT {
+public class DataLakeConsumerIT extends BaseIT {
@TempDir
static Path testDir;
-private static final Logger LOG =
LoggerFactory.getLogger(DataLakeConsumerTest.class);
+private static final Logger LOG =
LoggerFactory.getLogger(DataLakeConsumerIT.class);
@EndpointInject("direct:createFile")
private ProducerTemplate templateStart;
diff --git
a/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeFileOperationTest.java
b/components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeFileOperationIT.java
similarity index 99%
rename from
components/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/integration/DataLakeFileOperationTest.java
rename to
[camel] 04/08: CAMEL-15341 - Full 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.git commit cc7343ac369f807434da5d65a327308a12b51606 Author: Andrea Cosentino AuthorDate: Tue Jan 26 19:03:26 2021 +0100 CAMEL-15341 - Full regen --- .../camel/catalog/docs/azure-storage-datalake-component.adoc | 8 +++- .../modules/ROOT/pages/azure-storage-datalake-component.adoc | 8 +++- 2 files changed, 14 insertions(+), 2 deletions(-) diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-storage-datalake-component.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-storage-datalake-component.adoc index e6fcd5e..bc6f3e6 100644 --- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-storage-datalake-component.adoc +++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/azure-storage-datalake-component.adoc @@ -541,6 +541,12 @@ For running all the test in the component, you will need to obtain azure account can run the full test, on this component directory, by running the following maven command -mvn test -Dazure.storage.account.name=accountName -Dazure.storage.account.key=accountKey +mvn verify -PfullTests -Dazure.storage.account.name= -Dazure.storage.account.key= + + +You can also skip the integration test, and run only basic unit test by using the command + + +mvn test diff --git a/docs/components/modules/ROOT/pages/azure-storage-datalake-component.adoc b/docs/components/modules/ROOT/pages/azure-storage-datalake-component.adoc index c95eecb..fffe00e 100644 --- a/docs/components/modules/ROOT/pages/azure-storage-datalake-component.adoc +++ b/docs/components/modules/ROOT/pages/azure-storage-datalake-component.adoc @@ -543,6 +543,12 @@ For running all the test in the component, you will need to obtain azure account can run the full test, on this component directory, by running the following maven command -mvn test -Dazure.storage.account.name=accountName -Dazure.storage.account.key=accountKey +mvn verify -PfullTests -Dazure.storage.account.name= -Dazure.storage.account.key= + + +You can also skip the integration test, and run only basic unit test by using the command + + +mvn test
[camel] branch master updated (ae2c79d -> 4d3c860)
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 ae2c79d Full build new b6bf2b7 [Camel-15341] Created camel-azure-storage-datalake component new 8dc7115 CAMEL-15341 - Regen new 6d7a474 code refractor new cc7343a CAMEL-15341 - Full regen new 84ee9f2 Regen new 988bdbb CAMEL-15341 - Regen and added back profile for skipping IT Test new 86fea84 CAMEL-15341 - Renamed IT test classes new 4d3c860 CAMEL-15341 - Fixed logging configuration The 8 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: bom/camel-bom/pom.xml |5 + camel-dependencies/pom.xml |2 + .../org/apache/camel/catalog/components.properties |1 + .../catalog/components/azure-storage-datalake.json | 97 + .../org/apache/camel/catalog/docs.properties |1 + .../docs/azure-storage-datalake-component.adoc | 553 + components/camel-azure-storage-datalake/pom.xml| 139 ++ .../datalake/DataLakeComponentConfigurer.java | 229 ++ .../datalake/DataLakeEndpointConfigurer.java | 231 ++ .../datalake/DataLakeEndpointUriFactory.java | 97 + .../services/org/apache/camel/component.properties |7 + .../apache/camel/component/azure-storage-datalake |2 + .../configurer/azure-storage-datalake-component|2 + .../configurer/azure-storage-datalake-endpoint |2 + .../urifactory/azure-storage-datalake-endpoint |2 + .../storage/datalake/azure-storage-datalake.json | 97 + .../docs/azure-storage-datalake-component.adoc | 553 + .../azure/storage/datalake/DataLakeComponent.java | 112 + .../storage/datalake/DataLakeConfiguration.java| 356 +++ .../DataLakeConfigurationOptionsProxy.java | 267 +++ .../azure/storage/datalake/DataLakeConstants.java | 86 + .../azure/storage/datalake/DataLakeConsumer.java | 165 ++ .../azure/storage/datalake/DataLakeEndpoint.java | 97 + .../storage/datalake/DataLakeExchangeHeaders.java | 414 .../datalake/DataLakeOperationsDefinition.java | 35 + .../azure/storage/datalake/DataLakeProducer.java | 172 ++ .../azure/storage/datalake/DataLakeUtils.java | 48 + .../storage/datalake/FileCommonRequestOptions.java | 78 + .../storage/datalake/FileStreamAndLength.java | 78 + .../datalake/client/DataLakeClientFactory.java | 94 + .../client/DataLakeDirectoryClientWrapper.java | 56 + .../datalake/client/DataLakeFileClientWrapper.java | 130 ++ .../client/DataLakeFileSystemClientWrapper.java| 70 + .../client/DataLakeServiceClientWrapper.java | 47 + .../operations/DataLakeDirectoryOperations.java| 69 + .../operations/DataLakeFileOperations.java | 240 ++ .../operations/DataLakeFileSystemOperations.java | 85 + .../operations/DataLakeOperationResponse.java | 53 + .../operations/DataLakeServiceOperations.java | 42 + .../datalake/component/DataLakeComponentTest.java | 86 + .../azure/storage/datalake/integration/BaseIT.java | 94 + .../datalake/integration/DataLakeConsumerIT.java | 224 ++ .../integration/DataLakeFileOperationIT.java | 135 ++ .../integration/DataLakeFileSystemOperationIT.java | 81 + .../operations/DataLakeDirectoryOperationTest.java | 81 + .../operations/DataLakeFileOperationTest.java | 110 + .../DataLakeFileSystemOperationTest.java | 172 ++ .../src/test/resources/log4j2.properties | 27 + components/pom.xml |1 + core/camel-allcomponents/pom.xml |4 + .../component/ComponentsBuilderFactory.java| 13 + ...zureStorageDatalakeComponentBuilderFactory.java | 641 + .../src/generated/resources/metadata.json | 22 + .../builder/endpoint/EndpointBuilderFactory.java |1 + .../camel/builder/endpoint/EndpointBuilders.java |1 + .../builder/endpoint/StaticEndpointBuilders.java | 49 + .../dsl/DataLakeEndpointBuilderFactory.java| 2465 docs/components/modules/ROOT/nav.adoc |1 + .../pages/azure-storage-datalake-component.adoc| 555 + parent/pom.xml | 12 + .../pom.xml| 69 + .../src/main/resources/META-INF/MANIFEST.MF|0 .../clients/AzureStorageDataLakeClientUtils.java | 45 + .../AzureStorageDataLakeRemoteService.java | 54 + .../AzureStorageDataLakeServiceFactory.java| 43 + test-infra/pom.xml |1 + 66 files changed, 9801 insertions(+) create
[GitHub] [camel] mathewsreji commented on a change in pull request #4900: [CAMEL-16001] Camel component for HuaweiCloud Simple Notification Services (SMN) se…
mathewsreji commented on a change in pull request #4900:
URL: https://github.com/apache/camel/pull/4900#discussion_r565029333
##
File path:
components/camel-huaweicloud-smn/src/main/java/org/apache/camel/component/huaweicloud/smn/SimpleNotificationProducer.java
##
@@ -0,0 +1,366 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.huaweicloud.smn;
+
+import java.util.HashMap;
+
+import com.huaweicloud.sdk.core.auth.BasicCredentials;
+import com.huaweicloud.sdk.core.http.HttpConfig;
+import com.huaweicloud.sdk.smn.v2.SmnClient;
+import com.huaweicloud.sdk.smn.v2.model.PublishMessageRequest;
+import com.huaweicloud.sdk.smn.v2.model.PublishMessageRequestBody;
+import com.huaweicloud.sdk.smn.v2.model.PublishMessageResponse;
+import org.apache.camel.Exchange;
+import org.apache.camel.component.huaweicloud.smn.constants.SmnConstants;
+import org.apache.camel.component.huaweicloud.smn.constants.SmnOperations;
+import org.apache.camel.component.huaweicloud.smn.constants.SmnServices;
+import org.apache.camel.component.huaweicloud.smn.models.ClientConfigurations;
+import org.apache.camel.support.DefaultProducer;
+import org.apache.camel.util.ObjectHelper;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class SimpleNotificationProducer extends DefaultProducer {
+private static final Logger LOG =
LoggerFactory.getLogger(SimpleNotificationProducer.class);
+private SimpleNotificationEndpoint simpleNotificationEndpoint;
+private SmnClient smnClient;
+private ClientConfigurations clientConfigurations;
+
+public SimpleNotificationProducer(SimpleNotificationEndpoint endpoint) {
+super(endpoint);
+this.simpleNotificationEndpoint = endpoint;
+}
+
+public void process(Exchange exchange) throws Exception {
+
+/**
+ * the produce method is invoked when a message arrives at producer
endpoint (lazy init of SmnClient on first
+ * message)
+ */
+if (this.smnClient == null) {
+if (LOG.isDebugEnabled()) {
+LOG.debug("Initializing the SmnClient");
+}
+validateAndInitializeSmnClient(simpleNotificationEndpoint);
+}
+
+String service = simpleNotificationEndpoint.getSmnService();
+
+if (!ObjectHelper.isEmpty(service)) {
+switch (service) {
+case SmnServices.PUBLISH_MESSAGE:
+if (LOG.isDebugEnabled()) {
+LOG.debug("Using message publishing service");
+}
+
performPublishMessageServiceOperations(simpleNotificationEndpoint, exchange);
+if (LOG.isDebugEnabled()) {
+LOG.debug("Completed publishing message");
+}
+break;
+default:
+if (LOG.isErrorEnabled()) {
+LOG.error("Unsupported service name {}", service);
+}
+throw new
UnsupportedOperationException(String.format("service %s is not a supported
service", service));
+}
+} else {
+if (LOG.isErrorEnabled()) {
+LOG.error("Service name is null/empty");
+}
+throw new IllegalStateException("service name cannot be
null/empty");
+}
+}
+
+/**
+ * Publish message service operations
+ *
+ * @param endpoint
+ * @param exchange
+ */
+private void
performPublishMessageServiceOperations(SimpleNotificationEndpoint endpoint,
Exchange exchange) {
+PublishMessageResponse response;
+
+PublishMessageRequestBody apiBody;
+this.clientConfigurations = validateServiceConfigurations(endpoint,
exchange);
+
+if (LOG.isDebugEnabled()) {
+LOG.debug("Checking operation name");
+}
+switch (clientConfigurations.getOperation()) {
+
+case SmnOperations.PUBLISH_AS_TEXT_MESSAGE:
+if (LOG.isDebugEnabled()) {
+LOG.debug("Publishing as text message");
+}
+apiBody = new PublishMessageRequestBody()
+
[GitHub] [camel] mathewsreji commented on a change in pull request #4900: [CAMEL-16001] Camel component for HuaweiCloud Simple Notification Services (SMN) se…
mathewsreji commented on a change in pull request #4900:
URL: https://github.com/apache/camel/pull/4900#discussion_r565025883
##
File path:
components/camel-huaweicloud-smn/src/test/java/org/apache/camel/component/huaweicloud/smn/PublishTemplatedMessageTest.java
##
@@ -0,0 +1,129 @@
+package org.apache.camel.component.huaweicloud.smn;
+
+import java.nio.file.Files;
+import java.nio.file.Paths;
+import java.util.HashMap;
+import java.util.Map;
+
+import com.github.tomakehurst.wiremock.WireMockServer;
+import com.github.tomakehurst.wiremock.verification.LoggedRequest;
+import org.apache.camel.BindToRegistry;
+import org.apache.camel.Exchange;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.huaweicloud.smn.models.ServiceKeys;
+import org.apache.camel.component.mock.MockEndpoint;
+import org.apache.camel.test.junit4.CamelTestSupport;
+import org.junit.Assert;
+import org.junit.Test;
+import org.mockito.Mockito;
+import org.mockito.exceptions.base.MockitoException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import static com.github.tomakehurst.wiremock.client.WireMock.*;
+
+public class PublishTemplatedMessageTest extends CamelTestSupport {
+
+private static final Logger LOGGER =
LoggerFactory.getLogger(PublishTemplatedMessageTest.class.getName());
+private static int wiremockServerPort = 8080;
+
+TestConfiguration testConfiguration = new TestConfiguration();
+
+WireMockServer wireMockServer;
+
+@BindToRegistry("serviceKeys")
+ServiceKeys serviceKeys
+= new ServiceKeys(testConfiguration.getProperty("authKey"),
testConfiguration.getProperty("secretKey"));
+
+protected RouteBuilder createRouteBuilder() throws Exception {
+
+// populating tag values. user has to adjust the map entries according
to the structure of their respective templates
+Map tags = new HashMap<>();
+tags.put("name", "reji");
+tags.put("phone", "1234567890");
+
+return new RouteBuilder() {
+public void configure() {
+from("direct:publish_templated_message")
+.setProperty("CamelHwCloudSmnSubject", constant("This
is my subjectline"))
+.setProperty("CamelHwCloudSmnTopic",
constant(testConfiguration.getProperty("topic")))
+.setProperty("CamelHwCloudSmnMessageTtl", constant(60))
+.setProperty("CamelHwCloudSmnTemplateTags",
constant(tags))
+.setProperty("CamelHwCloudSmnTemplateName",
constant("hello-template"))
+
//.to("hwcloud-smn:publishMessageService?serviceKeys=#serviceKeys=publishAsTemplatedMessage"+"="+testConfiguration.getProperty("projectId")+"="+testConfiguration.getProperty("region")+"=localhost=3128=true")
+
.to("hwcloud-smn:publishMessageService?serviceKeys=#serviceKeys=publishAsTemplatedMessage"
++ "=" +
testConfiguration.getProperty("projectId") + "="
++ testConfiguration.getProperty("region") +
"=true")
+.log("templated notification sent")
+.to("mock:publish_templated_message_result");
+}
+};
+}
+
+private void setupSimpleNotificationsUtilsMock() {
+try {
+Mockito.mockStatic(SimpleNotificationUtils.class);
+
Mockito.when(SimpleNotificationUtils.resolveSmnServiceEndpoint("unit-test"))
+.thenReturn("http://localhost:; + wiremockServerPort);
+} catch (MockitoException e) {
+LOGGER.info("Mock already registered. Using existing
registration");
+}
+}
+
+@Test
+public void testTemplatedNotificationSend() throws Exception {
+boolean isMockedServerTest =
testConfiguration.getProperty("region").equals("unit-test");
+if (isMockedServerTest) {
+LOGGER.info("region is unit-test. Starting up wiremock stubs");
+initWireMock();
+setupSimpleNotificationsUtilsMock();
+}
+
+MockEndpoint mock =
getMockEndpoint("mock:publish_templated_message_result");
+mock.expectedMinimumMessageCount(1);
+template.sendBody("direct:publish_templated_message", null);
+Exchange responseExchange = mock.getExchanges().get(0);
+
+mock.assertIsSatisfied();
+
+
Assert.assertNotNull(responseExchange.getProperty("CamelSmnMesssageId"));
+
Assert.assertNotNull(responseExchange.getProperty("CamelSmnRequestId"));
+
Assert.assertTrue(responseExchange.getProperty("CamelSmnMesssageId").toString().length()
> 0);
+
Assert.assertTrue(responseExchange.getProperty("CamelSmnRequestId").toString().length()
> 0);
+
+if (isMockedServerTest) {
+Assert.assertEquals("bf94b63a5dfb475994d3ac34664e24f2",
responseExchange.getProperty("CamelSmnMesssageId"));
+
[GitHub] [camel] mathewsreji commented on a change in pull request #4900: [CAMEL-16001] Camel component for HuaweiCloud Simple Notification Services (SMN) se…
mathewsreji commented on a change in pull request #4900:
URL: https://github.com/apache/camel/pull/4900#discussion_r565025677
##
File path:
components/camel-huaweicloud-smn/src/main/java/org/apache/camel/component/huaweicloud/smn/SimpleNotificationUtils.java
##
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.huaweicloud.smn;
+
+import com.huaweicloud.sdk.core.region.Region;
+import com.huaweicloud.sdk.smn.v2.region.SmnRegion;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * utility functions for the component
+ */
+public class SimpleNotificationUtils {
+private static final Logger LOG =
LoggerFactory.getLogger(SimpleNotificationUtils.class.getName());
+
+/**
+ * resolves endpoint url for the given region
+ *
+ * @param region
+ * @return
+ */
+public static String resolveSmnServiceEndpoint(String region) {
+if (region == null) {
+return null;
+}
+
+String result = null;
+
+try {
+String formattedEndpointKey = formatEndpointKey(region);
Review comment:
Usage of reflection has been removed completely
This is an automated message from the 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] mathewsreji commented on a change in pull request #4900: [CAMEL-16001] Camel component for HuaweiCloud Simple Notification Services (SMN) se…
mathewsreji commented on a change in pull request #4900:
URL: https://github.com/apache/camel/pull/4900#discussion_r565025533
##
File path:
components/camel-huaweicloud-smn/src/main/java/org/apache/camel/component/huaweicloud/smn/SimpleNotificationProducer.java
##
@@ -0,0 +1,366 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.huaweicloud.smn;
+
+import java.util.HashMap;
+
+import com.huaweicloud.sdk.core.auth.BasicCredentials;
+import com.huaweicloud.sdk.core.http.HttpConfig;
+import com.huaweicloud.sdk.smn.v2.SmnClient;
+import com.huaweicloud.sdk.smn.v2.model.PublishMessageRequest;
+import com.huaweicloud.sdk.smn.v2.model.PublishMessageRequestBody;
+import com.huaweicloud.sdk.smn.v2.model.PublishMessageResponse;
+import org.apache.camel.Exchange;
+import org.apache.camel.component.huaweicloud.smn.constants.SmnConstants;
+import org.apache.camel.component.huaweicloud.smn.constants.SmnOperations;
+import org.apache.camel.component.huaweicloud.smn.constants.SmnServices;
+import org.apache.camel.component.huaweicloud.smn.models.ClientConfigurations;
+import org.apache.camel.support.DefaultProducer;
+import org.apache.camel.util.ObjectHelper;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class SimpleNotificationProducer extends DefaultProducer {
+private static final Logger LOG =
LoggerFactory.getLogger(SimpleNotificationProducer.class);
+private SimpleNotificationEndpoint simpleNotificationEndpoint;
+private SmnClient smnClient;
+private ClientConfigurations clientConfigurations;
+
+public SimpleNotificationProducer(SimpleNotificationEndpoint endpoint) {
+super(endpoint);
+this.simpleNotificationEndpoint = endpoint;
+}
+
+public void process(Exchange exchange) throws Exception {
+
+/**
+ * the produce method is invoked when a message arrives at producer
endpoint (lazy init of SmnClient on first
+ * message)
+ */
+if (this.smnClient == null) {
Review comment:
lazy initialization has been removed. instead moved the routine call
inside constructor
This is an automated message from the 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] mathewsreji commented on a change in pull request #4900: [CAMEL-16001] Camel component for HuaweiCloud Simple Notification Services (SMN) se…
mathewsreji commented on a change in pull request #4900:
URL: https://github.com/apache/camel/pull/4900#discussion_r565025341
##
File path:
components/camel-huaweicloud-smn/src/main/java/org/apache/camel/component/huaweicloud/smn/SimpleNotificationProducer.java
##
@@ -0,0 +1,366 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.huaweicloud.smn;
+
+import java.util.HashMap;
+
+import com.huaweicloud.sdk.core.auth.BasicCredentials;
+import com.huaweicloud.sdk.core.http.HttpConfig;
+import com.huaweicloud.sdk.smn.v2.SmnClient;
+import com.huaweicloud.sdk.smn.v2.model.PublishMessageRequest;
+import com.huaweicloud.sdk.smn.v2.model.PublishMessageRequestBody;
+import com.huaweicloud.sdk.smn.v2.model.PublishMessageResponse;
+import org.apache.camel.Exchange;
+import org.apache.camel.component.huaweicloud.smn.constants.SmnConstants;
+import org.apache.camel.component.huaweicloud.smn.constants.SmnOperations;
+import org.apache.camel.component.huaweicloud.smn.constants.SmnServices;
+import org.apache.camel.component.huaweicloud.smn.models.ClientConfigurations;
+import org.apache.camel.support.DefaultProducer;
+import org.apache.camel.util.ObjectHelper;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class SimpleNotificationProducer extends DefaultProducer {
+private static final Logger LOG =
LoggerFactory.getLogger(SimpleNotificationProducer.class);
+private SimpleNotificationEndpoint simpleNotificationEndpoint;
+private SmnClient smnClient;
+private ClientConfigurations clientConfigurations;
+
+public SimpleNotificationProducer(SimpleNotificationEndpoint endpoint) {
+super(endpoint);
+this.simpleNotificationEndpoint = endpoint;
+}
+
+public void process(Exchange exchange) throws Exception {
+
+/**
+ * the produce method is invoked when a message arrives at producer
endpoint (lazy init of SmnClient on first
+ * message)
+ */
+if (this.smnClient == null) {
+if (LOG.isDebugEnabled()) {
+LOG.debug("Initializing the SmnClient");
+}
+validateAndInitializeSmnClient(simpleNotificationEndpoint);
+}
+
+String service = simpleNotificationEndpoint.getSmnService();
+
+if (!ObjectHelper.isEmpty(service)) {
+switch (service) {
+case SmnServices.PUBLISH_MESSAGE:
+if (LOG.isDebugEnabled()) {
+LOG.debug("Using message publishing service");
+}
+
performPublishMessageServiceOperations(simpleNotificationEndpoint, exchange);
+if (LOG.isDebugEnabled()) {
+LOG.debug("Completed publishing message");
+}
+break;
+default:
+if (LOG.isErrorEnabled()) {
+LOG.error("Unsupported service name {}", service);
+}
+throw new
UnsupportedOperationException(String.format("service %s is not a supported
service", service));
+}
+} else {
+if (LOG.isErrorEnabled()) {
+LOG.error("Service name is null/empty");
+}
+throw new IllegalStateException("service name cannot be
null/empty");
Review comment:
It was just a personal choice. I have removed the lazy initialization to
class init time
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
[GitHub] [camel] mathewsreji commented on a change in pull request #4900: [CAMEL-16001] Camel component for HuaweiCloud Simple Notification Services (SMN) se…
mathewsreji commented on a change in pull request #4900: URL: https://github.com/apache/camel/pull/4900#discussion_r565025146 ## File path: components/camel-huaweicloud-smn/src/test/java/org/apache/camel/component/huaweicloud/smn/PublishTemplatedMessageTest.java ## @@ -0,0 +1,129 @@ +package org.apache.camel.component.huaweicloud.smn; + +import java.nio.file.Files; +import java.nio.file.Paths; +import java.util.HashMap; +import java.util.Map; + +import com.github.tomakehurst.wiremock.WireMockServer; +import com.github.tomakehurst.wiremock.verification.LoggedRequest; +import org.apache.camel.BindToRegistry; +import org.apache.camel.Exchange; +import org.apache.camel.builder.RouteBuilder; +import org.apache.camel.component.huaweicloud.smn.models.ServiceKeys; +import org.apache.camel.component.mock.MockEndpoint; +import org.apache.camel.test.junit4.CamelTestSupport; +import org.junit.Assert; +import org.junit.Test; +import org.mockito.Mockito; +import org.mockito.exceptions.base.MockitoException; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import static com.github.tomakehurst.wiremock.client.WireMock.*; Review comment: Suggestion has been incorporated into the code. Main codebase has been re-visited to make it more testable with above suggestion This is an automated message from the 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] mathewsreji commented on a change in pull request #4900: [CAMEL-16001] Camel component for HuaweiCloud Simple Notification Services (SMN) se…
mathewsreji commented on a change in pull request #4900:
URL: https://github.com/apache/camel/pull/4900#discussion_r565024902
##
File path:
components/camel-huaweicloud-smn/src/main/java/org/apache/camel/component/huaweicloud/smn/SimpleNotificationUtils.java
##
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.huaweicloud.smn;
+
+import com.huaweicloud.sdk.core.region.Region;
+import com.huaweicloud.sdk.smn.v2.region.SmnRegion;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * utility functions for the component
+ */
+public class SimpleNotificationUtils {
Review comment:
Added private constructor
This is an automated message from the 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] mathewsreji commented on a change in pull request #4900: [CAMEL-16001] Camel component for HuaweiCloud Simple Notification Services (SMN) se…
mathewsreji commented on a change in pull request #4900:
URL: https://github.com/apache/camel/pull/4900#discussion_r565024787
##
File path:
components/camel-huaweicloud-smn/src/main/java/org/apache/camel/component/huaweicloud/smn/constants/SmnConstants.java
##
@@ -0,0 +1,22 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.huaweicloud.smn.constants;
+
+public class SmnConstants {
Review comment:
Added private constructor
This is an automated message from the 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] mathewsreji commented on a change in pull request #4900: [CAMEL-16001] Camel component for HuaweiCloud Simple Notification Services (SMN) se…
mathewsreji commented on a change in pull request #4900:
URL: https://github.com/apache/camel/pull/4900#discussion_r565024654
##
File path:
components/camel-huaweicloud-smn/src/main/java/org/apache/camel/component/huaweicloud/smn/SimpleNotificationProducer.java
##
@@ -0,0 +1,366 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.huaweicloud.smn;
+
+import java.util.HashMap;
+
+import com.huaweicloud.sdk.core.auth.BasicCredentials;
+import com.huaweicloud.sdk.core.http.HttpConfig;
+import com.huaweicloud.sdk.smn.v2.SmnClient;
+import com.huaweicloud.sdk.smn.v2.model.PublishMessageRequest;
+import com.huaweicloud.sdk.smn.v2.model.PublishMessageRequestBody;
+import com.huaweicloud.sdk.smn.v2.model.PublishMessageResponse;
+import org.apache.camel.Exchange;
+import org.apache.camel.component.huaweicloud.smn.constants.SmnConstants;
+import org.apache.camel.component.huaweicloud.smn.constants.SmnOperations;
+import org.apache.camel.component.huaweicloud.smn.constants.SmnServices;
+import org.apache.camel.component.huaweicloud.smn.models.ClientConfigurations;
+import org.apache.camel.support.DefaultProducer;
+import org.apache.camel.util.ObjectHelper;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class SimpleNotificationProducer extends DefaultProducer {
+private static final Logger LOG =
LoggerFactory.getLogger(SimpleNotificationProducer.class);
+private SimpleNotificationEndpoint simpleNotificationEndpoint;
+private SmnClient smnClient;
+private ClientConfigurations clientConfigurations;
+
+public SimpleNotificationProducer(SimpleNotificationEndpoint endpoint) {
+super(endpoint);
+this.simpleNotificationEndpoint = endpoint;
+}
+
+public void process(Exchange exchange) throws Exception {
+
+/**
+ * the produce method is invoked when a message arrives at producer
endpoint (lazy init of SmnClient on first
+ * message)
+ */
+if (this.smnClient == null) {
+if (LOG.isDebugEnabled()) {
+LOG.debug("Initializing the SmnClient");
+}
+validateAndInitializeSmnClient(simpleNotificationEndpoint);
+}
+
+String service = simpleNotificationEndpoint.getSmnService();
+
+if (!ObjectHelper.isEmpty(service)) {
+switch (service) {
+case SmnServices.PUBLISH_MESSAGE:
+if (LOG.isDebugEnabled()) {
+LOG.debug("Using message publishing service");
+}
+
performPublishMessageServiceOperations(simpleNotificationEndpoint, exchange);
+if (LOG.isDebugEnabled()) {
+LOG.debug("Completed publishing message");
+}
+break;
+default:
+if (LOG.isErrorEnabled()) {
+LOG.error("Unsupported service name {}", service);
+}
+throw new
UnsupportedOperationException(String.format("service %s is not a supported
service", service));
+}
+} else {
+if (LOG.isErrorEnabled()) {
+LOG.error("Service name is null/empty");
+}
+throw new IllegalStateException("service name cannot be
null/empty");
+}
+}
+
+/**
+ * Publish message service operations
+ *
+ * @param endpoint
+ * @param exchange
+ */
+private void
performPublishMessageServiceOperations(SimpleNotificationEndpoint endpoint,
Exchange exchange) {
+PublishMessageResponse response;
+
+PublishMessageRequestBody apiBody;
+this.clientConfigurations = validateServiceConfigurations(endpoint,
exchange);
+
+if (LOG.isDebugEnabled()) {
+LOG.debug("Checking operation name");
+}
+switch (clientConfigurations.getOperation()) {
+
+case SmnOperations.PUBLISH_AS_TEXT_MESSAGE:
+if (LOG.isDebugEnabled()) {
+LOG.debug("Publishing as text message");
+}
+apiBody = new PublishMessageRequestBody()
+
[GitHub] [camel] mathewsreji commented on a change in pull request #4900: [CAMEL-16001] Camel component for HuaweiCloud Simple Notification Services (SMN) se…
mathewsreji commented on a change in pull request #4900:
URL: https://github.com/apache/camel/pull/4900#discussion_r565024581
##
File path:
components/camel-huaweicloud-smn/src/main/java/org/apache/camel/component/huaweicloud/smn/SimpleNotificationProducer.java
##
@@ -0,0 +1,366 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.huaweicloud.smn;
+
+import java.util.HashMap;
+
+import com.huaweicloud.sdk.core.auth.BasicCredentials;
+import com.huaweicloud.sdk.core.http.HttpConfig;
+import com.huaweicloud.sdk.smn.v2.SmnClient;
+import com.huaweicloud.sdk.smn.v2.model.PublishMessageRequest;
+import com.huaweicloud.sdk.smn.v2.model.PublishMessageRequestBody;
+import com.huaweicloud.sdk.smn.v2.model.PublishMessageResponse;
+import org.apache.camel.Exchange;
+import org.apache.camel.component.huaweicloud.smn.constants.SmnConstants;
+import org.apache.camel.component.huaweicloud.smn.constants.SmnOperations;
+import org.apache.camel.component.huaweicloud.smn.constants.SmnServices;
+import org.apache.camel.component.huaweicloud.smn.models.ClientConfigurations;
+import org.apache.camel.support.DefaultProducer;
+import org.apache.camel.util.ObjectHelper;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class SimpleNotificationProducer extends DefaultProducer {
+private static final Logger LOG =
LoggerFactory.getLogger(SimpleNotificationProducer.class);
+private SimpleNotificationEndpoint simpleNotificationEndpoint;
+private SmnClient smnClient;
+private ClientConfigurations clientConfigurations;
+
+public SimpleNotificationProducer(SimpleNotificationEndpoint endpoint) {
+super(endpoint);
+this.simpleNotificationEndpoint = endpoint;
+}
+
+public void process(Exchange exchange) throws Exception {
+
+/**
+ * the produce method is invoked when a message arrives at producer
endpoint (lazy init of SmnClient on first
+ * message)
+ */
+if (this.smnClient == null) {
+if (LOG.isDebugEnabled()) {
+LOG.debug("Initializing the SmnClient");
+}
+validateAndInitializeSmnClient(simpleNotificationEndpoint);
+}
+
+String service = simpleNotificationEndpoint.getSmnService();
+
+if (!ObjectHelper.isEmpty(service)) {
+switch (service) {
+case SmnServices.PUBLISH_MESSAGE:
+if (LOG.isDebugEnabled()) {
+LOG.debug("Using message publishing service");
+}
+
performPublishMessageServiceOperations(simpleNotificationEndpoint, exchange);
+if (LOG.isDebugEnabled()) {
+LOG.debug("Completed publishing message");
+}
+break;
+default:
+if (LOG.isErrorEnabled()) {
+LOG.error("Unsupported service name {}", service);
+}
+throw new
UnsupportedOperationException(String.format("service %s is not a supported
service", service));
+}
+} else {
+if (LOG.isErrorEnabled()) {
+LOG.error("Service name is null/empty");
+}
+throw new IllegalStateException("service name cannot be
null/empty");
+}
+}
+
+/**
+ * Publish message service operations
+ *
+ * @param endpoint
+ * @param exchange
+ */
+private void
performPublishMessageServiceOperations(SimpleNotificationEndpoint endpoint,
Exchange exchange) {
+PublishMessageResponse response;
+
+PublishMessageRequestBody apiBody;
+this.clientConfigurations = validateServiceConfigurations(endpoint,
exchange);
+
+if (LOG.isDebugEnabled()) {
+LOG.debug("Checking operation name");
+}
+switch (clientConfigurations.getOperation()) {
+
+case SmnOperations.PUBLISH_AS_TEXT_MESSAGE:
+if (LOG.isDebugEnabled()) {
+LOG.debug("Publishing as text message");
+}
+apiBody = new PublishMessageRequestBody()
+
[GitHub] [camel] mathewsreji commented on a change in pull request #4900: [CAMEL-16001] Camel component for HuaweiCloud Simple Notification Services (SMN) se…
mathewsreji commented on a change in pull request #4900:
URL: https://github.com/apache/camel/pull/4900#discussion_r565024384
##
File path:
components/camel-huaweicloud-smn/src/main/java/org/apache/camel/component/huaweicloud/smn/SimpleNotificationProducer.java
##
@@ -0,0 +1,366 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.huaweicloud.smn;
+
+import java.util.HashMap;
+
+import com.huaweicloud.sdk.core.auth.BasicCredentials;
+import com.huaweicloud.sdk.core.http.HttpConfig;
+import com.huaweicloud.sdk.smn.v2.SmnClient;
+import com.huaweicloud.sdk.smn.v2.model.PublishMessageRequest;
+import com.huaweicloud.sdk.smn.v2.model.PublishMessageRequestBody;
+import com.huaweicloud.sdk.smn.v2.model.PublishMessageResponse;
+import org.apache.camel.Exchange;
+import org.apache.camel.component.huaweicloud.smn.constants.SmnConstants;
+import org.apache.camel.component.huaweicloud.smn.constants.SmnOperations;
+import org.apache.camel.component.huaweicloud.smn.constants.SmnServices;
+import org.apache.camel.component.huaweicloud.smn.models.ClientConfigurations;
+import org.apache.camel.support.DefaultProducer;
+import org.apache.camel.util.ObjectHelper;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class SimpleNotificationProducer extends DefaultProducer {
+private static final Logger LOG =
LoggerFactory.getLogger(SimpleNotificationProducer.class);
+private SimpleNotificationEndpoint simpleNotificationEndpoint;
+private SmnClient smnClient;
+private ClientConfigurations clientConfigurations;
+
+public SimpleNotificationProducer(SimpleNotificationEndpoint endpoint) {
+super(endpoint);
+this.simpleNotificationEndpoint = endpoint;
Review comment:
Redundancy removed from the code
This is an automated message from the 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] mathewsreji commented on a change in pull request #4900: [CAMEL-16001] Camel component for HuaweiCloud Simple Notification Services (SMN) se…
mathewsreji commented on a change in pull request #4900:
URL: https://github.com/apache/camel/pull/4900#discussion_r565024294
##
File path:
components/camel-huaweicloud-smn/src/test/java/org/apache/camel/component/huaweicloud/smn/PublishTemplatedMessageTest.java
##
@@ -0,0 +1,129 @@
+package org.apache.camel.component.huaweicloud.smn;
+
+import java.nio.file.Files;
+import java.nio.file.Paths;
+import java.util.HashMap;
+import java.util.Map;
+
+import com.github.tomakehurst.wiremock.WireMockServer;
+import com.github.tomakehurst.wiremock.verification.LoggedRequest;
+import org.apache.camel.BindToRegistry;
+import org.apache.camel.Exchange;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.huaweicloud.smn.models.ServiceKeys;
+import org.apache.camel.component.mock.MockEndpoint;
+import org.apache.camel.test.junit4.CamelTestSupport;
+import org.junit.Assert;
+import org.junit.Test;
+import org.mockito.Mockito;
+import org.mockito.exceptions.base.MockitoException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import static com.github.tomakehurst.wiremock.client.WireMock.*;
+
+public class PublishTemplatedMessageTest extends CamelTestSupport {
Review comment:
Removed wiremocks (as it can potentially cause port conflicts in worst
case). Referred testing strategy of aws-s3 camel component by mocking SmnClient
This is an automated message from the 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] mathewsreji commented on a change in pull request #4900: [CAMEL-16001] Camel component for HuaweiCloud Simple Notification Services (SMN) se…
mathewsreji commented on a change in pull request #4900:
URL: https://github.com/apache/camel/pull/4900#discussion_r565024025
##
File path:
components/camel-huaweicloud-smn/src/test/java/org/apache/camel/component/huaweicloud/smn/PublishTemplatedMessageTest.java
##
@@ -0,0 +1,129 @@
+package org.apache.camel.component.huaweicloud.smn;
+
+import java.nio.file.Files;
+import java.nio.file.Paths;
+import java.util.HashMap;
+import java.util.Map;
+
+import com.github.tomakehurst.wiremock.WireMockServer;
+import com.github.tomakehurst.wiremock.verification.LoggedRequest;
+import org.apache.camel.BindToRegistry;
+import org.apache.camel.Exchange;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.huaweicloud.smn.models.ServiceKeys;
+import org.apache.camel.component.mock.MockEndpoint;
+import org.apache.camel.test.junit4.CamelTestSupport;
+import org.junit.Assert;
+import org.junit.Test;
+import org.mockito.Mockito;
+import org.mockito.exceptions.base.MockitoException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import static com.github.tomakehurst.wiremock.client.WireMock.*;
+
+public class PublishTemplatedMessageTest extends CamelTestSupport {
+
+private static final Logger LOGGER =
LoggerFactory.getLogger(PublishTemplatedMessageTest.class.getName());
+private static int wiremockServerPort = 8080;
+
+TestConfiguration testConfiguration = new TestConfiguration();
+
+WireMockServer wireMockServer;
+
+@BindToRegistry("serviceKeys")
+ServiceKeys serviceKeys
+= new ServiceKeys(testConfiguration.getProperty("authKey"),
testConfiguration.getProperty("secretKey"));
+
+protected RouteBuilder createRouteBuilder() throws Exception {
+
+// populating tag values. user has to adjust the map entries according
to the structure of their respective templates
+Map tags = new HashMap<>();
+tags.put("name", "reji");
+tags.put("phone", "1234567890");
+
+return new RouteBuilder() {
+public void configure() {
+from("direct:publish_templated_message")
+.setProperty("CamelHwCloudSmnSubject", constant("This
is my subjectline"))
+.setProperty("CamelHwCloudSmnTopic",
constant(testConfiguration.getProperty("topic")))
+.setProperty("CamelHwCloudSmnMessageTtl", constant(60))
+.setProperty("CamelHwCloudSmnTemplateTags",
constant(tags))
+.setProperty("CamelHwCloudSmnTemplateName",
constant("hello-template"))
+
//.to("hwcloud-smn:publishMessageService?serviceKeys=#serviceKeys=publishAsTemplatedMessage"+"="+testConfiguration.getProperty("projectId")+"="+testConfiguration.getProperty("region")+"=localhost=3128=true")
+
.to("hwcloud-smn:publishMessageService?serviceKeys=#serviceKeys=publishAsTemplatedMessage"
++ "=" +
testConfiguration.getProperty("projectId") + "="
++ testConfiguration.getProperty("region") +
"=true")
+.log("templated notification sent")
+.to("mock:publish_templated_message_result");
+}
+};
+}
+
+private void setupSimpleNotificationsUtilsMock() {
+try {
+Mockito.mockStatic(SimpleNotificationUtils.class);
Review comment:
This is completely removed
This is an automated message from the 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] mathewsreji commented on a change in pull request #4900: [CAMEL-16001] Camel component for HuaweiCloud Simple Notification Services (SMN) se…
mathewsreji commented on a change in pull request #4900:
URL: https://github.com/apache/camel/pull/4900#discussion_r565023971
##
File path:
components/camel-huaweicloud-smn/src/test/java/org/apache/camel/component/huaweicloud/smn/PublishTemplatedMessageTest.java
##
@@ -0,0 +1,129 @@
+package org.apache.camel.component.huaweicloud.smn;
+
+import java.nio.file.Files;
+import java.nio.file.Paths;
+import java.util.HashMap;
+import java.util.Map;
+
+import com.github.tomakehurst.wiremock.WireMockServer;
+import com.github.tomakehurst.wiremock.verification.LoggedRequest;
+import org.apache.camel.BindToRegistry;
+import org.apache.camel.Exchange;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.huaweicloud.smn.models.ServiceKeys;
+import org.apache.camel.component.mock.MockEndpoint;
+import org.apache.camel.test.junit4.CamelTestSupport;
+import org.junit.Assert;
+import org.junit.Test;
+import org.mockito.Mockito;
+import org.mockito.exceptions.base.MockitoException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import static com.github.tomakehurst.wiremock.client.WireMock.*;
+
+public class PublishTemplatedMessageTest extends CamelTestSupport {
+
+private static final Logger LOGGER =
LoggerFactory.getLogger(PublishTemplatedMessageTest.class.getName());
+private static int wiremockServerPort = 8080;
Review comment:
as suggested by @omarsmak , have removed external mocks and instead
mocked the SmnClient class and stubbed the operation method
This is an automated message from the 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] mathewsreji commented on a change in pull request #4900: [CAMEL-16001] Camel component for HuaweiCloud Simple Notification Services (SMN) se…
mathewsreji commented on a change in pull request #4900: URL: https://github.com/apache/camel/pull/4900#discussion_r565023737 ## File path: components/camel-huaweicloud-smn/src/test/java/org/apache/camel/component/huaweicloud/smn/PublishTemplatedMessageTest.java ## @@ -0,0 +1,129 @@ +package org.apache.camel.component.huaweicloud.smn; Review comment: License header added on all test files This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] github-actions[bot] opened a new issue #2170: [CI] - Quarkus Master Branch Build Failure
github-actions[bot] opened a new issue #2170: URL: https://github.com/apache/camel-quarkus/issues/2170 The [quarkus-master](https://github.com/apache/camel-quarkus/tree/quarkus-master) branch build is failing: * Build ID: 513904476-279-f474adad-c001-4998-b7dd-36325c1f1910 * Camel Quarkus Commit: 8e20a53f37c52cdb33b0ec36f0ffabc7753caa8e * Quarkus Master Commit: 19765046e64b5f39ee6b8aeaed27b3514986b2c3 * Link to build: https://github.com/apache/camel-quarkus/actions/runs/513904476 This is an automated message from the 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] 03/04: Allow to reset build taken for native builds that are super fast.
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 085c0447e0fd619d5d45cdcce6482f0e99c58d6a
Author: Claus Ibsen
AuthorDate: Mon Jan 25 09:55:36 2021 +0100
Allow to reset build taken for native builds that are super fast.
---
.../main/java/org/apache/camel/quarkus/core/FastCamelContext.java | 6 ++
.../main/java/org/apache/camel/quarkus/core/NoShutdownStrategy.java | 2 +-
2 files changed, 7 insertions(+), 1 deletion(-)
diff --git
a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastCamelContext.java
b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastCamelContext.java
index fd96350..2a30802 100644
---
a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastCamelContext.java
+++
b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/FastCamelContext.java
@@ -177,7 +177,13 @@ public class FastCamelContext extends AbstractCamelContext
implements CatalogCam
setTracing(Boolean.FALSE);
setDebugging(Boolean.FALSE);
setMessageHistory(Boolean.FALSE);
+}
+@Override
+public void build() {
+super.build();
+// we are fast build so the time should be reset to 0
+resetBuildTime();
}
@Override
diff --git
a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/NoShutdownStrategy.java
b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/NoShutdownStrategy.java
index 477bcc3..d48fe02 100644
---
a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/NoShutdownStrategy.java
+++
b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/NoShutdownStrategy.java
@@ -19,8 +19,8 @@ package org.apache.camel.quarkus.core;
import java.util.List;
import java.util.concurrent.TimeUnit;
-import org.apache.camel.LoggingLevel;
import org.apache.camel.CamelContext;
+import org.apache.camel.LoggingLevel;
import org.apache.camel.Service;
import org.apache.camel.spi.RouteStartupOrder;
import org.apache.camel.spi.ShutdownStrategy;
[camel-quarkus] 02/04: Adjust to camel 3.8 change
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit e157228f705e84ebf878906f01524b0f91b5dcd6
Author: Claus Ibsen
AuthorDate: Mon Jan 25 09:28:14 2021 +0100
Adjust to camel 3.8 change
---
.../java/org/apache/camel/quarkus/core/NoShutdownStrategy.java | 10 ++
1 file changed, 10 insertions(+)
diff --git
a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/NoShutdownStrategy.java
b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/NoShutdownStrategy.java
index 4110fba..477bcc3 100644
---
a/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/NoShutdownStrategy.java
+++
b/extensions-core/core/runtime/src/main/java/org/apache/camel/quarkus/core/NoShutdownStrategy.java
@@ -19,6 +19,7 @@ package org.apache.camel.quarkus.core;
import java.util.List;
import java.util.concurrent.TimeUnit;
+import org.apache.camel.LoggingLevel;
import org.apache.camel.CamelContext;
import org.apache.camel.Service;
import org.apache.camel.spi.RouteStartupOrder;
@@ -130,6 +131,15 @@ public class NoShutdownStrategy implements
ShutdownStrategy {
}
@Override
+public LoggingLevel getLoggingLevel() {
+return LoggingLevel.OFF;
+}
+
+public void setLoggingLevel(LoggingLevel LoggingLevel) {
+// noop
+}
+
+@Override
public void start() {
}
[camel-quarkus] 04/04: add HazelcastReplicatedmapConsumer test fixes #2095
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 771155f27d330d824d7c057127b344051e882e6a
Author: Zineb Bendhiba
AuthorDate: Mon Jan 25 10:31:56 2021 +0100
add HazelcastReplicatedmapConsumer test fixes #2095
---
.../hazelcast/it/HazelcastReplicatedmapTest.java | 18 +-
1 file changed, 17 insertions(+), 1 deletion(-)
diff --git
a/integration-tests/hazelcast/src/test/java/org/apache/camel/quarkus/component/hazelcast/it/HazelcastReplicatedmapTest.java
b/integration-tests/hazelcast/src/test/java/org/apache/camel/quarkus/component/hazelcast/it/HazelcastReplicatedmapTest.java
index 222e545..b134a2a 100644
---
a/integration-tests/hazelcast/src/test/java/org/apache/camel/quarkus/component/hazelcast/it/HazelcastReplicatedmapTest.java
+++
b/integration-tests/hazelcast/src/test/java/org/apache/camel/quarkus/component/hazelcast/it/HazelcastReplicatedmapTest.java
@@ -16,16 +16,20 @@
*/
package org.apache.camel.quarkus.component.hazelcast.it;
+import java.util.Arrays;
+import java.util.List;
import java.util.concurrent.TimeUnit;
import io.quarkus.test.common.QuarkusTestResource;
import io.quarkus.test.common.http.TestHTTPEndpoint;
import io.quarkus.test.junit.QuarkusTest;
+import io.restassured.RestAssured;
import io.restassured.http.ContentType;
import
org.apache.camel.quarkus.component.hazelcast.it.model.HazelcastMapRequest;
import org.junit.jupiter.api.Test;
import static io.restassured.RestAssured.given;
+import static org.awaitility.Awaitility.await;
import static org.hamcrest.Matchers.equalTo;
@QuarkusTest
@@ -89,7 +93,7 @@ public class HazelcastReplicatedmapTest {
.then()
.body(equalTo("true"));
-// verify that map doesn't contain value "val2"
+// verify that map doesn't contain value "val3"
given()
.contentType(ContentType.JSON)
.when()
@@ -119,5 +123,17 @@ public class HazelcastReplicatedmapTest {
.then()
.statusCode(202);
+// verify that the consumer has received all added keys
+await().atMost(10L, TimeUnit.SECONDS).until(() -> {
+List body =
RestAssured.get("/added").then().extract().body().as(List.class);
+return body.size() == 2 && body.containsAll(Arrays.asList("1",
"2"));
+});
+
+// verify that the consumer has received all removed keys
+await().atMost(10L, TimeUnit.SECONDS).until(() -> {
+List body =
RestAssured.get("/deleted").then().extract().body().as(List.class);
+return body.size() == 1 && body.contains("1");
+});
+
}
}
[GitHub] [camel-quarkus] github-actions[bot] closed issue #2157: [CI] - Camel Master Branch Build Failure
github-actions[bot] closed issue #2157: URL: https://github.com/apache/camel-quarkus/issues/2157 This is an automated message from the 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 camel-master updated (4469e22 -> 771155f)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git.
discard 4469e22 add HazelcastReplicatedmapConsumer test fixes #2095
discard 11103a7 Allow to reset build taken for native builds that are super
fast.
discard 3dde29f Adjust to camel 3.8 change
discard 3b24ab6 Upgrade to Camel 3.8.0
add 1976504 XML Tokenize language native support
new 8faaada Upgrade to Camel 3.8.0
new e157228 Adjust to camel 3.8 change
new 085c044 Allow to reset build taken for native builds that are super
fast.
new 771155f add HazelcastReplicatedmapConsumer test fixes #2095
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 (4469e22)
\
N -- N -- N refs/heads/camel-master (771155f)
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 4 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:
catalog/pom.xml| 13
.../ROOT/pages/reference/extensions/xml-jaxp.adoc | 15 ++
.../xml-jaxp/runtime/src/main/doc/usage.adoc | 11 +++
extensions-support/pom.xml | 1 +
.../{jetty => stax}/deployment/pom.xml | 8 ++---
.../stax/deployment/StaxSupportProcessor.java} | 35 +-
.../jackson => extensions-support/stax}/pom.xml| 4 +--
extensions-support/{jetty => stax}/runtime/pom.xml | 10 +++
.../main/resources/META-INF/quarkus-extension.yaml | 7 +++--
integration-tests/xml/pom.xml | 34 +
.../quarkus/component/xml/it/XmlResource.java | 22 ++
.../quarkus/component/xml/it/XmlRouteBuilder.java | 7 +
.../camel/quarkus/component/xml/it/XmlTest.java| 21 +
poms/bom/pom.xml | 10 +++
14 files changed, 157 insertions(+), 41 deletions(-)
create mode 100644 extensions-core/xml-jaxp/runtime/src/main/doc/usage.adoc
copy extensions-support/{jetty => stax}/deployment/pom.xml (88%)
copy
extensions-support/{jackson-dataformat-xml/deployment/src/main/java/org/apache/camel/quarkus/support/jackson/datafromat/xml/deployment/JacksonDataformatXmlSupportProcessor.java
=>
stax/deployment/src/main/java/org/apache/camel/quarkus/support/stax/deployment/StaxSupportProcessor.java}
(61%)
copy {extensions/jackson => extensions-support/stax}/pom.xml (92%)
copy extensions-support/{jetty => stax}/runtime/pom.xml (90%)
copy extensions-support/{common =>
stax}/runtime/src/main/resources/META-INF/quarkus-extension.yaml (89%)
[camel-quarkus] 01/04: Upgrade to Camel 3.8.0
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 8faaada6ed6ec989e9222f646a52f083c85ae494
Author: James Netherton
AuthorDate: Wed Jan 6 08:53:07 2021 +
Upgrade to Camel 3.8.0
---
docs/modules/ROOT/pages/reference/extensions/jsonata.adoc | 2 +-
docs/modules/ROOT/pages/reference/extensions/sjms.adoc | 3 +--
.../modules/ROOT/partials/reference/components/jsonata.adoc | 4 ++--
.../ROOT/partials/reference/components/paho-mqtt5.adoc | 1 +
.../ROOT/partials/reference/components/sjms-batch.adoc | 13 -
.../ROOT/partials/reference/components/spring-rabbitmq.adoc | 1 +
.../ROOT/partials/reference/others/flight-recorder.adoc | 1 +
docs/modules/ROOT/partials/reference/others/jfr.adoc| 1 +
.../apache/camel/component/qute/QuteEndpointConfigurer.java | 3 ---
.../apache/camel/component/qute/QuteEndpointUriFactory.java | 3 +--
.../resources/org/apache/camel/component/qute/qute.json | 3 +--
.../quarkus/component/hazelcast/it/HazelcastQueueTest.java | 2 --
pom.xml | 6 +++---
13 files changed, 13 insertions(+), 30 deletions(-)
diff --git a/docs/modules/ROOT/pages/reference/extensions/jsonata.adoc
b/docs/modules/ROOT/pages/reference/extensions/jsonata.adoc
index d22514b..3b53fd3 100644
--- a/docs/modules/ROOT/pages/reference/extensions/jsonata.adoc
+++ b/docs/modules/ROOT/pages/reference/extensions/jsonata.adoc
@@ -16,7 +16,7 @@ JSON to JSON transformation using JSONATA.
== What's inside
-* xref:{cq-camel-components}::jsonata-component.adoc[JSONATA component], URI
syntax: `jsonata:resourceUri`
+* xref:{cq-camel-components}::jsonata-component.adoc[JSONata component], URI
syntax: `jsonata:resourceUri`
Please refer to the above link for usage and configuration details.
diff --git a/docs/modules/ROOT/pages/reference/extensions/sjms.adoc
b/docs/modules/ROOT/pages/reference/extensions/sjms.adoc
index a9c8263..ccbfe90 100644
--- a/docs/modules/ROOT/pages/reference/extensions/sjms.adoc
+++ b/docs/modules/ROOT/pages/reference/extensions/sjms.adoc
@@ -18,9 +18,8 @@ Send and receive messages to/from a JMS Queue or Topic using
plain JMS 1.x API.
== What's inside
* xref:{cq-camel-components}::sjms-component.adoc[Simple JMS component], URI
syntax: `sjms:destinationType:destinationName`
-* xref:{cq-camel-components}::sjms-batch-component.adoc[Simple JMS Batch
component], URI syntax: `sjms-batch:destinationName`
-Please refer to the above links for usage and configuration details.
+Please refer to the above link for usage and configuration details.
== Maven coordinates
diff --git a/docs/modules/ROOT/partials/reference/components/jsonata.adoc
b/docs/modules/ROOT/partials/reference/components/jsonata.adoc
index 0e6518d..2b9f794 100644
--- a/docs/modules/ROOT/partials/reference/components/jsonata.adoc
+++ b/docs/modules/ROOT/partials/reference/components/jsonata.adoc
@@ -8,6 +8,6 @@
:cq-jvm-since: 1.6.0
:cq-native-since: 1.6.0
:cq-camel-part-name: jsonata
-:cq-camel-part-title: JSONATA
-:cq-camel-part-description: JSON to JSON transformation using JSONATA.
+:cq-camel-part-title: JSONata
+:cq-camel-part-description: Transforms JSON payload using JSONata
transformation.
:cq-extension-page-title: JSONATA
diff --git a/docs/modules/ROOT/partials/reference/components/paho-mqtt5.adoc
b/docs/modules/ROOT/partials/reference/components/paho-mqtt5.adoc
new file mode 100644
index 000..a509c1d
--- /dev/null
+++ b/docs/modules/ROOT/partials/reference/components/paho-mqtt5.adoc
@@ -0,0 +1 @@
+// Empty partial for a Camel bit unsupported by Camel Quarkus to avoid
warnings when this file is included from a Camel page
diff --git a/docs/modules/ROOT/partials/reference/components/sjms-batch.adoc
b/docs/modules/ROOT/partials/reference/components/sjms-batch.adoc
deleted file mode 100644
index eff2868..000
--- a/docs/modules/ROOT/partials/reference/components/sjms-batch.adoc
+++ /dev/null
@@ -1,13 +0,0 @@
-// Do not edit directly!
-// This file was generated by
camel-quarkus-maven-plugin:update-extension-doc-page
-:cq-artifact-id: camel-quarkus-sjms
-:cq-artifact-id-base: sjms
-:cq-native-supported: true
-:cq-status: Stable
-:cq-deprecated: false
-:cq-jvm-since: 1.0.0
-:cq-native-since: 1.0.0
-:cq-camel-part-name: sjms-batch
-:cq-camel-part-title: Simple JMS Batch
-:cq-camel-part-description: Highly performant and transactional batch
consumption of messages from a JMS queue.
-:cq-extension-page-title: Simple JMS
diff --git
a/docs/modules/ROOT/partials/reference/components/spring-rabbitmq.adoc
b/docs/modules/ROOT/partials/reference/components/spring-rabbitmq.adoc
new file mode 100644
index 000..a509c1d
--- /dev/null
+++ b/docs/modules/ROOT/partials/reference/components/spring-rabbitmq.adoc
@@ -0,0 +1 @@
+// Empty partial for a Camel bit
[GitHub] [camel-quarkus] github-actions[bot] commented on issue #2157: [CI] - Camel Master Branch Build Failure
github-actions[bot] commented on issue #2157: URL: https://github.com/apache/camel-quarkus/issues/2157#issuecomment-768000450 Build fixed with: * Camel Quarkus Commit: 771155f27d330d824d7c057127b344051e882e6a * Camel Master Commit: 19765046e64b5f39ee6b8aeaed27b3514986b2c3 * Link to build: https://github.com/apache/camel-quarkus/actions/runs/513701136 This is an automated message from the 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] bobpaulin opened a new pull request #4938: CAMEL-16083: Route Scoped OnCompletion After Consumer routeId check.
bobpaulin opened a new pull request #4938: URL: https://github.com/apache/camel/pull/4938 Hi this is a suggested fix to CAMEL-16083 to support After Consumer mode onCompletion definitions in routeScope. Open to other suggestions. The testOnCompletionInSub is the usecase I'm trying to solve for. The other unit tests were just other regressions I was concerned about. - [ x] Make sure there is a [JIRA issue](https://issues.apache.org/jira/browse/CAMEL) filed for the change (usually before you start working on it). Trivial changes like typos do not require a JIRA issue. Your pull request should address just this issue, without pulling in other changes. - [x ] Each commit in the pull request should have a meaningful subject line and body. - [ x] If you're unsure, you can format the pull request title like `[CAMEL-XXX] Fixes bug in camel-file component`, where you replace `CAMEL-XXX` with the appropriate JIRA issue. - [x ] Write a pull request description that is detailed enough to understand what the pull request does, how, and why. - [ x] Run `mvn clean install -Psourcecheck` in your module with source check enabled to make sure basic checks pass and there are no checkstyle violations. A more thorough check will be performed on your pull request automatically. Below are the contribution guidelines: https://github.com/apache/camel/blob/master/CONTRIBUTING.md This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] ppalaga merged pull request #2169: XML Tokenize language native support
ppalaga merged pull request #2169: URL: https://github.com/apache/camel-quarkus/pull/2169 This is an automated message from the 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: XML Tokenize language native support
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 1976504 XML Tokenize language native support
1976504 is described below
commit 19765046e64b5f39ee6b8aeaed27b3514986b2c3
Author: James Netherton
AuthorDate: Tue Jan 26 14:09:39 2021 +
XML Tokenize language native support
Fixes #780
---
catalog/pom.xml| 13
.../ROOT/pages/reference/extensions/xml-jaxp.adoc | 15 +
.../xml-jaxp/runtime/src/main/doc/usage.adoc | 11
extensions-support/pom.xml | 1 +
extensions-support/{ => stax/deployment}/pom.xml | 61 +-
.../stax/deployment/StaxSupportProcessor.java | 61 ++
extensions-support/{ => stax}/pom.xml | 32 ++
extensions-support/stax/runtime/pom.xml| 74 ++
.../main/resources/META-INF/quarkus-extension.yaml | 28
integration-tests/xml/pom.xml | 34 ++
.../quarkus/component/xml/it/XmlResource.java | 22 +++
.../quarkus/component/xml/it/XmlRouteBuilder.java | 7 ++
.../camel/quarkus/component/xml/it/XmlTest.java| 21 ++
poms/bom/pom.xml | 10 +++
14 files changed, 335 insertions(+), 55 deletions(-)
diff --git a/catalog/pom.xml b/catalog/pom.xml
index f9edefc..da1081a 100644
--- a/catalog/pom.xml
+++ b/catalog/pom.xml
@@ -3767,6 +3767,19 @@
org.apache.camel.quarkus
+camel-quarkus-support-stax
+${project.version}
+pom
+test
+
+
+*
+*
+
+
+
+
+org.apache.camel.quarkus
camel-quarkus-support-webhook
${project.version}
pom
diff --git a/docs/modules/ROOT/pages/reference/extensions/xml-jaxp.adoc
b/docs/modules/ROOT/pages/reference/extensions/xml-jaxp.adoc
index ae0678c..290f4b2 100644
--- a/docs/modules/ROOT/pages/reference/extensions/xml-jaxp.adoc
+++ b/docs/modules/ROOT/pages/reference/extensions/xml-jaxp.adoc
@@ -32,3 +32,18 @@ Please refer to the above link for usage and configuration
details.
Check the xref:user-guide/index.adoc[User guide] for more information about
writing Camel Quarkus applications.
+
+== Usage
+
+To use the XML Tokenize language, a StAX Reader implementation must be present
on the classpath.
+
+For convenience, Camel Quarkus provides a StAX extension with native mode
support.
+
+[source,xml]
+
+
+org.apache.camel.quarkus
+camel-quarkus-support-stax
+
+
+
diff --git a/extensions-core/xml-jaxp/runtime/src/main/doc/usage.adoc
b/extensions-core/xml-jaxp/runtime/src/main/doc/usage.adoc
new file mode 100644
index 000..b49c71e
--- /dev/null
+++ b/extensions-core/xml-jaxp/runtime/src/main/doc/usage.adoc
@@ -0,0 +1,11 @@
+To use the XML Tokenize language, a StAX Reader implementation must be present
on the classpath.
+
+For convenience, Camel Quarkus provides a StAX extension with native mode
support.
+
+[source,xml]
+
+
+org.apache.camel.quarkus
+camel-quarkus-support-stax
+
+
diff --git a/extensions-support/pom.xml b/extensions-support/pom.xml
index 53be603..40bb2d4 100644
--- a/extensions-support/pom.xml
+++ b/extensions-support/pom.xml
@@ -50,6 +50,7 @@
reactor-netty
retrofit
spring
+stax
webhook
xstream
xalan
diff --git a/extensions-support/pom.xml
b/extensions-support/stax/deployment/pom.xml
similarity index 51%
copy from extensions-support/pom.xml
copy to extensions-support/stax/deployment/pom.xml
index 53be603..93d5273 100644
--- a/extensions-support/pom.xml
+++ b/extensions-support/stax/deployment/pom.xml
@@ -18,40 +18,41 @@
-->
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/xsd/maven-4.0.0.xsd;>
-
org.apache.camel.quarkus
-camel-quarkus
+camel-quarkus-support-stax-parent
1.7.0-SNAPSHOT
-
4.0.0
-camel-quarkus-extensions-support
-Camel Quarkus :: Extensions :: Support
-pom
-
-
-
-ahc
-aws
-aws2
-bouncycastle
-common
-commons-logging
-consul-client
-debezium
-google-http-client
-httpclient
-jackson-dataformat-xml
-jetty
-mail
-mongodb
-reactor-netty
-retrofit
-spring
-webhook
-xstream
-xalan
-
+camel-quarkus-support-stax-deployment
+Camel Quarkus :: Support :: StAX :: Deployment
+
+
+
[GitHub] [camel-quarkus] ppalaga closed issue #780: XML Tokenize language native support
ppalaga closed issue #780: URL: https://github.com/apache/camel-quarkus/issues/780 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] ppalaga commented on pull request #2169: XML Tokenize language native support
ppalaga commented on pull request #2169: URL: https://github.com/apache/camel-quarkus/pull/2169#issuecomment-767815063 > > Shouldn't we try to offer the woodstox stuff to Quarkus project? (Seems to be a better place than e.g. Quarkiverse) > > I can ask the Quarkus folks. Any reason to not want to go with Quarkiverse? My guess is that it'll be suggested that it should live there. First, stax is quite a common thing (similar to JAXP) that potentially many extensions may need. Second, Quarkiverse would mean more work for us. This is an automated message from the 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] mathewsreji commented on a change in pull request #4900: [CAMEL-16001] Camel component for HuaweiCloud Simple Notification Services (SMN) se…
mathewsreji commented on a change in pull request #4900: URL: https://github.com/apache/camel/pull/4900#discussion_r564774880 ## File path: components/camel-huaweicloud-smn/src/test/java/org/apache/camel/component/huaweicloud/smn/PublishTemplatedMessageTest.java ## @@ -0,0 +1,129 @@ +package org.apache.camel.component.huaweicloud.smn; + +import java.nio.file.Files; +import java.nio.file.Paths; +import java.util.HashMap; +import java.util.Map; + +import com.github.tomakehurst.wiremock.WireMockServer; +import com.github.tomakehurst.wiremock.verification.LoggedRequest; +import org.apache.camel.BindToRegistry; +import org.apache.camel.Exchange; +import org.apache.camel.builder.RouteBuilder; +import org.apache.camel.component.huaweicloud.smn.models.ServiceKeys; +import org.apache.camel.component.mock.MockEndpoint; +import org.apache.camel.test.junit4.CamelTestSupport; +import org.junit.Assert; +import org.junit.Test; +import org.mockito.Mockito; +import org.mockito.exceptions.base.MockitoException; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import static com.github.tomakehurst.wiremock.client.WireMock.*; Review comment: Sounds like a better idea. I will get the wiremock removed and instead have a mocked client. Thanks This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] llowinge commented on issue #2155: Re-think MockBackendUtils class so it is not needed to use it manually
llowinge commented on issue #2155:
URL: https://github.com/apache/camel-quarkus/issues/2155#issuecomment-767749705
I've noticed that the message ("Mock backend will be used") also doesn't
print the name of the test/module, which would be also really handy for
exclusion by given name. But it would be possible to parse it somehow from log,
but i'm not sure how.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
[GitHub] [camel] oscerd commented on pull request #4697: [CAMEL-15341] Create camel-azure-storage-datalake to serve Azure DataLakes Gen2
oscerd commented on pull request #4697: URL: https://github.com/apache/camel/pull/4697#issuecomment-767745305 I mean run the full build and then run mvn install only on the component. They will run This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] oscerd commented on pull request #4697: [CAMEL-15341] Create camel-azure-storage-datalake to serve Azure DataLakes Gen2
oscerd commented on pull request #4697: URL: https://github.com/apache/camel/pull/4697#issuecomment-767744419 Rebase and run a full build mvn install -DskipTests.. they will run if you have docker service running. You have to deactivate the profile by default, ignore the test, remove the tests or find a different approach. This is an automated message from the 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] aryankoul edited a comment on pull request #4697: [CAMEL-15341] Create camel-azure-storage-datalake to serve Azure DataLakes Gen2
aryankoul edited a comment on pull request #4697: URL: https://github.com/apache/camel/pull/4697#issuecomment-767741560 > If you run the mvn install on this component the tests will run anyway and fail. No matter the profile. AFAIK , only those files are included automatically for test which have "Test" as prefix or suffix. Thats why i changed the names of the test files that were failing due to lack of access key, to have suffix "IT" instead of "Test", so that they do not run automatically in mvn commands. I have added a profile to run them explicitly. This is an automated message from the 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] aryankoul commented on pull request #4697: [CAMEL-15341] Create camel-azure-storage-datalake to serve Azure DataLakes Gen2
aryankoul commented on pull request #4697: URL: https://github.com/apache/camel/pull/4697#issuecomment-767741560 > If you run the mvn install on this component the tests will run anyway and fail. No matter the profile. AFAIK , only those files are included automatically for test which have "Test" as prefix or suffix. Thats why i changed the names of the test files that were failing due to lack of access key, to have prefix "IT" instead of "Test", so that they do not run automatically in mvn commands. I have added a profile to run them explicitly. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] oscerd commented on pull request #4697: [CAMEL-15341] Create camel-azure-storage-datalake to serve Azure DataLakes Gen2
oscerd commented on pull request #4697: URL: https://github.com/apache/camel/pull/4697#issuecomment-767734032 Lets try to find a solution, because we would like to release 3.8 soon. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] oscerd commented on pull request #4697: [CAMEL-15341] Create camel-azure-storage-datalake to serve Azure DataLakes Gen2
oscerd commented on pull request #4697: URL: https://github.com/apache/camel/pull/4697#issuecomment-767733715 If you have docker service running, they will run with a pure mvn install. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] oscerd commented on pull request #4697: [CAMEL-15341] Create camel-azure-storage-datalake to serve Azure DataLakes Gen2
oscerd commented on pull request #4697: URL: https://github.com/apache/camel/pull/4697#issuecomment-767727934 If you run the mvn install on this component the tests will run anyway and fail. No matter the profile. This is an automated message from the 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 #4935: CAMEL-16080: Migrate camel-kamelet component from camel-k-runtime to camel
davsclaus commented on pull request #4935: URL: https://github.com/apache/camel/pull/4935#issuecomment-767725202 And it would be nice with an example at camel-examples git repo This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] davsclaus commented on a change in pull request #4935: CAMEL-16080: Migrate camel-kamelet component from camel-k-runtime to camel
davsclaus commented on a change in pull request #4935:
URL: https://github.com/apache/camel/pull/4935#discussion_r564716563
##
File path:
catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/kamelet-component.adoc
##
@@ -0,0 +1,144 @@
+[[kamelet-component]]
+= Kamelet Component
+:docTitle: Kamelet
+:artifactId: camel-kamelet
+:description: The Kamelet Component provides support for interacting with the
Camel Route Template engine
+:since: 3.8
+:supportLevel: Preview
+:component-header: Both producer and consumer are supported
+:core:
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/components/kamelet.adoc[opts=optional]
+
+*Since Camel {since}*
+
+*{component-header}*
+
+The Kamelet Component provides support for interacting with the
https://camel.apache.org/manual/latest/route-template.html[Camel Route
Template] engine using Endpoint semantic.
+
+== URI format
+
+[source]
+
+kamelet:kamelet:templateId/routeId[?options]
Review comment:
kamelet is duplicated
##
File path:
catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/kamelet-component.adoc
##
@@ -0,0 +1,144 @@
+[[kamelet-component]]
+= Kamelet Component
+:docTitle: Kamelet
+:artifactId: camel-kamelet
+:description: The Kamelet Component provides support for interacting with the
Camel Route Template engine
+:since: 3.8
+:supportLevel: Preview
+:component-header: Both producer and consumer are supported
+:core:
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/components/kamelet.adoc[opts=optional]
+
+*Since Camel {since}*
+
+*{component-header}*
+
+The Kamelet Component provides support for interacting with the
https://camel.apache.org/manual/latest/route-template.html[Camel Route
Template] engine using Endpoint semantic.
+
+== URI format
+
+[source]
+
+kamelet:kamelet:templateId/routeId[?options]
+
+
+== Options
+
+
+
+// component options: START
+The Kamelet component supports 7 options, which are listed below.
+
+
+
+[width="100%",cols="2,5,^1,2",options="header"]
+|===
+| Name | Description | Default | Type
+| *routeProperties* (common) | Set route local parameters. | | Map
+| *templateProperties* (common) | Set template local parameters. | | Map
+| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions occurred while the
consumer is trying to pickup incoming messages, or the likes, will now be
processed as a message and handled by the routing Error Handler. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored. | false |
boolean
+| *block* (producer) | If sending a message to a kamelet endpoint which has no
active consumer, then we can tell the producer to block and wait for the
consumer to become active. | true | boolean
+| *lazyStartProducer* (producer) | Whether the producer should be started lazy
(on the first message). By starting lazy you can use this to allow CamelContext
and routes to startup in situations where a producer may otherwise fail during
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and starting the producer may take a little time and prolong the
total processing time of the processing. | false | boolean
+| *timeout* (producer) | The timeout value to use if block is enabled. | 3
| long
+| *autowiredEnabled* (advanced) | Whether autowiring is enabled. This is used
for automatic autowiring options (the option must be marked as autowired) by
looking up in the registry to find if there is a single instance of matching
type, which then gets configured on the component. This can be used for
automatic configuring JDBC data sources, JMS connection factories, AWS Clients,
etc. | true | boolean
+|===
+// component options: END
+
+
+
+
+// endpoint options: START
+The Kamelet endpoint is configured using URI syntax:
+
+
+kamelet:templateId/routeId
+
+
+with the following path and query parameters:
+
+=== Path Parameters (2 parameters):
+
+
+[width="100%",cols="2,5,^1,2",options="header"]
+|===
+| Name | Description | Default | Type
+| *templateId* | *Required* The Route Template ID | | String
+| *routeId* | The Route ID. Default value notice: The ID will be
auto-generated if not provided | | String
+|===
+
+
+=== Query Parameters (7 parameters):
+
+
+[width="100%",cols="2,5,^1,2",options="header"]
+|===
+| Name | Description | Default | Type
+| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions occurred while the
consumer is trying to pickup incoming messages, or the likes, will now be
processed as a message and
[GitHub] [camel] aryankoul commented on pull request #4697: [CAMEL-15341] Create camel-azure-storage-datalake to serve Azure DataLakes Gen2
aryankoul commented on pull request #4697: URL: https://github.com/apache/camel/pull/4697#issuecomment-767716992 > For the moment it is in a local branch on my machine, correctly rebased. Please fix the tests. @oscerd i have fixed the tests, please check 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
[camel-examples] branch master updated: Add an example of list large azure storage blob container. (#32)
This is an automated email from the ASF dual-hosted git repository.
oalsafi 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 386b8de Add an example of list large azure storage blob container.
(#32)
386b8de is described below
commit 386b8de50f5dbb7e3f0160177883abf05e8d8a3d
Author: Mark Andreev
AuthorDate: Tue Jan 26 20:24:48 2021 +0300
Add an example of list large azure storage blob container. (#32)
---
examples/README.adoc | 2 +
.../camel-example-azure-storage-blob/README.adoc | 47 ++
examples/camel-example-azure-storage-blob/pom.xml | 103 +
.../example/azurestorageblob/Application.java | 80
.../src/main/resources/log4j2.properties | 23 +
examples/pom.xml | 1 +
6 files changed, 256 insertions(+)
diff --git a/examples/README.adoc b/examples/README.adoc
index 8c15fae..bd5e49e 100644
--- a/examples/README.adoc
+++ b/examples/README.adoc
@@ -76,6 +76,8 @@ Number of Examples: 86 (0 deprecated)
| link:camel-example-ssh/README.adoc[Ssh] (camel-example-ssh) | Beginner | An
example that uses Camel SSH component
+| link:camel-example-azure-storage-blob/README.adoc[Azure Storage Blob List]
(camel-example-azure-storage-blob) | Beginner | An example that uses Camel
Azure Storage Blob and explain how list large blob container.
+
| link:camel-example-cassandra-kubernetes/README.adoc[Cassandra Kubernetes]
(camel-example-cassandra-kubernetes) | Cloud | An example with Camel and
Cassandra running on Kubernetes
| link:camel-example-cdi-aws-s3/README.adoc[CDI AWS S3]
(camel-example-cdi-aws-s3) | Cloud | AWS S3 CDI example
diff --git a/examples/camel-example-azure-storage-blob/README.adoc
b/examples/camel-example-azure-storage-blob/README.adoc
new file mode 100644
index 000..7986864
--- /dev/null
+++ b/examples/camel-example-azure-storage-blob/README.adoc
@@ -0,0 +1,47 @@
+== Camel Basic Example
+
+=== Introduction
+
+This is a very basic example that shows how to list large azure storage blob
container.
+
+This example shows you that Camel can be used in standalone mode
+as a _public static void main_ application.
+
+The example has only 1 java file in the `Application.java` located in the src
folder.
+There is code comments explaining in more details.
+
+Set `ACCOUNT` & `ACCESS_KEY` & `BLOB_CONTAINER_NAME` for start example.
+
+=== Build
+
+You will need to compile this example first:
+
+
+mvn compile
+
+
+=== Run
+
+To run the example type
+
+
+mvn camel:run
+
+
+The
+
+To stop the example hit ctrl+c
+
+You can also run the example from your editor such as Eclipse, IDEA etc,
+by opening the org.apache.camel.example.basic.CamelBasic class
+and then right click, and chose run java application.
+
+=== 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-azure-storage-blob/pom.xml
b/examples/camel-example-azure-storage-blob/pom.xml
new file mode 100644
index 000..183440f
--- /dev/null
+++ b/examples/camel-example-azure-storage-blob/pom.xml
@@ -0,0 +1,103 @@
+
+
+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.8.0-SNAPSHOT
+
+
+camel-example-azure-storage-blob
+jar
+Camel :: Example :: Azure Storage Blob
+Azure Storage Blob example
+
+
+Beginner
+
+
+
+
+
+
+org.apache.camel
+camel-bom
+${camel.version}
+pom
+import
+
+
+
+
+
+
+
+org.apache.camel
+camel-core
+
+
+
+org.apache.camel
+camel-azure-storage-blob
+
+
+
+
+org.apache.logging.log4j
+log4j-api
+runtime
+${log4j2-version}
+
+
+org.apache.logging.log4j
+log4j-core
+runtime
+${log4j2-version}
+
+
+org.apache.logging.log4j
+log4j-slf4j-impl
+runtime
+${log4j2-version}
+
+
+
+
+
+
+
+
+
+org.apache.camel
+camel-maven-plugin
+${camel.version}
+
+
org.apache.camel.example.azurestorageblob.Application
+
[GitHub] [camel-examples] omarsmak merged pull request #32: Add an example of list large azure storage blob container.
omarsmak merged pull request #32: URL: https://github.com/apache/camel-examples/pull/32 This is an automated message from the 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-examples] omarsmak commented on pull request #32: Add an example of list large azure storage blob container.
omarsmak commented on pull request #32: URL: https://github.com/apache/camel-examples/pull/32#issuecomment-767698688 Thanks @mrk-andreev for the example. Besides this example, would be great if we can come up with solution on camel-azure-storage-blob component side as Andrea mentioned This is an automated message from the 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] aldettinger commented on issue #2107: Redis native support
aldettinger commented on issue #2107: URL: https://github.com/apache/camel-quarkus/issues/2107#issuecomment-767695135 Work in progress in this branch https://github.com/aldettinger/camel-quarkus/commits/CAMEL-QUARKUS-2107 This is an automated message from the 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 #1666: Workaround for knative-source loader does not exists any more?
lburgazzoli commented on issue #1666: URL: https://github.com/apache/camel-k/issues/1666#issuecomment-767686522 @nicolaferraro is this still an issue ? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] lburgazzoli commented on pull request #4937: Fix Consul key path used when determining leader.
lburgazzoli commented on pull request #4937: URL: https://github.com/apache/camel/pull/4937#issuecomment-767685044 @colin-mullikin thx for spotting this, is there any chance you also provide a test ? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-k] astefanutti opened a new pull request #1950: chore(crd): Use conversion-gen API for structured conversion of CRDs to v1beta1
astefanutti opened a new pull request #1950: URL: https://github.com/apache/camel-k/pull/1950 **Release Note** ```release-note NONE ``` This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-examples] mrk-andreev opened a new pull request #32: Add an example of list large azure storage blob container.
mrk-andreev opened a new pull request #32: URL: https://github.com/apache/camel-examples/pull/32 I found problem with list large Azure Storage Blob container (~250k blobs). Now we have work around that I want to share with another camel users. Short discussion in mailing list: http://mail-archives.apache.org/mod_mbox/camel-users/202101.mbox/browser This is an automated message from the 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] colin-mullikin opened a new pull request #4937: Fix Consul key path used when determining leader.
colin-mullikin opened a new pull request #4937: URL: https://github.com/apache/camel/pull/4937 The session lock is on the full key path, not on the root path. As far as I can tell, the result of this method isn't actually used anywhere, but this fix at least makes it correct. I discovered this issue due to my Consul ACL policy. My application has access to the full key path, but does not have access to the configured root path, so I was getting an error at startup. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] oscerd commented on pull request #4697: [CAMEL-15341] Create camel-azure-storage-datalake to serve Azure DataLakes Gen2
oscerd commented on pull request #4697: URL: https://github.com/apache/camel/pull/4697#issuecomment-767665329 For the moment it is in a local branch on my machine, correctly rebased. Please fix the tests. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] oscerd commented on pull request #4697: [CAMEL-15341] Create camel-azure-storage-datalake to serve Azure DataLakes Gen2
oscerd commented on pull request #4697: URL: https://github.com/apache/camel/pull/4697#issuecomment-767663238 Merged but tests are failing [ERROR] Errors: [ERROR] org.apache.camel.component.azure.storage.datalake.integration.DataLakeConsumerTest.null [ERROR] Run 1: DataLakeConsumerTest>BaseIT.initProperties:80 » NullPointer 'accountName' cann... [ERROR] Run 2: DataLakeConsumerTest>BaseIT.initProperties:80 » NullPointer 'accountName' cann... [ERROR] Run 3: DataLakeConsumerTest>BaseIT.initProperties:80 » NullPointer 'accountName' cann... [INFO] [ERROR] org.apache.camel.component.azure.storage.datalake.integration.DataLakeFileOperationTest.null [ERROR] Run 1: DataLakeFileOperationTest>BaseIT.initProperties:80 » NullPointer 'accountName'... [ERROR] Run 2: DataLakeFileOperationTest>BaseIT.initProperties:80 » NullPointer 'accountName'... [ERROR] Run 3: DataLakeFileOperationTest>BaseIT.initProperties:80 » NullPointer 'accountName'... [INFO] [ERROR] org.apache.camel.component.azure.storage.datalake.integration.DataLakeFileSystemOperationTest.null [ERROR] Run 1: DataLakeFileSystemOperationTest>BaseIT.initProperties:80 » NullPointer 'accoun... [ERROR] Run 2: DataLakeFileSystemOperationTest>BaseIT.initProperties:80 » NullPointer 'accoun... [ERROR] Run 3: DataLakeFileSystemOperationTest>BaseIT.initProperties:80 » NullPointer 'accoun... This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel-quarkus] jamesnetherton commented on pull request #2169: XML Tokenize language native support
jamesnetherton commented on pull request #2169: URL: https://github.com/apache/camel-quarkus/pull/2169#issuecomment-767633676 > Shouldn't we try to offer the woodstox stuff to Quarkus project? (Seems to be a better place than e.g. Quarkiverse) I can ask the Quarkus folks. Any reason to not want to go with Quarkiverse? My guess is that it'll be suggested that it should live there. This is an automated message from the 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] omarsmak opened a new pull request #4936: CAMEL-15933: Add Stitch component to Camel
omarsmak opened a new pull request #4936: URL: https://github.com/apache/camel/pull/4936 - [ ] 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-quarkus] jamesnetherton opened a new pull request #2169: XML Tokenize language native support
jamesnetherton opened a new pull request #2169: URL: https://github.com/apache/camel-quarkus/pull/2169 Fixes #780 This is an automated message from the 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] omarsmak commented on pull request #4697: [CAMEL-15341] Create camel-azure-storage-datalake to serve Azure DataLakes Gen2
omarsmak commented on pull request #4697: URL: https://github.com/apache/camel/pull/4697#issuecomment-767595549 > It cannot be rebased. But I'll try to merge it today or tomorrow Thanks a lot! This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] oscerd commented on pull request #4697: [CAMEL-15341] Create camel-azure-storage-datalake to serve Azure DataLakes Gen2
oscerd commented on pull request #4697: URL: https://github.com/apache/camel/pull/4697#issuecomment-767594761 It cannot be rebased. But I'll try to merge it today or tomorrow This is an automated message from the 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] omarsmak commented on pull request #4697: [CAMEL-15341] Create camel-azure-storage-datalake to serve Azure DataLakes Gen2
omarsmak commented on pull request #4697: URL: https://github.com/apache/camel/pull/4697#issuecomment-767593288 Can we merge 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
[camel-k] branch master updated: doc: local development environment
This is an automated email from the ASF dual-hosted git repository.
astefanutti pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-k.git
The following commit(s) were added to refs/heads/master by this push:
new 3b51630 doc: local development environment
3b51630 is described below
commit 3b5163027cd8077bfd9b67c027a87b6779840041
Author: Pasquale Congiusti
AuthorDate: Tue Jan 26 11:30:21 2021 +0100
doc: local development environment
Added a section to instruct how to run a Camel K operator locally.
---
docs/modules/ROOT/nav-end.adoc | 3 +-
.../ROOT/pages/{ => contributing}/developers.adoc | 4 ++
.../ROOT/pages/contributing/local-development.adoc | 59 ++
3 files changed, 65 insertions(+), 1 deletion(-)
diff --git a/docs/modules/ROOT/nav-end.adoc b/docs/modules/ROOT/nav-end.adoc
index 03d45be..d3c6f62 100644
--- a/docs/modules/ROOT/nav-end.adoc
+++ b/docs/modules/ROOT/nav-end.adoc
@@ -14,4 +14,5 @@
** xref:architecture/traits.adoc[Traits]
** xref:architecture/sources.adoc[Sources]
* xref:uninstalling.adoc[Uninstalling]
-* xref:developers.adoc[Contributing]
+* xref:contributing/developers.adoc[Contributing]
+** xref:contributing/local-development.adoc[Local development]
diff --git a/docs/modules/ROOT/pages/developers.adoc
b/docs/modules/ROOT/pages/contributing/developers.adoc
similarity index 97%
rename from docs/modules/ROOT/pages/developers.adoc
rename to docs/modules/ROOT/pages/contributing/developers.adoc
index 2a0cda3..80463ca 100644
--- a/docs/modules/ROOT/pages/developers.adoc
+++ b/docs/modules/ROOT/pages/contributing/developers.adoc
@@ -155,6 +155,10 @@ To add additional dependencies to your routes:
./kamel run -d camel:dns examples/dns.js
+[[local-development]]
+== Local development environment
+If you need to develop and test your Camel K operator locally, you can follow
the link:local-development.html[local development procedure].
+
[[debugging]]
== Debugging and Running from IDE
diff --git a/docs/modules/ROOT/pages/contributing/local-development.adoc
b/docs/modules/ROOT/pages/contributing/local-development.adoc
new file mode 100644
index 000..1229590
--- /dev/null
+++ b/docs/modules/ROOT/pages/contributing/local-development.adoc
@@ -0,0 +1,59 @@
+[[development-environment]]
+= Local development environment
+
+If you plan to contribute to Camel K, you will end up needing to run and
troubleshoot your operator code locally. Here a guideline that will help you
configure your local operator running.
+
+[[local-operator]]
+== Running operator locally
+
+As soon as you build your operator locally you will ask yourself how to test
it. The idea is that you execute it locally and instruct it to **watch** a
namespace on a Kubernetes cluster (it may be remote or any local environment).
Let's use a namespace called ``operator-test``.
+
+* We start by setting the environment variable ``WATCH_NAMESPACE`` with the
namespace you'd like your operator to watch.
+
+export WATCH_NAMESPACE=operator-test
+
+
+* The next step is to install an ``IntegrationPlatform`` on the cluster
namespace. You probably need to tweak the registry parameters in order to be
able to authenticate against an image repository (see below paragraph for local
repository instructions).
+
+./kamel install --skip-operator-setup -n operator-test --registry
my-registry:5000
+
+
+* Finally, assuming you've builded your application correctly we can run the
operator:
+-
+./kamel operator
+-
+
+* Test the local operator by creating a test `Integration`.
+-
+./kamel run xyz.abc -n operator-test
+-
+
+IMPORTANT: make sure no other Camel K Operators are watching that namespace,
neither you have a global Camel K Operator installed on your cluster.
+
+[[local-minikube]]
+== Local operator and local cluster
+
+If you want to run a local operator togheter with ``Minikube`` you will need
an additional step in order to let the local operator being able to push images
in the local registry. We need to expose the local registry as described in
https://minikube.sigs.k8s.io/docs/handbook/registry/#docker-on-windows[this
procedure]:
+
+* Enable the addon registry (this should be already in place):
+
+minikube addons enable registry
+
+
+* Get the ``Pod`` name that is in charge to run the registry and proxy the
registry 5000 port to be used locally.
+
+kubectl get pods -n kube-system
+NAME READY STATUSRESTARTS AGE
+...
+registry-fttbv 1/1 Running 40 89d
+...
+
+kubectl port-forward --namespace kube-system registry-fttbv 5000:5000
+
+
+* Update the ``IntegrationPlatform`` to instruct it to use the ``localhost``
registry:
+
+./kamel install --skip-operator-setup -n operator-test --registry
localhost:5000 --force
+
+
+A similar procedure may work if you use other local environments. The idea is
[GitHub] [camel-k] astefanutti merged pull request #1949: doc: local development environment
astefanutti merged pull request #1949: URL: https://github.com/apache/camel-k/pull/1949 This is an automated message from the 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] dmvolod commented on pull request #1767: Fix build issue with openshift API version in go.mod
dmvolod commented on pull request #1767: URL: https://github.com/apache/camel-k/pull/1767#issuecomment-767579317 @nicolaferraro , @lburgazzoli could you please a look, seems to be compile from scratch (without initial vendor folder) cause this problem This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [camel] lburgazzoli opened a new pull request #4935: CAMEL-16080: Migrate camel-kamelet component from camel-k-runtime to camel
lburgazzoli opened a new pull request #4935: URL: https://github.com/apache/camel/pull/4935 - [ ] 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
