You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jb...@apache.org on 2025/07/18 05:00:23 UTC
(activemq-artemis-examples) 01/03: ARTEMIS-5489 Add a basic AMQP bridge example for broker connections
This is an automated email from the ASF dual-hosted git repository.
jbertram pushed a commit to branch development
in repository https://gitbox.apache.org/repos/asf/activemq-artemis-examples.git
commit ed96db037603f8ffbcaad954e3d7ad26540b9d1a
Author: Timothy Bish <ta...@gmail.com>
AuthorDate: Tue May 20 16:10:48 2025 -0400
ARTEMIS-5489 Add a basic AMQP bridge example for broker connections
Adds an example that shows bridging from and to on a single broker connection.
---
.../features/broker-connection/amqp-bridge/pom.xml | 158 +++++++++++++++++++++
.../broker-connection/amqp-bridge/readme.md | 7 +
.../artemis/jms/example/BrokerBridgeExample.java | 79 +++++++++++
.../src/main/resources/activemq/server0/broker.xml | 123 ++++++++++++++++
.../src/main/resources/activemq/server1/broker.xml | 106 ++++++++++++++
examples/features/broker-connection/pom.xml | 2 +
scripts/run-examples.sh | 1 +
7 files changed, 476 insertions(+)
diff --git a/examples/features/broker-connection/amqp-bridge/pom.xml b/examples/features/broker-connection/amqp-bridge/pom.xml
new file mode 100644
index 00000000..56d783c1
--- /dev/null
+++ b/examples/features/broker-connection/amqp-bridge/pom.xml
@@ -0,0 +1,158 @@
+<?xml version='1.0'?>
+<!--
+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/maven-v4_0_0.xsd">
+ <modelVersion>4.0.0</modelVersion>
+
+ <parent>
+ <groupId>org.apache.activemq.examples.broker-connection</groupId>
+ <artifactId>broker-connections</artifactId>
+ <version>2.42.0-SNAPSHOT</version>
+ </parent>
+
+ <artifactId>amqp-bridge</artifactId>
+ <packaging>jar</packaging>
+ <name>amqp-bridge</name>
+
+ <properties>
+ <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
+ </properties>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.qpid</groupId>
+ <artifactId>qpid-jms-client</artifactId>
+ </dependency>
+ </dependencies>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>artemis-maven-plugin</artifactId>
+ <executions>
+ <execution>
+ <id>create0</id>
+ <goals>
+ <goal>create</goal>
+ </goals>
+ <configuration>
+ <ignore>${noServer}</ignore>
+ <instance>${basedir}/target/server0</instance>
+ <allowAnonymous>true</allowAnonymous>
+ <configuration>${basedir}/target/classes/activemq/server0</configuration>
+ <!-- this makes it easier in certain envs -->
+ <javaOptions>-Djava.net.preferIPv4Stack=true</javaOptions>
+ </configuration>
+ </execution>
+ <execution>
+ <id>create1</id>
+ <goals>
+ <goal>create</goal>
+ </goals>
+ <configuration>
+ <ignore>${noServer}</ignore>
+ <instance>${basedir}/target/server1</instance>
+ <allowAnonymous>true</allowAnonymous>
+ <configuration>${basedir}/target/classes/activemq/server1</configuration>
+ <!-- this makes it easier in certain envs -->
+ <javaOptions>-Djava.net.preferIPv4Stack=true</javaOptions>
+ </configuration>
+ </execution>
+ <!-- we first start broker 1, to avoid reconnecting statements -->
+ <execution>
+ <id>start1</id>
+ <goals>
+ <goal>cli</goal>
+ </goals>
+ <configuration>
+ <ignore>${noServer}</ignore>
+ <spawn>true</spawn>
+ <location>${basedir}/target/server1</location>
+ <testURI>tcp://localhost:5771</testURI>
+ <args>
+ <param>run</param>
+ </args>
+ <name>server1</name>
+ </configuration>
+ </execution>
+ <execution>
+ <id>start0</id>
+ <goals>
+ <goal>cli</goal>
+ </goals>
+ <configuration>
+ <spawn>true</spawn>
+ <ignore>${noServer}</ignore>
+ <location>${basedir}/target/server0</location>
+ <testURI>tcp://localhost:5660</testURI>
+ <args>
+ <param>run</param>
+ </args>
+ <name>server0</name>
+ </configuration>
+ </execution>
+ <execution>
+ <id>runClient</id>
+ <goals>
+ <goal>runClient</goal>
+ </goals>
+ <configuration>
+ <!-- you may have to set export MAVEN_OPTS="-Djava.net.preferIPv4Stack=true"
+ if you are on MacOS for instance -->
+ <clientClass>org.apache.activemq.artemis.jms.example.BrokerBridgeExample</clientClass>
+ </configuration>
+ </execution>
+ <execution>
+ <id>stop0</id>
+ <goals>
+ <goal>stop</goal>
+ </goals>
+ <configuration>
+ <ignore>${noServer}</ignore>
+ <location>${basedir}/target/server0</location>
+ </configuration>
+ </execution>
+ <execution>
+ <id>stop1</id>
+ <goals>
+ <goal>stop</goal>
+ </goals>
+ <configuration>
+ <ignore>${noServer}</ignore>
+ <location>${basedir}/target/server1</location>
+ </configuration>
+ </execution>
+ </executions>
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.activemq.examples.broker-connection</groupId>
+ <artifactId>amqp-bridge</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
+ </plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-clean-plugin</artifactId>
+ </plugin>
+ </plugins>
+ </build>
+</project>
diff --git a/examples/features/broker-connection/amqp-bridge/readme.md b/examples/features/broker-connection/amqp-bridge/readme.md
new file mode 100644
index 00000000..7adb38c9
--- /dev/null
+++ b/examples/features/broker-connection/amqp-bridge/readme.md
@@ -0,0 +1,7 @@
+# AMQP Broker Connection with bridge from and bridge to configurations
+
+If you have not already done so, [prepare the broker distribution](../../../../README.md#getting-started) before running the example.
+
+To run the example, simply type **mvn verify** from this directory, or **mvn -PnoServer verify** if you want to create and start the broker manually.
+
+This example demonstrates how you can bridge messages sent to an Address on a remote server back to the local server and also instruct the local server to bridge messages sent to a Queue on the local server to a queue on the remote broker over single AMQP connection.
diff --git a/examples/features/broker-connection/amqp-bridge/src/main/java/org/apache/activemq/artemis/jms/example/BrokerBridgeExample.java b/examples/features/broker-connection/amqp-bridge/src/main/java/org/apache/activemq/artemis/jms/example/BrokerBridgeExample.java
new file mode 100644
index 00000000..fae3b41e
--- /dev/null
+++ b/examples/features/broker-connection/amqp-bridge/src/main/java/org/apache/activemq/artemis/jms/example/BrokerBridgeExample.java
@@ -0,0 +1,79 @@
+/*
+ * 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.activemq.artemis.jms.example;
+
+import javax.jms.Connection;
+import javax.jms.ConnectionFactory;
+import javax.jms.MessageConsumer;
+import javax.jms.MessageProducer;
+import javax.jms.Queue;
+import javax.jms.Session;
+import javax.jms.TextMessage;
+import javax.jms.Topic;
+
+import org.apache.qpid.jms.JmsConnectionFactory;
+
+/**
+ * This example is demonstrating how messages are bridge between two brokers with the
+ * bridge configuration located on only one broker (server0) and only a single outbound
+ * connection is configured from server0 to server1
+ */
+public class BrokerBridgeExample {
+
+ public static void main(final String[] args) throws Exception {
+ final ConnectionFactory connectionFactoryServer0 = new JmsConnectionFactory("amqp://localhost:5660");
+ final ConnectionFactory connectionFactoryServer1 = new JmsConnectionFactory("amqp://localhost:5771");
+
+ final Connection connectionOnServer0 = connectionFactoryServer0.createConnection();
+ final Connection connectionOnServer1 = connectionFactoryServer1.createConnection();
+
+ connectionOnServer0.start();
+ connectionOnServer1.start();
+
+ final Session sessionOnServer0 = connectionOnServer0.createSession(Session.AUTO_ACKNOWLEDGE);
+ final Session sessionOnServer1 = connectionOnServer1.createSession(Session.AUTO_ACKNOWLEDGE);
+
+ final Topic ordersTopic = sessionOnServer0.createTopic("orders");
+ final Queue trackingQueue = sessionOnServer1.createQueue("tracking");
+
+ // Create consumers which generate demand on tracked resources and create bridge links
+ final MessageConsumer ordersConsumerOn0 = sessionOnServer0.createConsumer(ordersTopic);
+ final MessageConsumer trackingConsumerOn1 = sessionOnServer1.createConsumer(trackingQueue);
+
+ // Bridge from server0 to server1 on the tracking queue
+ final MessageProducer trackingProducerOn0 = sessionOnServer0.createProducer(trackingQueue);
+
+ final TextMessage trackingMessageSent = sessionOnServer0.createTextMessage("new-tracking-data");
+
+ trackingProducerOn0.send(trackingMessageSent);
+
+ final TextMessage trackingMessageReceived = (TextMessage) trackingConsumerOn1.receive(5_000);
+
+ System.out.println("Consumer on server 1 received tracking data from producer on server 0 " + trackingMessageReceived.getText());
+
+ // Bridge from server1 back to server0 on the orders address
+ final MessageProducer ordersProducerOn1 = sessionOnServer1.createProducer(ordersTopic);
+
+ final TextMessage orderMessageSent = sessionOnServer1.createTextMessage("new-order");
+
+ ordersProducerOn1.send(orderMessageSent);
+
+ final TextMessage orderMessageReceived = (TextMessage) ordersConsumerOn0.receive(5_000);
+
+ System.out.println("Consumer on server 0 received order message from producer on server 1 " + orderMessageReceived.getText());
+ }
+}
diff --git a/examples/features/broker-connection/amqp-bridge/src/main/resources/activemq/server0/broker.xml b/examples/features/broker-connection/amqp-bridge/src/main/resources/activemq/server0/broker.xml
new file mode 100644
index 00000000..28f40fb2
--- /dev/null
+++ b/examples/features/broker-connection/amqp-bridge/src/main/resources/activemq/server0/broker.xml
@@ -0,0 +1,123 @@
+<?xml version='1.0'?>
+<!--
+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.
+-->
+
+<configuration xmlns="urn:activemq"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xmlns:xi="http://www.w3.org/2001/XInclude"
+ xsi:schemaLocation="urn:activemq /schema/artemis-configuration.xsd">
+
+ <core xmlns="urn:activemq:core" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="urn:activemq:core ">
+
+ <name>0.0.0.0</name>
+
+ <persistence-enabled>false</persistence-enabled>
+
+ <journal-type>NIO</journal-type>
+
+ <!-- should the broker detect dead locks and other issues -->
+ <critical-analyzer>true</critical-analyzer>
+
+ <critical-analyzer-timeout>120000</critical-analyzer-timeout>
+
+ <critical-analyzer-check-period>60000</critical-analyzer-check-period>
+
+ <critical-analyzer-policy>HALT</critical-analyzer-policy>
+
+ <page-sync-timeout>44000</page-sync-timeout>
+
+ <acceptors>
+ <!-- Acceptor for every supported protocol -->
+ <acceptor name="artemis">tcp://0.0.0.0:5660?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;amqpMinLargeMessageSize=102400;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE;useEpoll=true;amqpCredits=1000;amqpLowCredits=300;amqpDuplicateDetection=true</acceptor>
+ </acceptors>
+
+ <broker-connections>
+ <amqp-connection uri="tcp://localhost:5771" name="bridge-example" retry-interval="100">
+ <!-- This will create a bridge connection between servers, the local
+ server will bridge messages sent to the address 'orders' from the
+ remote and the local will bridge messages sent to the tracking queue
+ on the local broker to the matching queue on the remote. -->
+ <bridge name = "example-bridge-configuration">
+ <bridge-to-queue name="bridge-to-remote-queue">
+ <include address-match="#" queue-match="tracking" />
+ </bridge-to-queue>
+ <bridge-from-address name="bridge-from-remote-address">
+ <include address-match="orders" />
+ </bridge-from-address>
+ </bridge>
+ </amqp-connection>
+ </broker-connections>
+
+ <security-settings>
+ <security-setting match="#">
+ <permission type="createNonDurableQueue" roles="guest"/>
+ <permission type="deleteNonDurableQueue" roles="guest"/>
+ <permission type="createDurableQueue" roles="guest"/>
+ <permission type="deleteDurableQueue" roles="guest"/>
+ <permission type="createAddress" roles="guest"/>
+ <permission type="deleteAddress" roles="guest"/>
+ <permission type="consume" roles="guest"/>
+ <permission type="browse" roles="guest"/>
+ <permission type="send" roles="guest"/>
+ <permission type="manage" roles="guest"/>
+ </security-setting>
+ </security-settings>
+
+ <address-settings>
+ <!-- if you define auto-create on certain queues, management has to be auto-create -->
+ <address-setting match="activemq.management#">
+ <dead-letter-address>DLQ</dead-letter-address>
+ <expiry-address>ExpiryQueue</expiry-address>
+ <redelivery-delay>0</redelivery-delay>
+ <!-- with -1 only the global-max-size is in use for limiting -->
+ <max-size-bytes>-1</max-size-bytes>
+ <message-counter-history-day-limit>10</message-counter-history-day-limit>
+ <address-full-policy>PAGE</address-full-policy>
+ <auto-create-queues>true</auto-create-queues>
+ <auto-create-addresses>true</auto-create-addresses>
+ </address-setting>
+ <!--default for catch all-->
+ <address-setting match="#">
+ <dead-letter-address>DLQ</dead-letter-address>
+ <expiry-address>ExpiryQueue</expiry-address>
+ <redelivery-delay>0</redelivery-delay>
+ <!-- with -1 only the global-max-size is in use for limiting -->
+ <max-size-bytes>-1</max-size-bytes>
+ <message-counter-history-day-limit>10</message-counter-history-day-limit>
+ <address-full-policy>PAGE</address-full-policy>
+ <auto-create-queues>true</auto-create-queues>
+ <auto-create-addresses>true</auto-create-addresses>
+ </address-setting>
+ </address-settings>
+
+ <addresses>
+ <address name="orders">
+ <multicast>
+ </multicast>
+ </address>
+ <address name="tracking">
+ <anycast>
+ <queue name="tracking" />
+ </anycast>
+ </address>
+ </addresses>
+
+ </core>
+</configuration>
diff --git a/examples/features/broker-connection/amqp-bridge/src/main/resources/activemq/server1/broker.xml b/examples/features/broker-connection/amqp-bridge/src/main/resources/activemq/server1/broker.xml
new file mode 100644
index 00000000..1ce9e95c
--- /dev/null
+++ b/examples/features/broker-connection/amqp-bridge/src/main/resources/activemq/server1/broker.xml
@@ -0,0 +1,106 @@
+<?xml version='1.0'?>
+<!--
+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.
+-->
+
+<configuration xmlns="urn:activemq"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xmlns:xi="http://www.w3.org/2001/XInclude"
+ xsi:schemaLocation="urn:activemq /schema/artemis-configuration.xsd">
+
+ <core xmlns="urn:activemq:core" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="urn:activemq:core ">
+
+ <name>0.0.0.0</name>
+
+ <persistence-enabled>false</persistence-enabled>
+
+ <journal-type>NIO</journal-type>
+
+ <!-- should the broker detect dead locks and other issues -->
+ <critical-analyzer>true</critical-analyzer>
+
+ <critical-analyzer-timeout>120000</critical-analyzer-timeout>
+
+ <critical-analyzer-check-period>60000</critical-analyzer-check-period>
+
+ <critical-analyzer-policy>HALT</critical-analyzer-policy>
+
+ <page-sync-timeout>44000</page-sync-timeout>
+
+ <acceptors>
+ <!-- Acceptor for every supported protocol -->
+ <acceptor name="artemis">tcp://0.0.0.0:5771?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;amqpMinLargeMessageSize=102400;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE;useEpoll=true;amqpCredits=1000;amqpLowCredits=300;amqpDuplicateDetection=true</acceptor>
+ </acceptors>
+
+ <security-settings>
+ <security-setting match="#">
+ <permission type="createNonDurableQueue" roles="guest"/>
+ <permission type="deleteNonDurableQueue" roles="guest"/>
+ <permission type="createDurableQueue" roles="guest"/>
+ <permission type="deleteDurableQueue" roles="guest"/>
+ <permission type="createAddress" roles="guest"/>
+ <permission type="deleteAddress" roles="guest"/>
+ <permission type="consume" roles="guest"/>
+ <permission type="browse" roles="guest"/>
+ <permission type="send" roles="guest"/>
+ <permission type="manage" roles="guest"/>
+ </security-setting>
+ </security-settings>
+
+ <address-settings>
+ <!-- if you define auto-create on certain queues, management has to be auto-create -->
+ <address-setting match="activemq.management#">
+ <dead-letter-address>DLQ</dead-letter-address>
+ <expiry-address>ExpiryQueue</expiry-address>
+ <redelivery-delay>0</redelivery-delay>
+ <!-- with -1 only the global-max-size is in use for limiting -->
+ <max-size-bytes>-1</max-size-bytes>
+ <message-counter-history-day-limit>10</message-counter-history-day-limit>
+ <address-full-policy>PAGE</address-full-policy>
+ <auto-create-queues>true</auto-create-queues>
+ <auto-create-addresses>true</auto-create-addresses>
+ </address-setting>
+ <!--default for catch all-->
+ <address-setting match="#">
+ <dead-letter-address>DLQ</dead-letter-address>
+ <expiry-address>ExpiryQueue</expiry-address>
+ <redelivery-delay>0</redelivery-delay>
+ <!-- with -1 only the global-max-size is in use for limiting -->
+ <max-size-bytes>-1</max-size-bytes>
+ <message-counter-history-day-limit>10</message-counter-history-day-limit>
+ <address-full-policy>PAGE</address-full-policy>
+ <auto-create-queues>true</auto-create-queues>
+ <auto-create-addresses>true</auto-create-addresses>
+ </address-setting>
+ </address-settings>
+
+ <addresses>
+ <address name="orders">
+ <multicast>
+ </multicast>
+ </address>
+ <address name="tracking">
+ <anycast>
+ <queue name="tracking" />
+ </anycast>
+ </address>
+ </addresses>
+
+ </core>
+</configuration>
diff --git a/examples/features/broker-connection/pom.xml b/examples/features/broker-connection/pom.xml
index 6071f369..3bc2b277 100644
--- a/examples/features/broker-connection/pom.xml
+++ b/examples/features/broker-connection/pom.xml
@@ -60,6 +60,7 @@ under the License.
<module>amqp-federation-queue-priority</module>
<module>amqp-federation-queue-multiple-brokers</module>
<module>amqp-federation-queue-pull-messages</module>
+ <module>amqp-bridge</module>
<module>disaster-recovery</module>
</modules>
</profile>
@@ -79,6 +80,7 @@ under the License.
<module>amqp-federation-queue-priority</module>
<module>amqp-federation-queue-multiple-brokers</module>
<module>amqp-federation-queue-pull-messages</module>
+ <module>amqp-bridge</module>
<module>disaster-recovery</module>
</modules>
</profile>
diff --git a/scripts/run-examples.sh b/scripts/run-examples.sh
index fbbc573f..5491b5ed 100755
--- a/scripts/run-examples.sh
+++ b/scripts/run-examples.sh
@@ -183,4 +183,5 @@ cd amqp-federation-queue-dual-federation; mvn verify; cd ..
cd amqp-federation-queue-priority; mvn verify; cd ..
cd amqp-federation-queue-multiple-brokers; mvn verify; cd ..
cd amqp-federation-queue-pull-messages; mvn verify; cd ..
+cd amqp-bridge; mvn verify; cd ..
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@activemq.apache.org
For additional commands, e-mail: commits-help@activemq.apache.org
For further information, visit: https://activemq.apache.org/contact