为了能够和其它的jms providers 进行交换,activemq提供了消息桥的功能。只需要配置jmsBridgeConnectors就可以实现它与其它jms providers,如websphere mq的双向通信。
在两个服务器上分别运行activemq和websphere mq的服务器端,这两个MOM直接通过网络进行双向通信。
经过验证,在网络畅通的情况下,二者之间可以相互转发消息。但如果出现网络异常,如网络断掉的情况,activemq不能将消息转发到websphere mq,它也不会将这些消息持久化(即使配置了持久化消息),那将意味着在网络断掉期间,所有的消息不能成功的用activemq转发到websphere mq,可怕的是这些消息不会持久化,而是会被丢失。最后,只好通过使用activemq的其它特征解决这一问题。
1、 JBoss被Red Hat收购后,发布了Jboss Messaging作为缺省的
JMS
提供者来代替Jboss
MQ
,但是目前Jboss Messaging已经处于bug修复模式,由HornetQ完全支持
JMS
。
2、 IBM
WebSphere
MQ
IBM
WebSphere
MQ
是IBM业务集成的基础性产品,也是十几年以来
消息
中
间
件市场的主要领军产品之一。
WebSphere
MQ
作
http://websystique.com/spring/spring-4-
jms
-
activemq
-example-with-
jms
listener-enable
jms
/
转载于:https://www.cnblogs.com/zhangshitong/p/7906468.html
使用目的:将本地产生的
消息
转发到远程,通过远程服务器来处理
消息
,处理完成后,再启动消费者处理本地服务器
消息
(验证
消息
是否被转走,本地无
消息
可处理为正常)
消息
在下面的地址被消费,无需任何特别配置,采用默认的配置即可。
114.113.145.63:61616
生产
消息
地址为localhost:7001,需要做如下配置。
<bean id="bridgedBroker" class="...
@
Jms
Listener(destination = "mytest.queue")
@SendTo("out.queue")
public String receiveQueue(String text){
System.out.println(text);
return "
消息
已收到,over";
@
Jms
Listener(destination = "out.queue")
public void consumerMessage(String message){
activemq
网络
桥接
在此博客中,我们将看到双工网络连接器如何工作。
在上一部分中,我们从broker-1和broker-2创建了一个网络连接器。 我们能够看到,当代理2上有一个使用者使用队列“ foo.bar”时,代理1上的队列“ foo.bar”的
消息
如何转发到代理2上的队列“ foo.bar”。
让我们尝试通过将
消息
生成到broker-2的队列foo.bar中并从broker...
ActiveMQ
基础
ActiveMQ
实现
了
JMS
1.1并提供了很多附加的特性,比如JMX管理、主从管理、
消息
组通信、
消息
优先级、延迟接收
消息
、虚拟接收者、
消息
持久化、
消息
队列监控等。
ActiveMQ
主要特性
支持Java、C、C++、C#、Ruby、Perl、Python、PHP等多种语言的客户端和协议,如OpenWire、STOMP、A
MQ
P、
MQ
TT协议。
提供了像
消息
组通信、
消息
优先级、延迟接收
消息
、虚拟接收者、
消息
持久化之类的高级特性。
完全支持
JMS
1.1和J2EE1.4规范(包括持久化、分