This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch camel-2.x
in repository https://gitbox.apache.org/repos/asf/camel.git.
from baf898b CAMEL-13433 - Fixed CS
new 585a263 CAMEL-12665 - Pulsar component
new 355afb4 CAMEL-12665 - Fixed component
new aa3191e CAMEL-12665 - Added docs
new 9677b45 CAMEL-12665 - Regen
new 5c8207b CAMEL-12665 - Regen docs
new 05e8eaa CAMEL-12665 - Regen
new a6570d4 CAMEL-13405 - Camel-Pulsar: Create integration test for Karaf
and SB - Karaf Itests
new 3905de1 CAMEL-13405 - Camel-Pulsar: Create integration test for Karaf
and SB - SB Itests
new 7a3708a CAMEL-13404 - Added Karaf feature for Camel-Pulsar
new 384a3c0 CAMEL-12665 - Fixed CS
new 46d8562 CAMEL-12665 - Fixed CS
new 5ff52a9 CAMEL-12665 - Use log4j2
The 34456 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
apache-camel/pom.xml | 9 ++
bom/camel-bom/pom.xml | 10 ++
components/camel-pulsar/pom.xml | 98 ++++++++++++
.../src/main/docs/pulsar-component.adoc | 101 +++++++++++++
.../camel/component/pulsar/PulsarComponent.java | 81 ++++++++++
.../camel/component/pulsar/PulsarConsumer.java | 81 ++++++++++
.../camel/component/pulsar/PulsarEndpoint.java | 92 ++++++++++++
.../component/pulsar/PulsarMessageListener.java | 64 ++++++++
.../camel/component/pulsar/PulsarProducer.java | 73 +++++++++
.../pulsar/configuration/PulsarConfiguration.java | 119 +++++++++++++++
.../component/pulsar/utils/AutoConfiguration.java | 80 ++++++++++
.../camel/component/pulsar/utils/PulsarPath.java | 48 ++++++
.../camel/component/pulsar/utils/PulsarUtils.java | 40 +++++
.../consumers/CommonCreationStrategyImpl.java | 37 +++++
.../utils/consumers/ConsumerCreationStrategy.java | 27 ++++
.../consumers/ConsumerCreationStrategyFactory.java | 54 +++++++
.../utils/consumers/ExclusiveConsumerStrategy.java | 43 ++++++
.../utils/consumers/FailoverConsumerStrategy.java | 63 ++++++++
.../utils/consumers/SharedConsumerStrategy.java | 63 ++++++++
.../pulsar/utils/consumers/SubscriptionType.java | 21 +++
.../pulsar/utils/message/PulsarMessageHeaders.java | 30 ++++
.../pulsar/utils/message/PulsarMessageUtils.java | 86 +++++++++++
.../src/main/resources/META-INF/LICENSE.txt | 0
.../src/main/resources/META-INF/NOTICE.txt | 0
.../services/org/apache/camel/component/pulsar | 18 +++
.../component/pulsar/PulsarComponentTest.java | 77 ++++++++++
.../pulsar/PulsarConcurrentConsumerInTest.java | 118 +++++++++++++++
.../pulsar/PulsarConcurrentProducerInTest.java | 116 ++++++++++++++
.../component/pulsar/PulsarConsumerInTest.java | 119 +++++++++++++++
.../camel/component/pulsar/PulsarEndpointTest.java | 28 ++++
.../component/pulsar/PulsarProducerInTest.java | 109 ++++++++++++++
.../pulsar/utils/AutoConfigurationTest.java | 105 +++++++++++++
.../component/pulsar/utils/PulsarUtilsTest.java | 73 +++++++++
.../ConsumerCreationStrategyFactoryTest.java | 75 ++++++++++
.../utils/message/PulsarMessageUtilsTest.java | 61 ++++++++
.../src/test/resources/log4j2.properties | 28 ++++
.../camel-rmi/src/main/docs/rmi-component.adoc | 2 +
components/pom.xml | 1 +
components/readme.adoc | 11 +-
docs/components/modules/ROOT/nav.adoc | 11 +-
.../modules/ROOT/pages/pulsar-component.adoc | 1 +
examples/camel-example-spring-pulsar/README.md | 35 +++++
examples/camel-example-spring-pulsar/pom.xml | 166 +++++++++++++++++++++
.../camel/example/pulsar/client/CamelClient.java | 55 +++++++
.../example/pulsar/client/CamelClientEndpoint.java | 81 ++++++++++
.../camel/example/pulsar/server/Multiplier.java | 34 +++++
.../camel/example/pulsar/server/ServerRoutes.java | 40 +++++
.../apache/camel/example/pulsar/server/Treble.java | 34 +++++
.../example/pulsar/server/TypeConverters.java | 29 ++++
.../src/main/resources/META-INF/LICENSE.txt | 0
.../src/main/resources/META-INF/NOTICE.txt | 0
.../resources/META-INF/spring/camel-server.xml | 82 ++++++++++
.../src/main/resources/camel-client.xml | 68 +++++++++
.../src/main/resources/camel.properties | 18 +++
.../src/main/resources/features.xml | 29 ++++
.../src/main/resources/log4j2.properties | 25 ++++
.../camel/example/SpringJmsClientServerTest.java | 89 +++++++++++
examples/pom.xml | 1 +
parent/pom.xml | 23 +++
.../karaf/features/src/main/resources/features.xml | 6 +
.../camel-pulsar-starter/pom.xml | 53 +++++++
.../PulsarComponentAutoConfiguration.java | 128 ++++++++++++++++
.../springboot/PulsarComponentConfiguration.java | 84 +++++++++++
.../src/main/resources/META-INF/LICENSE.txt | 0
.../src/main/resources/META-INF/NOTICE.txt | 0
.../src/main/resources/META-INF/spring.factories | 19 +++
.../src/main/resources/META-INF/spring.provides | 17 +++
platforms/spring-boot/components-starter/pom.xml | 1 +
.../camel-spring-boot-dependencies/pom.xml | 32 +++-
.../apache/camel/itest/karaf/CamelPulsarTest.java | 34 +++++
.../camel/itest/springboot/CamelPulsarTest.java | 48 ++++++
71 files changed, 3489 insertions(+), 15 deletions(-)
create mode 100644 components/camel-pulsar/pom.xml
create mode 100644 components/camel-pulsar/src/main/docs/pulsar-component.adoc
create mode 100644
components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarComponent.java
create mode 100644
components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarConsumer.java
create mode 100644
components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarEndpoint.java
create mode 100644
components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarMessageListener.java
create mode 100644
components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarProducer.java
create mode 100644
components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/configuration/PulsarConfiguration.java
create mode 100644
components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/utils/AutoConfiguration.java
create mode 100644
components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/utils/PulsarPath.java
create mode 100644
components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/utils/PulsarUtils.java
create mode 100644
components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/utils/consumers/CommonCreationStrategyImpl.java
create mode 100644
components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/utils/consumers/ConsumerCreationStrategy.java
create mode 100644
components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/utils/consumers/ConsumerCreationStrategyFactory.java
create mode 100644
components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/utils/consumers/ExclusiveConsumerStrategy.java
create mode 100644
components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/utils/consumers/FailoverConsumerStrategy.java
create mode 100644
components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/utils/consumers/SharedConsumerStrategy.java
create mode 100644
components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/utils/consumers/SubscriptionType.java
create mode 100644
components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/utils/message/PulsarMessageHeaders.java
create mode 100644
components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/utils/message/PulsarMessageUtils.java
copy {tooling/maven/guice-maven-plugin =>
components/camel-pulsar}/src/main/resources/META-INF/LICENSE.txt (100%)
copy {tooling/maven/guice-maven-plugin =>
components/camel-pulsar}/src/main/resources/META-INF/NOTICE.txt (100%)
create mode 100644
components/camel-pulsar/src/main/resources/META-INF/services/org/apache/camel/component/pulsar
create mode 100644
components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarComponentTest.java
create mode 100644
components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConcurrentConsumerInTest.java
create mode 100644
components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConcurrentProducerInTest.java
create mode 100644
components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerInTest.java
create mode 100644
components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarEndpointTest.java
create mode 100644
components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarProducerInTest.java
create mode 100644
components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/utils/AutoConfigurationTest.java
create mode 100644
components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/utils/PulsarUtilsTest.java
create mode 100644
components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/utils/consumers/ConsumerCreationStrategyFactoryTest.java
create mode 100644
components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/utils/message/PulsarMessageUtilsTest.java
create mode 100644 components/camel-pulsar/src/test/resources/log4j2.properties
create mode 120000 docs/components/modules/ROOT/pages/pulsar-component.adoc
create mode 100644 examples/camel-example-spring-pulsar/README.md
create mode 100644 examples/camel-example-spring-pulsar/pom.xml
create mode 100644
examples/camel-example-spring-pulsar/src/main/java/org/apache/camel/example/pulsar/client/CamelClient.java
create mode 100644
examples/camel-example-spring-pulsar/src/main/java/org/apache/camel/example/pulsar/client/CamelClientEndpoint.java
create mode 100644
examples/camel-example-spring-pulsar/src/main/java/org/apache/camel/example/pulsar/server/Multiplier.java
create mode 100644
examples/camel-example-spring-pulsar/src/main/java/org/apache/camel/example/pulsar/server/ServerRoutes.java
create mode 100644
examples/camel-example-spring-pulsar/src/main/java/org/apache/camel/example/pulsar/server/Treble.java
create mode 100644
examples/camel-example-spring-pulsar/src/main/java/org/apache/camel/example/pulsar/server/TypeConverters.java
copy {tooling/maven/guice-maven-plugin =>
examples/camel-example-spring-pulsar}/src/main/resources/META-INF/LICENSE.txt
(100%)
copy {tooling/maven/guice-maven-plugin =>
examples/camel-example-spring-pulsar}/src/main/resources/META-INF/NOTICE.txt
(100%)
create mode 100644
examples/camel-example-spring-pulsar/src/main/resources/META-INF/spring/camel-server.xml
create mode 100644
examples/camel-example-spring-pulsar/src/main/resources/camel-client.xml
create mode 100644
examples/camel-example-spring-pulsar/src/main/resources/camel.properties
create mode 100644
examples/camel-example-spring-pulsar/src/main/resources/features.xml
create mode 100644
examples/camel-example-spring-pulsar/src/main/resources/log4j2.properties
create mode 100644
examples/camel-example-spring-pulsar/src/test/java/org/apache/camel/example/SpringJmsClientServerTest.java
create mode 100644
platforms/spring-boot/components-starter/camel-pulsar-starter/pom.xml
create mode 100644
platforms/spring-boot/components-starter/camel-pulsar-starter/src/main/java/org/apache/camel/component/pulsar/springboot/PulsarComponentAutoConfiguration.java
create mode 100644
platforms/spring-boot/components-starter/camel-pulsar-starter/src/main/java/org/apache/camel/component/pulsar/springboot/PulsarComponentConfiguration.java
copy {tooling/maven/guice-maven-plugin =>
platforms/spring-boot/components-starter/camel-pulsar-starter}/src/main/resources/META-INF/LICENSE.txt
(100%)
copy {tooling/maven/guice-maven-plugin =>
platforms/spring-boot/components-starter/camel-pulsar-starter}/src/main/resources/META-INF/NOTICE.txt
(100%)
create mode 100644
platforms/spring-boot/components-starter/camel-pulsar-starter/src/main/resources/META-INF/spring.factories
create mode 100644
platforms/spring-boot/components-starter/camel-pulsar-starter/src/main/resources/META-INF/spring.provides
create mode 100644
tests/camel-itest-karaf/src/test/java/org/apache/camel/itest/karaf/CamelPulsarTest.java
create mode 100644
tests/camel-itest-spring-boot/src/test/java/org/apache/camel/itest/springboot/CamelPulsarTest.java
