You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ja...@apache.org on 2021/02/11 12:48:45 UTC
[camel-quarkus] branch master updated (5332d4f -> 3edfdc9)
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git.
from 5332d4f Remove redundant Netty reflective class configuration
new cee9221 camel-spring-rabbitmq - new component #2128
new 3edfdc9 Deprecation changes caused by upgrade to the Camel 3.8.
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
catalog/pom.xml | 13 +++
.../{oaipmh.adoc => spring-rabbitmq.adoc} | 18 ++--
.../reference/components/spring-rabbitmq.adoc | 14 ++-
.../main/resources/META-INF/quarkus-extension.yaml | 1 +
.../main/resources/META-INF/quarkus-extension.yaml | 1 +
.../main/resources/META-INF/quarkus-extension.yaml | 1 +
.../main/resources/META-INF/quarkus-extension.yaml | 1 +
.../main/resources/META-INF/quarkus-extension.yaml | 1 +
.../main/resources/META-INF/quarkus-extension.yaml | 1 +
.../main/resources/META-INF/quarkus-extension.yaml | 1 +
.../main/resources/META-INF/quarkus-extension.yaml | 1 +
.../main/resources/META-INF/quarkus-extension.yaml | 1 +
.../main/resources/META-INF/quarkus-extension.yaml | 1 +
.../main/resources/META-INF/quarkus-extension.yaml | 1 +
.../main/resources/META-INF/quarkus-extension.yaml | 1 +
.../main/resources/META-INF/quarkus-extension.yaml | 1 +
.../main/resources/META-INF/quarkus-extension.yaml | 1 +
extensions/pom.xml | 1 +
.../deployment/pom.xml | 14 ++-
.../deployment/SpringRabbitmqProcessor.java | 13 ++-
.../{azure-eventhubs => spring-rabbitmq}/pom.xml | 4 +-
.../{oaipmh => spring-rabbitmq}/runtime/pom.xml | 19 ++--
.../main/resources/META-INF/quarkus-extension.yaml | 6 +-
integration-tests/pom.xml | 1 +
.../{cassandraql => spring-rabbitmq}/pom.xml | 32 +++---
.../SpringRabbitmqConnectionFactoryProducer.java | 51 ++++++++++
.../spring/rabbitmq/it/SpringRabbitmqResource.java | 93 +++++++++++++++++
.../rabbitmq/it/SpringRabbitmqRouteBuilder.java} | 21 ++--
.../spring/rabbitmq/it/SpringRabbitmqIT.java} | 4 +-
.../spring/rabbitmq/it/SpringRabbitmqTest.java | 112 +++++++++++++++++++++
.../rabbitmq/it/SpringRabbitmqTestResource.java} | 43 ++++----
poms/bom/pom.xml | 15 +++
tooling/scripts/test-categories.yaml | 1 +
33 files changed, 401 insertions(+), 88 deletions(-)
copy docs/modules/ROOT/pages/reference/extensions/{oaipmh.adoc => spring-rabbitmq.adoc} (54%)
copy extensions/{azure-eventhubs => spring-rabbitmq}/deployment/pom.xml (82%)
copy extensions-support/aws/deployment/src/main/java/org/apache/camel/quarkus/component/aws/commons/deployment/AwsCommonsProcessor.java => extensions/spring-rabbitmq/deployment/src/main/java/org/apache/camel/quarkus/component/spring/rabbitmq/deployment/SpringRabbitmqProcessor.java (73%)
copy extensions/{azure-eventhubs => spring-rabbitmq}/pom.xml (92%)
copy extensions/{oaipmh => spring-rabbitmq}/runtime/pom.xml (87%)
copy {extensions-core/threadpoolfactory-vertx => extensions/spring-rabbitmq}/runtime/src/main/resources/META-INF/quarkus-extension.yaml (87%)
copy integration-tests/{cassandraql => spring-rabbitmq}/pom.xml (82%)
create mode 100644 integration-tests/spring-rabbitmq/src/main/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqConnectionFactoryProducer.java
create mode 100644 integration-tests/spring-rabbitmq/src/main/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqResource.java
copy integration-tests/{bean/src/main/java/org/apache/camel/quarkus/component/bean/LazyAppScopedRouteBuilder.java => spring-rabbitmq/src/main/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqRouteBuilder.java} (62%)
copy integration-tests/{activemq/src/test/java/org/apache/camel/quarkus/component/activemq/it/ActiveMQIT.java => spring-rabbitmq/src/test/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqIT.java} (88%)
create mode 100644 integration-tests/spring-rabbitmq/src/test/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqTest.java
copy integration-tests/{rabbitmq/src/test/java/org/apache/camel/quarkus/component/rabbitmq/it/RabbitmqTestResource.java => spring-rabbitmq/src/test/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqTestResource.java} (56%)
[camel-quarkus] 01/02: camel-spring-rabbitmq - new component #2128
Posted by ja...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit cee922120d5b690a6f910c987d4536773e67ab32
Author: JiriOndrusek <on...@gmail.com>
AuthorDate: Wed Feb 10 15:04:56 2021 +0100
camel-spring-rabbitmq - new component #2128
---
catalog/pom.xml | 13 ++
.../reference/extensions/spring-rabbitmq.adoc | 33 +++++
.../reference/components/spring-rabbitmq.adoc | 14 ++-
extensions/pom.xml | 1 +
extensions/spring-rabbitmq/deployment/pom.xml | 71 +++++++++++
.../deployment/SpringRabbitmqProcessor.java | 37 ++++++
extensions/spring-rabbitmq/pom.xml | 39 ++++++
extensions/spring-rabbitmq/runtime/pom.xml | 121 +++++++++++++++++++
.../main/resources/META-INF/quarkus-extension.yaml | 31 +++++
integration-tests/pom.xml | 1 +
integration-tests/spring-rabbitmq/pom.xml | 133 +++++++++++++++++++++
.../SpringRabbitmqConnectionFactoryProducer.java | 51 ++++++++
.../spring/rabbitmq/it/SpringRabbitmqResource.java | 93 ++++++++++++++
.../rabbitmq/it/SpringRabbitmqRouteBuilder.java | 37 ++++++
.../spring/rabbitmq/it/SpringRabbitmqIT.java | 24 ++++
.../spring/rabbitmq/it/SpringRabbitmqTest.java | 112 +++++++++++++++++
.../rabbitmq/it/SpringRabbitmqTestResource.java | 78 ++++++++++++
poms/bom/pom.xml | 15 +++
tooling/scripts/test-categories.yaml | 1 +
19 files changed, 904 insertions(+), 1 deletion(-)
diff --git a/catalog/pom.xml b/catalog/pom.xml
index 86f4439..a2b6bb9 100644
--- a/catalog/pom.xml
+++ b/catalog/pom.xml
@@ -3481,6 +3481,19 @@
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-spring-rabbitmq</artifactId>
+ <version>${project.version}</version>
+ <type>pom</type>
+ <scope>test</scope>
+ <exclusions>
+ <exclusion>
+ <groupId>*</groupId>
+ <artifactId>*</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
<artifactId>camel-quarkus-sql</artifactId>
<version>${project.version}</version>
<type>pom</type>
diff --git a/docs/modules/ROOT/pages/reference/extensions/spring-rabbitmq.adoc b/docs/modules/ROOT/pages/reference/extensions/spring-rabbitmq.adoc
new file mode 100644
index 0000000..bff1f77
--- /dev/null
+++ b/docs/modules/ROOT/pages/reference/extensions/spring-rabbitmq.adoc
@@ -0,0 +1,33 @@
+// Do not edit directly!
+// This file was generated by camel-quarkus-maven-plugin:update-extension-doc-page
+= Spring RabbitMQ
+:cq-artifact-id: camel-quarkus-spring-rabbitmq
+:cq-native-supported: true
+:cq-status: Stable
+:cq-description: Send and receive messages from RabbitMQ using Spring RabbitMQ client.
+:cq-deprecated: false
+:cq-jvm-since: 1.7.0
+:cq-native-since: 1.7.0
+
+[.badges]
+[.badge-key]##JVM since##[.badge-supported]##1.7.0## [.badge-key]##Native since##[.badge-supported]##1.7.0##
+
+Send and receive messages from RabbitMQ using Spring RabbitMQ client.
+
+== What's inside
+
+* xref:{cq-camel-components}::spring-rabbitmq-component.adoc[Spring RabbitMQ component], URI syntax: `spring-rabbitmq:exchangeName`
+
+Please refer to the above link for usage and configuration details.
+
+== Maven coordinates
+
+[source,xml]
+----
+<dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-spring-rabbitmq</artifactId>
+</dependency>
+----
+
+Check the xref:user-guide/index.adoc[User guide] for more information about writing Camel Quarkus applications.
diff --git a/docs/modules/ROOT/partials/reference/components/spring-rabbitmq.adoc b/docs/modules/ROOT/partials/reference/components/spring-rabbitmq.adoc
index a509c1d..fa57234 100644
--- a/docs/modules/ROOT/partials/reference/components/spring-rabbitmq.adoc
+++ b/docs/modules/ROOT/partials/reference/components/spring-rabbitmq.adoc
@@ -1 +1,13 @@
-// Empty partial for a Camel bit unsupported by Camel Quarkus to avoid warnings when this file is included from a Camel page
+// Do not edit directly!
+// This file was generated by camel-quarkus-maven-plugin:update-extension-doc-page
+:cq-artifact-id: camel-quarkus-spring-rabbitmq
+:cq-artifact-id-base: spring-rabbitmq
+:cq-native-supported: true
+:cq-status: Stable
+:cq-deprecated: false
+:cq-jvm-since: 1.7.0
+:cq-native-since: 1.7.0
+:cq-camel-part-name: spring-rabbitmq
+:cq-camel-part-title: Spring RabbitMQ
+:cq-camel-part-description: Send and receive messages from RabbitMQ using Spring RabbitMQ client.
+:cq-extension-page-title: Spring RabbitMQ
diff --git a/extensions/pom.xml b/extensions/pom.xml
index f23b94e..f6fa647 100644
--- a/extensions/pom.xml
+++ b/extensions/pom.xml
@@ -211,6 +211,7 @@
<module>snakeyaml</module>
<module>soap</module>
<module>solr</module>
+ <module>spring-rabbitmq</module>
<module>sql</module>
<module>ssh</module>
<module>stax</module>
diff --git a/extensions/spring-rabbitmq/deployment/pom.xml b/extensions/spring-rabbitmq/deployment/pom.xml
new file mode 100644
index 0000000..4d4a636
--- /dev/null
+++ b/extensions/spring-rabbitmq/deployment/pom.xml
@@ -0,0 +1,71 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+ 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.
+
+-->
+<project xmlns="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">
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-spring-rabbitmq-parent</artifactId>
+ <version>1.7.0-SNAPSHOT</version>
+ <relativePath>../pom.xml</relativePath>
+ </parent>
+
+ <artifactId>camel-quarkus-spring-rabbitmq-deployment</artifactId>
+ <name>Camel Quarkus :: Spring RabbitMQ :: Deployment</name>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-core-deployment</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-spring-rabbitmq</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-support-commons-logging-deployment</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-support-spring-deployment</artifactId>
+ </dependency>
+ </dependencies>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-compiler-plugin</artifactId>
+ <configuration>
+ <annotationProcessorPaths>
+ <path>
+ <groupId>io.quarkus</groupId>
+ <artifactId>quarkus-extension-processor</artifactId>
+ <version>${quarkus.version}</version>
+ </path>
+ </annotationProcessorPaths>
+ </configuration>
+ </plugin>
+ </plugins>
+ </build>
+
+</project>
diff --git a/extensions/spring-rabbitmq/deployment/src/main/java/org/apache/camel/quarkus/component/spring/rabbitmq/deployment/SpringRabbitmqProcessor.java b/extensions/spring-rabbitmq/deployment/src/main/java/org/apache/camel/quarkus/component/spring/rabbitmq/deployment/SpringRabbitmqProcessor.java
new file mode 100644
index 0000000..d5c6a52
--- /dev/null
+++ b/extensions/spring-rabbitmq/deployment/src/main/java/org/apache/camel/quarkus/component/spring/rabbitmq/deployment/SpringRabbitmqProcessor.java
@@ -0,0 +1,37 @@
+/*
+ * 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.quarkus.component.spring.rabbitmq.deployment;
+
+import io.quarkus.deployment.annotations.BuildStep;
+import io.quarkus.deployment.builditem.FeatureBuildItem;
+import io.quarkus.deployment.builditem.nativeimage.NativeImageProxyDefinitionBuildItem;
+import org.springframework.amqp.rabbit.connection.ChannelProxy;
+
+class SpringRabbitmqProcessor {
+
+ private static final String FEATURE = "camel-spring-rabbitmq";
+
+ @BuildStep
+ FeatureBuildItem feature() {
+ return new FeatureBuildItem(FEATURE);
+ }
+
+ @BuildStep
+ NativeImageProxyDefinitionBuildItem initProxies() {
+ return new NativeImageProxyDefinitionBuildItem(ChannelProxy.class.getCanonicalName());
+ }
+}
diff --git a/extensions/spring-rabbitmq/pom.xml b/extensions/spring-rabbitmq/pom.xml
new file mode 100644
index 0000000..19f6470
--- /dev/null
+++ b/extensions/spring-rabbitmq/pom.xml
@@ -0,0 +1,39 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+ 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.
+
+-->
+<project xmlns="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">
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-build-parent</artifactId>
+ <version>1.7.0-SNAPSHOT</version>
+ <relativePath>../../poms/build-parent/pom.xml</relativePath>
+ </parent>
+
+ <artifactId>camel-quarkus-spring-rabbitmq-parent</artifactId>
+ <name>Camel Quarkus :: Spring RabbitMQ</name>
+ <packaging>pom</packaging>
+
+ <modules>
+ <module>deployment</module>
+ <module>runtime</module>
+ </modules>
+</project>
diff --git a/extensions/spring-rabbitmq/runtime/pom.xml b/extensions/spring-rabbitmq/runtime/pom.xml
new file mode 100644
index 0000000..b84c680
--- /dev/null
+++ b/extensions/spring-rabbitmq/runtime/pom.xml
@@ -0,0 +1,121 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+ 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.
+
+-->
+<project xmlns="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">
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-spring-rabbitmq-parent</artifactId>
+ <version>1.7.0-SNAPSHOT</version>
+ <relativePath>../pom.xml</relativePath>
+ </parent>
+
+ <artifactId>camel-quarkus-spring-rabbitmq</artifactId>
+ <name>Camel Quarkus :: Spring RabbitMQ :: Runtime</name>
+ <description>Send and receive messages from RabbitMQ using Spring RabbitMQ client.</description>
+
+ <properties>
+ <camel.quarkus.jvmSince>1.7.0</camel.quarkus.jvmSince>
+ <camel.quarkus.nativeSince>1.7.0</camel.quarkus.nativeSince>
+ </properties>
+
+ <dependencyManagement>
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-bom</artifactId>
+ <version>${project.version}</version>
+ <type>pom</type>
+ <scope>import</scope>
+ </dependency>
+ </dependencies>
+ </dependencyManagement>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-core</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
+ <artifactId>camel-spring-rabbitmq</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-support-commons-logging</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-support-spring</artifactId>
+ </dependency>
+ </dependencies>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>io.quarkus</groupId>
+ <artifactId>quarkus-bootstrap-maven-plugin</artifactId>
+ </plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-compiler-plugin</artifactId>
+ <configuration>
+ <annotationProcessorPaths>
+ <path>
+ <groupId>io.quarkus</groupId>
+ <artifactId>quarkus-extension-processor</artifactId>
+ <version>${quarkus.version}</version>
+ </path>
+ </annotationProcessorPaths>
+ </configuration>
+ </plugin>
+ </plugins>
+ </build>
+
+
+ <profiles>
+ <profile>
+ <id>full</id>
+ <activation>
+ <property>
+ <name>!quickly</name>
+ </property>
+ </activation>
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-maven-plugin</artifactId>
+ <executions>
+ <execution>
+ <id>update-extension-doc-page</id>
+ <goals>
+ <goal>update-extension-doc-page</goal>
+ </goals>
+ <phase>process-classes</phase>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
+ </profile>
+ </profiles>
+</project>
diff --git a/extensions/spring-rabbitmq/runtime/src/main/resources/META-INF/quarkus-extension.yaml b/extensions/spring-rabbitmq/runtime/src/main/resources/META-INF/quarkus-extension.yaml
new file mode 100644
index 0000000..723d1e4
--- /dev/null
+++ b/extensions/spring-rabbitmq/runtime/src/main/resources/META-INF/quarkus-extension.yaml
@@ -0,0 +1,31 @@
+#
+# 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.
+#
+
+# This is a generated file. Do not edit directly!
+# To re-generate, run the following command from the top level directory:
+#
+# mvn -N cq:update-quarkus-metadata
+#
+---
+name: "Camel Spring RabbitMQ"
+description: "Send and receive messages from RabbitMQ using Spring RabbitMQ client"
+metadata:
+ guide: "https://camel.apache.org/camel-quarkus/latest/reference/extensions/spring-rabbitmq.html"
+ categories:
+ - "integration"
+ status:
+ - "stable"
diff --git a/integration-tests/pom.xml b/integration-tests/pom.xml
index b2455af..e44a762 100644
--- a/integration-tests/pom.xml
+++ b/integration-tests/pom.xml
@@ -178,6 +178,7 @@
<module>smallrye-reactive-messaging</module>
<module>soap</module>
<module>solr</module>
+ <module>spring-rabbitmq</module>
<module>sql</module>
<module>ssh</module>
<module>stax</module>
diff --git a/integration-tests/spring-rabbitmq/pom.xml b/integration-tests/spring-rabbitmq/pom.xml
new file mode 100644
index 0000000..146ff3d
--- /dev/null
+++ b/integration-tests/spring-rabbitmq/pom.xml
@@ -0,0 +1,133 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+ 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.
+
+-->
+<project xmlns="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">
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-integration-tests</artifactId>
+ <version>1.7.0-SNAPSHOT</version>
+ <relativePath>../pom.xml</relativePath>
+ </parent>
+
+ <artifactId>camel-quarkus-integration-test-spring-rabbitmq</artifactId>
+ <name>Camel Quarkus :: Integration Tests :: Spring RabbitMQ</name>
+ <description>Integration tests for Camel Quarkus Spring RabbitMQ extension</description>
+
+ <dependencyManagement>
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-bom-test</artifactId>
+ <version>${project.version}</version>
+ <type>pom</type>
+ <scope>import</scope>
+ </dependency>
+ </dependencies>
+ </dependencyManagement>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-spring-rabbitmq</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>io.quarkus</groupId>
+ <artifactId>quarkus-resteasy</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-direct</artifactId>
+ </dependency>
+ <!-- test dependencies -->
+ <dependency>
+ <groupId>io.quarkus</groupId>
+ <artifactId>quarkus-junit5</artifactId>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>io.rest-assured</groupId>
+ <artifactId>rest-assured</artifactId>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-integration-testcontainers-support</artifactId>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.awaitility</groupId>
+ <artifactId>awaitility</artifactId>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.testcontainers</groupId>
+ <artifactId>rabbitmq</artifactId>
+ <scope>test</scope>
+ </dependency>
+
+ <!-- The following dependencies guarantee that this module is built after them. You can update them by running `mvn process-resources -Pformat -N` from the source tree root directory -->
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-spring-rabbitmq-deployment</artifactId>
+ <version>${project.version}</version>
+ <type>pom</type>
+ <scope>test</scope>
+ <exclusions>
+ <exclusion>
+ <groupId>*</groupId>
+ <artifactId>*</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+ </dependencies>
+
+ <profiles>
+ <profile>
+ <id>native</id>
+ <activation>
+ <property>
+ <name>native</name>
+ </property>
+ </activation>
+ <properties>
+ <quarkus.package.type>native</quarkus.package.type>
+ </properties>
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-failsafe-plugin</artifactId>
+ <executions>
+ <execution>
+ <goals>
+ <goal>integration-test</goal>
+ <goal>verify</goal>
+ </goals>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
+ </profile>
+ </profiles>
+
+</project>
diff --git a/integration-tests/spring-rabbitmq/src/main/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqConnectionFactoryProducer.java b/integration-tests/spring-rabbitmq/src/main/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqConnectionFactoryProducer.java
new file mode 100644
index 0000000..c05468c
--- /dev/null
+++ b/integration-tests/spring-rabbitmq/src/main/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqConnectionFactoryProducer.java
@@ -0,0 +1,51 @@
+/*
+ * 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.quarkus.component.spring.rabbitmq.it;
+
+import javax.enterprise.context.ApplicationScoped;
+import javax.inject.Named;
+import javax.ws.rs.Produces;
+
+import org.eclipse.microprofile.config.inject.ConfigProperty;
+import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
+import org.springframework.amqp.rabbit.connection.ConnectionFactory;
+
+public class SpringRabbitmqConnectionFactoryProducer {
+
+ @ConfigProperty(name = SpringRabbitmqResource.PARAMETER_PORT)
+ Integer port;
+
+ @ConfigProperty(name = SpringRabbitmqResource.PARAMETER_HOSTNAME)
+ String hostname;
+
+ @ConfigProperty(name = SpringRabbitmqResource.PARAMETER_USERNAME)
+ String usernane;
+
+ @ConfigProperty(name = SpringRabbitmqResource.PARAMETER_PASSWORD)
+ String password;
+
+ @Produces
+ @ApplicationScoped
+ @Named("connectionFactory")
+ public ConnectionFactory produceConnectionFactory() {
+ CachingConnectionFactory cf = new CachingConnectionFactory();
+ cf.setUri(String.format("amqp://%s:%d", hostname, port));
+ cf.setUsername(usernane);
+ cf.setPassword(password);
+ return cf;
+ }
+}
diff --git a/integration-tests/spring-rabbitmq/src/main/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqResource.java b/integration-tests/spring-rabbitmq/src/main/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqResource.java
new file mode 100644
index 0000000..39d1607
--- /dev/null
+++ b/integration-tests/spring-rabbitmq/src/main/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqResource.java
@@ -0,0 +1,93 @@
+/*
+ * 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.quarkus.component.spring.rabbitmq.it;
+
+import java.util.concurrent.Executors;
+
+import javax.enterprise.context.ApplicationScoped;
+import javax.inject.Inject;
+import javax.ws.rs.Consumes;
+import javax.ws.rs.POST;
+import javax.ws.rs.Path;
+import javax.ws.rs.Produces;
+import javax.ws.rs.QueryParam;
+import javax.ws.rs.core.MediaType;
+
+import org.apache.camel.ConsumerTemplate;
+import org.apache.camel.ProducerTemplate;
+import org.jboss.logging.Logger;
+
+@Path("/spring-rabbitmq")
+@ApplicationScoped
+public class SpringRabbitmqResource {
+ private static final Logger LOG = Logger.getLogger(SpringRabbitmqResource.class);
+
+ public static final String PARAMETER_PORT = "camel.quarkus.spring-rabbitmq.test.port";
+ public static final String PARAMETER_HOSTNAME = "camel.quarkus.spring-rabbitmq.test.hostname";
+ public static final String PARAMETER_USERNAME = "camel.quarkus.spring-rabbitmq.test.username";
+ public static final String PARAMETER_PASSWORD = "camel.quarkus.spring-rabbitmq.test.password";
+
+ public static final String ROUTING_KEY_IN_OUT = "foo.bar";
+ public static final String EXCHANGE_IN_OUT = "inOut";
+
+ public static final String POLLING_QUEUE_NAME = "pollingQueue";
+
+ public static final String DIRECT_IN_OUT = "direct:inOut";
+ public static final String DIRECT_POLLING = "direct:polling";
+
+ public static final String QUERY_ROUTING_KEY = "routingKey";
+ public static final String QUERY_DIRECT = "fromDirect";
+ public static final String QUERY_EXCHANGE = "exchange";
+ public static final String QUERY_TIMEOUT = "timeout";
+
+ @Inject
+ ProducerTemplate producerTemplate;
+
+ @Inject
+ ConsumerTemplate consumerTemplate;
+
+ @Path("/getFromDirect")
+ @POST
+ @Produces(MediaType.TEXT_PLAIN)
+ public String getFromDirect(@QueryParam(QUERY_DIRECT) String directName, @QueryParam(QUERY_TIMEOUT) int timeout) {
+ final String message = timeout > 0 ? consumerTemplate.receiveBody(directName, timeout, String.class)
+ : consumerTemplate.receiveBodyNoWait(directName, String.class);
+ return message;
+ }
+
+ @Path("/send")
+ @POST
+ @Consumes(MediaType.TEXT_PLAIN)
+ public void send(String message, @QueryParam(QUERY_EXCHANGE) String exchange,
+ @QueryParam(QUERY_ROUTING_KEY) String routingKey) {
+ String url = String.format("spring-rabbitmq:" + exchange + "?routingKey=%s&autoDeclare=true", routingKey);
+ producerTemplate.sendBody(url, message);
+ }
+
+ @Path("/startPolling")
+ @POST
+ public void startPolling(@QueryParam(QUERY_EXCHANGE) String exchange,
+ @QueryParam(QUERY_ROUTING_KEY) String routingKey) {
+ // use another thread for polling consumer to demonstrate that we can wait before
+ // the message is sent to the queue
+ Executors.newSingleThreadExecutor().execute(() -> {
+ String url = String.format("spring-rabbitmq:%s?queues=%s&routingKey=%s", exchange, POLLING_QUEUE_NAME, routingKey);
+ String body = consumerTemplate.receiveBody(url, String.class);
+ producerTemplate.sendBody(DIRECT_POLLING, "Polling Hello " + body);
+ });
+ }
+}
diff --git a/integration-tests/spring-rabbitmq/src/main/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqRouteBuilder.java b/integration-tests/spring-rabbitmq/src/main/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqRouteBuilder.java
new file mode 100644
index 0000000..442c313
--- /dev/null
+++ b/integration-tests/spring-rabbitmq/src/main/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqRouteBuilder.java
@@ -0,0 +1,37 @@
+/*
+ * 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.quarkus.component.spring.rabbitmq.it;
+
+import javax.enterprise.context.ApplicationScoped;
+
+import org.apache.camel.builder.RouteBuilder;
+
+@ApplicationScoped
+public class SpringRabbitmqRouteBuilder extends RouteBuilder {
+
+ @Override
+ public void configure() throws Exception {
+ String url = String.format(
+ "spring-rabbitmq:%s?queues=myqueue&routingKey=%s&connectionFactory=#connectionFactory&autoDeclare=true",
+ SpringRabbitmqResource.EXCHANGE_IN_OUT, SpringRabbitmqResource.ROUTING_KEY_IN_OUT);
+
+ from(url)
+ .transform(body().prepend("Hello "))
+ .to(SpringRabbitmqResource.DIRECT_IN_OUT);
+ }
+}
diff --git a/integration-tests/spring-rabbitmq/src/test/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqIT.java b/integration-tests/spring-rabbitmq/src/test/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqIT.java
new file mode 100644
index 0000000..52812e3
--- /dev/null
+++ b/integration-tests/spring-rabbitmq/src/test/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqIT.java
@@ -0,0 +1,24 @@
+/*
+ * 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.quarkus.component.spring.rabbitmq.it;
+
+import io.quarkus.test.junit.NativeImageTest;
+
+@NativeImageTest
+class SpringRabbitmqIT extends SpringRabbitmqTest {
+
+}
diff --git a/integration-tests/spring-rabbitmq/src/test/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqTest.java b/integration-tests/spring-rabbitmq/src/test/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqTest.java
new file mode 100644
index 0000000..255bef8
--- /dev/null
+++ b/integration-tests/spring-rabbitmq/src/test/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqTest.java
@@ -0,0 +1,112 @@
+/*
+ * 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.quarkus.component.spring.rabbitmq.it;
+
+import io.quarkus.test.common.QuarkusTestResource;
+import io.quarkus.test.junit.QuarkusTest;
+import io.restassured.RestAssured;
+import io.restassured.response.Response;
+import org.junit.jupiter.api.Test;
+import org.springframework.amqp.core.AmqpAdmin;
+import org.springframework.amqp.core.BindingBuilder;
+import org.springframework.amqp.core.DirectExchange;
+import org.springframework.amqp.core.Queue;
+import org.springframework.amqp.rabbit.connection.ConnectionFactory;
+import org.springframework.amqp.rabbit.core.RabbitAdmin;
+
+import static org.hamcrest.Matchers.is;
+
+@QuarkusTest
+@QuarkusTestResource(SpringRabbitmqTestResource.class)
+class SpringRabbitmqTest {
+
+ private final static String EXCHANGE_POLLING = "polling";
+ private final static String ROUTING_KEY_POLLING = "pollingKey";
+ private ConnectionFactory connectionFactory;
+
+ @Test
+ public void testInOut() {
+ //direct has to be empty
+ getFromDirect(SpringRabbitmqResource.DIRECT_IN_OUT)
+ .then()
+ .statusCode(204);
+
+ sendToExchange(SpringRabbitmqResource.EXCHANGE_IN_OUT, SpringRabbitmqResource.ROUTING_KEY_IN_OUT, "Sheldon");
+
+ getFromDirect(SpringRabbitmqResource.DIRECT_IN_OUT)
+ .then()
+ .statusCode(200)
+ .body(is("Hello Sheldon"));
+
+ }
+
+ @Test
+ public void testPolling() throws InterruptedException {
+
+ bindQueue(SpringRabbitmqResource.POLLING_QUEUE_NAME, EXCHANGE_POLLING, ROUTING_KEY_POLLING);
+
+ //start thread with the poling consumer from exchange "polling", polling queue, routing "pollingKey", result is sent to polling direct
+ RestAssured.given()
+ .queryParam(SpringRabbitmqResource.QUERY_EXCHANGE, EXCHANGE_POLLING)
+ .queryParam(SpringRabbitmqResource.QUERY_ROUTING_KEY, ROUTING_KEY_POLLING)
+ .post("/spring-rabbitmq/startPolling");
+
+ // wait a little to demonstrate we can start poll before we have a msg on the queue
+ Thread.sleep(500);
+
+ sendToExchange(EXCHANGE_POLLING, ROUTING_KEY_POLLING, "Sheldon");
+
+ //get result from direct (for pooling) with timeout
+ getFromDirect(SpringRabbitmqResource.DIRECT_POLLING, 1000)
+ .then()
+ .statusCode(200)
+ .body(is("Polling Hello Sheldon"));
+
+ }
+
+ private void sendToExchange(String exchange, String routingKey, String body) {
+ RestAssured.given()
+ .queryParam(SpringRabbitmqResource.QUERY_EXCHANGE, exchange)
+ .queryParam(SpringRabbitmqResource.QUERY_ROUTING_KEY, routingKey)
+ .body(body)
+ .post("/spring-rabbitmq/send");
+ }
+
+ private Response getFromDirect(String direct) {
+ return getFromDirect(direct, 0);
+ }
+
+ private Response getFromDirect(String direct, int timeout) {
+ return RestAssured.given()
+ .queryParam(SpringRabbitmqResource.QUERY_DIRECT, direct)
+ .queryParam(SpringRabbitmqResource.QUERY_TIMEOUT, timeout)
+ .post("/spring-rabbitmq/getFromDirect");
+ }
+
+ private void bindQueue(String queue, String exchange, String routingKey) {
+ Queue q = new Queue(queue, false);
+ DirectExchange t = new DirectExchange(exchange);
+ AmqpAdmin admin = new RabbitAdmin(connectionFactory);
+ admin.declareQueue(q);
+ admin.declareExchange(t);
+ admin.declareBinding(BindingBuilder.bind(q).to(t).with(routingKey));
+ }
+
+ public void setConnectionFactory(ConnectionFactory connectionFactory) {
+ this.connectionFactory = connectionFactory;
+ }
+}
diff --git a/integration-tests/spring-rabbitmq/src/test/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqTestResource.java b/integration-tests/spring-rabbitmq/src/test/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqTestResource.java
new file mode 100644
index 0000000..95d7622
--- /dev/null
+++ b/integration-tests/spring-rabbitmq/src/test/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqTestResource.java
@@ -0,0 +1,78 @@
+/*
+ * 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.quarkus.component.spring.rabbitmq.it;
+
+import java.util.Map;
+
+import io.quarkus.test.common.QuarkusTestResourceLifecycleManager;
+import org.apache.camel.util.CollectionHelper;
+import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
+import org.testcontainers.containers.RabbitMQContainer;
+import org.testcontainers.containers.wait.strategy.Wait;
+
+public class SpringRabbitmqTestResource implements QuarkusTestResourceLifecycleManager {
+
+ private static final String RABBITMQ_IMAGE = "rabbitmq:3.7.25-management-alpine";
+ private static final int RABBITMQ_PORT = 5672;
+ private static final String RABBITMQ_USERNAME = "guest";
+ private static final String RABBITMQ_PASSWORD = "guest";
+
+ private RabbitMQContainer container;
+
+ @Override
+ public Map<String, String> start() {
+
+ try {
+ container = new RabbitMQContainer(RABBITMQ_IMAGE)
+ .withExposedPorts(RABBITMQ_PORT)
+ .waitingFor(Wait.forListeningPort());
+ container.start();
+
+ return CollectionHelper.mapOf(
+ SpringRabbitmqResource.PARAMETER_PORT, container.getMappedPort(RABBITMQ_PORT).toString(),
+ SpringRabbitmqResource.PARAMETER_HOSTNAME, container.getHost(),
+ SpringRabbitmqResource.PARAMETER_USERNAME, RABBITMQ_USERNAME,
+ SpringRabbitmqResource.PARAMETER_PASSWORD, RABBITMQ_PASSWORD);
+ } catch (Exception e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ public void inject(Object testInstance) {
+ if (testInstance instanceof SpringRabbitmqTest) {
+ SpringRabbitmqTest test = (SpringRabbitmqTest) testInstance;
+
+ CachingConnectionFactory cf = new CachingConnectionFactory();
+ cf.setUri(String.format("amqp://%s:%d", container.getHost(), container.getMappedPort(RABBITMQ_PORT)));
+ cf.setUsername(RABBITMQ_USERNAME);
+ cf.setPassword(RABBITMQ_PASSWORD);
+
+ test.setConnectionFactory(cf);
+ }
+ }
+
+ @Override
+ public void stop() {
+ try {
+ if (container != null) {
+ container.stop();
+ }
+ } catch (Exception e) {
+ // Ignored
+ }
+ }
+}
diff --git a/poms/bom/pom.xml b/poms/bom/pom.xml
index 4e58f9a..6d3df20 100644
--- a/poms/bom/pom.xml
+++ b/poms/bom/pom.xml
@@ -1882,6 +1882,11 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
+ <artifactId>camel-spring-rabbitmq</artifactId>
+ <version>${camel.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
<artifactId>camel-sql</artifactId>
<version>${camel.version}</version>
<exclusions>
@@ -4793,6 +4798,16 @@
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-spring-rabbitmq</artifactId>
+ <version>${camel-quarkus.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
+ <artifactId>camel-quarkus-spring-rabbitmq-deployment</artifactId>
+ <version>${camel-quarkus.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel.quarkus</groupId>
<artifactId>camel-quarkus-sql</artifactId>
<version>${camel-quarkus.version}</version>
</dependency>
diff --git a/tooling/scripts/test-categories.yaml b/tooling/scripts/test-categories.yaml
index e11f229..579b2e4 100644
--- a/tooling/scripts/test-categories.yaml
+++ b/tooling/scripts/test-categories.yaml
@@ -121,6 +121,7 @@ messaging-networking1:
- kafka
- messaging
- nats
+ - spring-rabbitmq
- rabbitmq
- ftp
- graphql
[camel-quarkus] 02/02: Deprecation changes caused by upgrade to the
Camel 3.8.
Posted by ja...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 3edfdc948a6a7e9083ff1514a3fb21926dbd040d
Author: JiriOndrusek <on...@gmail.com>
AuthorDate: Thu Feb 11 11:12:47 2021 +0100
Deprecation changes caused by upgrade to the Camel 3.8.
---
.../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 1 +
.../aws-ec2/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 1 +
.../aws-ecs/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 1 +
.../aws-eks/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 1 +
.../aws-iam/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 1 +
.../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 1 +
.../aws-kms/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 1 +
.../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 1 +
.../aws-s3/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 1 +
.../aws-sdb/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 1 +
.../aws-sns/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 1 +
.../aws-sqs/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 1 +
.../aws-swf/runtime/src/main/resources/META-INF/quarkus-extension.yaml | 1 +
.../runtime/src/main/resources/META-INF/quarkus-extension.yaml | 1 +
14 files changed, 14 insertions(+)
diff --git a/extensions-core/caffeine-lrucache/runtime/src/main/resources/META-INF/quarkus-extension.yaml b/extensions-core/caffeine-lrucache/runtime/src/main/resources/META-INF/quarkus-extension.yaml
index d17563b..50a3f40 100644
--- a/extensions-core/caffeine-lrucache/runtime/src/main/resources/META-INF/quarkus-extension.yaml
+++ b/extensions-core/caffeine-lrucache/runtime/src/main/resources/META-INF/quarkus-extension.yaml
@@ -29,3 +29,4 @@ metadata:
- "integration"
status:
- "stable"
+ - "deprecated"
\ No newline at end of file
diff --git a/extensions/aws-ec2/runtime/src/main/resources/META-INF/quarkus-extension.yaml b/extensions/aws-ec2/runtime/src/main/resources/META-INF/quarkus-extension.yaml
index 72d3a91..8d6ff70 100644
--- a/extensions/aws-ec2/runtime/src/main/resources/META-INF/quarkus-extension.yaml
+++ b/extensions/aws-ec2/runtime/src/main/resources/META-INF/quarkus-extension.yaml
@@ -31,3 +31,4 @@ metadata:
- "integration"
status:
- "stable"
+ - "deprecated"
\ No newline at end of file
diff --git a/extensions/aws-ecs/runtime/src/main/resources/META-INF/quarkus-extension.yaml b/extensions/aws-ecs/runtime/src/main/resources/META-INF/quarkus-extension.yaml
index 81b0b15..efe8c42 100644
--- a/extensions/aws-ecs/runtime/src/main/resources/META-INF/quarkus-extension.yaml
+++ b/extensions/aws-ecs/runtime/src/main/resources/META-INF/quarkus-extension.yaml
@@ -31,3 +31,4 @@ metadata:
- "integration"
status:
- "stable"
+ - "deprecated"
\ No newline at end of file
diff --git a/extensions/aws-eks/runtime/src/main/resources/META-INF/quarkus-extension.yaml b/extensions/aws-eks/runtime/src/main/resources/META-INF/quarkus-extension.yaml
index d14fec3..7a1aef5 100644
--- a/extensions/aws-eks/runtime/src/main/resources/META-INF/quarkus-extension.yaml
+++ b/extensions/aws-eks/runtime/src/main/resources/META-INF/quarkus-extension.yaml
@@ -31,3 +31,4 @@ metadata:
- "integration"
status:
- "stable"
+ - "deprecated"
\ No newline at end of file
diff --git a/extensions/aws-iam/runtime/src/main/resources/META-INF/quarkus-extension.yaml b/extensions/aws-iam/runtime/src/main/resources/META-INF/quarkus-extension.yaml
index b3edeab..5f180aa 100644
--- a/extensions/aws-iam/runtime/src/main/resources/META-INF/quarkus-extension.yaml
+++ b/extensions/aws-iam/runtime/src/main/resources/META-INF/quarkus-extension.yaml
@@ -31,3 +31,4 @@ metadata:
- "integration"
status:
- "stable"
+ - "deprecated"
\ No newline at end of file
diff --git a/extensions/aws-kinesis/runtime/src/main/resources/META-INF/quarkus-extension.yaml b/extensions/aws-kinesis/runtime/src/main/resources/META-INF/quarkus-extension.yaml
index c7a5146..a27655e 100644
--- a/extensions/aws-kinesis/runtime/src/main/resources/META-INF/quarkus-extension.yaml
+++ b/extensions/aws-kinesis/runtime/src/main/resources/META-INF/quarkus-extension.yaml
@@ -31,3 +31,4 @@ metadata:
- "integration"
status:
- "stable"
+ - "deprecated"
\ No newline at end of file
diff --git a/extensions/aws-kms/runtime/src/main/resources/META-INF/quarkus-extension.yaml b/extensions/aws-kms/runtime/src/main/resources/META-INF/quarkus-extension.yaml
index 1dfe40e..4d1e979 100644
--- a/extensions/aws-kms/runtime/src/main/resources/META-INF/quarkus-extension.yaml
+++ b/extensions/aws-kms/runtime/src/main/resources/META-INF/quarkus-extension.yaml
@@ -31,3 +31,4 @@ metadata:
- "integration"
status:
- "stable"
+ - "deprecated"
\ No newline at end of file
diff --git a/extensions/aws-lambda/runtime/src/main/resources/META-INF/quarkus-extension.yaml b/extensions/aws-lambda/runtime/src/main/resources/META-INF/quarkus-extension.yaml
index 764c8ce..c9af2c3 100644
--- a/extensions/aws-lambda/runtime/src/main/resources/META-INF/quarkus-extension.yaml
+++ b/extensions/aws-lambda/runtime/src/main/resources/META-INF/quarkus-extension.yaml
@@ -31,3 +31,4 @@ metadata:
- "integration"
status:
- "stable"
+ - "deprecated"
\ No newline at end of file
diff --git a/extensions/aws-s3/runtime/src/main/resources/META-INF/quarkus-extension.yaml b/extensions/aws-s3/runtime/src/main/resources/META-INF/quarkus-extension.yaml
index 0f0a4a6..11b6b70 100644
--- a/extensions/aws-s3/runtime/src/main/resources/META-INF/quarkus-extension.yaml
+++ b/extensions/aws-s3/runtime/src/main/resources/META-INF/quarkus-extension.yaml
@@ -31,3 +31,4 @@ metadata:
- "integration"
status:
- "stable"
+ - "deprecated"
\ No newline at end of file
diff --git a/extensions/aws-sdb/runtime/src/main/resources/META-INF/quarkus-extension.yaml b/extensions/aws-sdb/runtime/src/main/resources/META-INF/quarkus-extension.yaml
index 7d6b2a5..c2b2304 100644
--- a/extensions/aws-sdb/runtime/src/main/resources/META-INF/quarkus-extension.yaml
+++ b/extensions/aws-sdb/runtime/src/main/resources/META-INF/quarkus-extension.yaml
@@ -31,3 +31,4 @@ metadata:
- "integration"
status:
- "stable"
+ - "deprecated"
\ No newline at end of file
diff --git a/extensions/aws-sns/runtime/src/main/resources/META-INF/quarkus-extension.yaml b/extensions/aws-sns/runtime/src/main/resources/META-INF/quarkus-extension.yaml
index c06e08e..1f34db3 100644
--- a/extensions/aws-sns/runtime/src/main/resources/META-INF/quarkus-extension.yaml
+++ b/extensions/aws-sns/runtime/src/main/resources/META-INF/quarkus-extension.yaml
@@ -31,3 +31,4 @@ metadata:
- "integration"
status:
- "stable"
+ - "deprecated"
\ No newline at end of file
diff --git a/extensions/aws-sqs/runtime/src/main/resources/META-INF/quarkus-extension.yaml b/extensions/aws-sqs/runtime/src/main/resources/META-INF/quarkus-extension.yaml
index b391165..b808f7f 100644
--- a/extensions/aws-sqs/runtime/src/main/resources/META-INF/quarkus-extension.yaml
+++ b/extensions/aws-sqs/runtime/src/main/resources/META-INF/quarkus-extension.yaml
@@ -31,3 +31,4 @@ metadata:
- "integration"
status:
- "stable"
+ - "deprecated"
\ No newline at end of file
diff --git a/extensions/aws-swf/runtime/src/main/resources/META-INF/quarkus-extension.yaml b/extensions/aws-swf/runtime/src/main/resources/META-INF/quarkus-extension.yaml
index 1ffe8cb..475805b 100644
--- a/extensions/aws-swf/runtime/src/main/resources/META-INF/quarkus-extension.yaml
+++ b/extensions/aws-swf/runtime/src/main/resources/META-INF/quarkus-extension.yaml
@@ -31,3 +31,4 @@ metadata:
- "integration"
status:
- "stable"
+ - "deprecated"
\ No newline at end of file
diff --git a/extensions/aws-translate/runtime/src/main/resources/META-INF/quarkus-extension.yaml b/extensions/aws-translate/runtime/src/main/resources/META-INF/quarkus-extension.yaml
index 929eea5..4c15722 100644
--- a/extensions/aws-translate/runtime/src/main/resources/META-INF/quarkus-extension.yaml
+++ b/extensions/aws-translate/runtime/src/main/resources/META-INF/quarkus-extension.yaml
@@ -31,3 +31,4 @@ metadata:
- "integration"
status:
- "stable"
+ - "deprecated"
\ No newline at end of file