`
highriver
  • 浏览: 71759 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Activemq收发消息的目的地不一致的问题。

    博客分类:
  • java
阅读更多
发送消息,在发送者的应用中定义了queue:
<amq:queue name="createQueue"
physicalName="org.apache.activemq.spring.Test.spring.embedded" />

<amq:queue name="saveQueue"
physicalName="org.apache.activemq.spring.Test.spring.embedded" />

在接收者的应用中也定义了:
<amq:queue name="createQueue"
physicalName="org.apache.activemq.spring.Test.spring.embedded" />

<amq:queue name="saveQueue"
physicalName="org.apache.activemq.spring.Test.spring.embedded" />

即使二个应用跑在一个jvm里,但它们的queue仍然是不同.即发送者发送消息到queue,接收者不一定能收到(测试是有时可能会收到)。最终解决不使用嵌入式的queue,而是在jms服务器上先建立createQueue,saveQueue,然后,将每个应用中的配置改为:
<amq:queue name="createQueue"
physicalName="createQueue" />

<amq:queue name="saveQueue"
physicalName="saveQueue" />
这样就能保证收发的目的地是一致的。
0
0
分享到:
评论
1 楼 pudong 2010-07-21  
路过。。。。

相关推荐

    activeMQ收发工具.rar

    3. **消息类型**:理解JMS提供的不同消息类型,如文本消息、对象消息、流消息和二进制消息,以及如何通过ActiveMQ收发工具发送和接收这些消息。 4. **队列与主题**:熟悉ActiveMQ中的队列(Queue)和主题(Topic)...

    ActiveMQ收发消息Demo

    在这个"ActiveMQ收发消息Demo"中,我们将深入探讨如何使用ActiveMQ进行消息的接收和发送。 首先,让我们了解ActiveMQ的基本概念。在JMS框架下,消息生产者(Producer)创建消息并将其发送到消息队列(Queue)或主题...

    go语言实现使用activemq 收发消息

    在本文中,我们将深入探讨如何使用Go语言实现与ActiveMQ的通信,主要关注消息的收发功能。ActiveMQ是Apache软件基金会开发的一款开源消息中间件,支持多种协议,包括我们这里提到的STOMP(Simple Text Oriented ...

    springboot集成activemq实现消息接收demo

    而ActiveMQ是Apache出品的一款开源消息中间件,它遵循JMS(Java Message Service)规范,用于处理应用程序之间的异步通信。本教程将详细介绍如何在Spring Boot项目中集成ActiveMQ,实现消息接收的Demo。 首先,我们...

    Spring 使用ActiveMQ 收发消息实例

    - 定义队列(Queue)或主题(Topic)作为消息的目的地。 ```xml &lt;bean id="myQueue" class="org.apache.activemq.command.ActiveMQQueue"&gt; ``` 4. **发送消息**: - 使用`JmsTemplate`发送消息到队列或主题。...

    ActiveMQ队列消息过期时间设置和自动清除解决方案.docx

    在使用 ActiveMQ 时,消息过期时间设置和自动清除是一个非常重要的问题。本文将介绍 ActiveMQ 队列消息过期时间设置和自动清除的解决方案。 一、消息过期时间设置 在 ActiveMQ 中,可以通过设置时间戳插件来实现...

    ActiveMQ 使用Ajax 收发消息实战

    标题中的"ActiveMQ 使用Ajax 收发消息实战"指出我们将探讨如何使用ActiveMQ消息中间件与Ajax技术结合,实现Web应用程序中的异步消息传递。ActiveMQ是Apache软件基金会的一个项目,提供了一个开源的消息代理,支持...

    ActiveMQ实现的消息收发案例

    通过以上步骤,我们可以实现一个简单的ActiveMQ消息收发案例。这个案例对于理解消息队列的工作原理和实践JMS编程非常有帮助。在实际应用中,ActiveMQ还支持许多高级特性,如持久化、事务、消息优先级、消息筛选等,...

    activeMQ三种收发消息方式

    在这个小例子中,我们将探讨ActiveMQ的三种主要的消息收发方式:点对点、发布/订阅和事务处理模式。 1. **点对点(Point-to-Point)模式**: 在点对点模式下,消息从一个生产者发送到一个队列,然后由一个或多个...

    activeMQ发送消息返回消息

    6. **发送消息**:使用Producer和创建好的Message,我们可以调用Producer的send方法将消息发送到目的地,如Queue或Topic。 7. **接收消息**:创建MessageConsumer,它可以从Queue或Topic接收消息。你可以设置监听器...

    ActiveMQ结合Spring收发消息的示例代码

    在本文中,我们将深入探讨如何将ActiveMQ与Spring框架整合,以便更高效、便捷地实现消息的收发。首先,ActiveMQ是Apache软件基金会开发的一个开源消息中间件,它支持多种消息协议,如JMS(Java消息服务),并提供...

    ActiveMQ消息过期时间设置和自动清除解决方案

    - [CSDN问答 - ActiveMQ消息过期问题](http://ask.csdn.net/questions/376817) - [ActiveMQ官方文档 - 消息重试和DLQ处理](http://activemq.apache.org/message-redelivery-and-dlq-handling.html) #### 6. 当前...

    用C#实现的ActiveMQ发布/订阅消息传送

    4. `Producer`: 负责创建并发送消息到目的地(主题或队列)。使用`Session.CreateProducer()`方法创建。 5. `Consumer`: 用于接收消息。通过`Session.CreateConsumer()`方法创建。 6. `TextMessage`: 一种消息类型,...

    一个jms activemq Topic 消息实例

    一个jms activemq Topic 消息实例 关于jms JMS 是接口,相当于jdbc ,要真正使用它需要某些厂商进行实现 ,即jms provider 常见的jms provider 有 ActiveMQ JBoss 社区所研发的 HornetQ (在jboss6 中默认即可以...

    7道消息队列ActiveMQ面试题!

    为了实现更均匀的消息消费,可以将prefetch的值设置为1,即消费者每次只预取一条消息,处理完这条消息后再去预取下一条,这样可以有效地解决消息消费不均匀的问题。 6. ActiveMQ的死信队列 在消息处理失败的情况下...

    SpringBoot快速玩转ActiveMQ消息队列

    在IT行业中,消息队列(Message Queue)是一种重要的中间件技术,它允许应用程序之间通过异步通信进行数据交换。...通过理解和实践上述知识点,你将能够熟练地在SpringBoot项目中运用ActiveMQ实现消息队列的功能。

    ActiveMQ学习笔记之九--发送消息到队列中

    JMS提供了两个核心接口,`MessageProducer`和`MessageConsumer`,用于创建消息并将其发送到目的地(如队列或主题),以及从目的地接收消息。此外,`Session`接口用于管理事务和同步消息的发送与接收。 2. **连接...

    ActiveMQ消息总线介绍

    - **消息路由**:通过集成Apache Camel等工具,ActiveMQ支持复杂的路由规则,使得消息可以根据特定条件被路由到不同的目的地。 - **事务支持**:支持XA事务,确保消息处理的一致性和完整性。 - **集群支持**:支持多...

    activemq ajax方式demo

    2. **发送消息**:使用Ajax,客户端可以向ActiveMQ发布消息,这通常涉及构建JMS消息对象,设置目的地(如主题或队列),然后通过Ajax请求发送到服务器。 3. **接收消息**:同样,客户端会监听服务器的响应,一旦有新...

    activemq-cpp发送接收消息,消息过滤器

    3. **定义目的地**:消息需要发送到特定的目的地,可能是队列(Queue)或主题(Topic)。你可以创建`Destination`对象来表示这些目标。 4. **创建生产者**:使用会话创建一个`MessageProducer`对象,它是发送消息的...

Global site tag (gtag.js) - Google Analytics