You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2019/04/10 07:43:10 UTC
[camel] branch master updated (4c0e2aa -> 56acd9d)
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 4c0e2aa Fix operation name in exception message
new b917194 CAMEL-12665 - Apache Pulsar integration via component
new c96df1b CAMEL-12665 - Use Log4j2.properties
new 000775f CAMEL-12665 - Ported the component to Camel 3
new b50733c CAMEL-12665 - Added camel-pulsar to kit
new c0cf59f CAMEL-12665 - Rebased to Camel 3
new c70b6c8 CAMEL-12665 - More alignment to Camel 3 and configuration
new 36bff3d CAMEL-12665 - Added autogenerated docs
new 85318ac Regen
new 8780086 CAMEL-12665 - Fixed CS
new 56acd9d CAMEL-12665 - Aligned the example to the camel 3 alignment of the component
The 36501 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 | 10 ++
apache-camel/src/main/descriptors/common-bin.xml | 2 +
bom/camel-bom/pom.xml | 10 ++
.../src/main/docs/aws-s3-component.adoc | 2 +-
components/camel-pulsar/pom.xml | 97 ++++++++++++
.../src/main/docs/pulsar-component.adoc | 114 ++++++++++++++
.../camel/component/pulsar/PulsarComponent.java | 83 +++++++++++
.../camel/component/pulsar/PulsarConsumer.java | 81 ++++++++++
.../camel/component/pulsar/PulsarEndpoint.java | 92 ++++++++++++
.../component/pulsar/PulsarMessageListener.java | 64 ++++++++
.../camel/component/pulsar/PulsarProducer.java | 79 ++++++++++
.../pulsar/configuration/PulsarConfiguration.java | 126 ++++++++++++++++
.../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 +++++++++++
.../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 ++++
components/pom.xml | 1 +
components/readme.adoc | 5 +-
docs/components/modules/ROOT/nav.adoc | 1 +
.../modules/ROOT/pages/aws-s3-component.adoc | 4 +-
.../modules/ROOT/pages/pulsar-component.adoc | 114 ++++++++++++++
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 +++
.../camel-pulsar-starter/pom.xml | 53 +++++++
.../PulsarComponentAutoConfiguration.java | 128 ++++++++++++++++
.../springboot/PulsarComponentConfiguration.java | 80 ++++++++++
.../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 | 20 +++
67 files changed, 3509 insertions(+), 4 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
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 100644 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/camel-package-maven-plugin => examples/camel-example-spring-pulsar}/src/main/resources/META-INF/LICENSE.txt (100%)
copy {tooling/maven/camel-package-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/camel-package-maven-plugin => platforms/spring-boot/components-starter/camel-pulsar-starter}/src/main/resources/META-INF/LICENSE.txt (100%)
copy {tooling/maven/camel-package-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