标签:
ActiveMQ 按照通信方式划分:桥接转发和双向通信
1.桥接转发是将消息传递给另外一个ActiveMQ的Broker。
2.双向通信是用一个通道既可以收消息,也可以发消息。
这样推送给Broker1的消息会自动转发给Broker2中,Broker2不需要修改任何设置,只对Broker1做修改即可。
<bean id="bridgedBroker" class="org.apache.activemq.broker.BrokerService" init-method="start" destroy-method="stop"> <property name="brokerName" value = "bridgedBroker"/> <property name="persistent" value="false"/> <property name="transportConnectorURIs"> <list> <!--消息生产队列--> <value>tcp://localhost:61616</value> </list> </property> <property name="jmsBridgeConnectors"> <list> <bean class="org.apache.activemq.network.jms.JmsQueueConnector"> <property name="outboundQueueConnectionFactory"> <bean class="org.apache.activemq.ActiveMQConnectionFactory"> <!--消费者队列地址--> <property name="brokerURL" value="tcp://10.1.230.200:61616" /> </bean> </property> <property name="outboundQueueBridges"> <list> <bean class="org.apache.activemq.network.jms.OutboundQueueBridge"> <!--只转发该消息队列--> <constructor-arg value="messages.input"/> </bean> </list> </property> </bean> </list> </property> </bean> |
场景:
本机ActiveMQ启动后,创建后队列,然后点击 Send TO 发送10条消息到该队列。
第三方队列启动后默认空。
我们对第一个MQ发送消息后,应该通过我们配置好的地址,对消息进行转发。这样第二个MQ应该接到10条转发过来的消息。
版权声明:本文为博主原创文章,未经博主允许不得转载。
标签:
原文地址:http://my.oschina.net/u/1757031/blog/493547