我有一个Spring JMS,ActiveMQ设置,其中我使用SimpleMessageListenerContainer,我将其与POJO消息监听器相关联。我定义了一个ReDeliveryPolicy,如果POJO消息监听器中存在异常,则消息将在4次尝试后发送到DLQ。我想在重试耗尽后访问消息,是否可以使用SMLC?DefaultMessageListenerContainer怎么样?
您需要另一个容器侦听DLQ。
或者可以使用JmsTemplate。在DLQ上接收(),以便按需获取它们。
问题内容: 有没有一种方法可以抑制ActiveMQ服务器上定义的队列上的重复消息? 我尝试手动定义JMSMessageID((message.setJMSMessageID(“ uniqueid”)),但是服务器忽略此修改并使用内置的JMSMessageID传递消息。 根据规范,我没有找到有关如何删除邮件重复数据的参考。 在HornetQ中,要解决此问题,我们需要在消息定义中声明HQ特定的属性or
我已经做了什么: > 在Weblogic 11g节点上配置的JMS服务器 配置的外部服务器-AMQ连接工厂和绑定到本地JNDI的源队列对象(OK:Conn.工厂和队列对象可见于服务器JNDI树中) 用默认道具创建JMS桥(好吧-我想) 使用默认配置为目标目的地(Weblogic)创建了桥接目的地--在可能的情况下(OK:部署了资源适配器) 为源目标(AMQ)创建了桥接目标-JNDI属性,在可能的情
我需要从两个队列加载消息,并且我使用ActiveMQ,我必须实现重试机制,以防出现任何错误或网络或应用程序服务器故障并加载回同一个队列。此外,我想将任何有害消息加载到DLQ。 请让我知道我是否可以通过Spring JMS实现这些。此外,请提供一些很好的例子来完成这项任务。我检查了Spring JMS留档,没有太多细节。
我尝试制作示例代码来研究jms。我遇到了一些错误。所以,我搜索了一些解决错误的文章。我放弃了,因为我找不到如何使用spring4在ActiveMQ中设置代理。请给我一些建议或解决问题。 这是一个错误。 这是我的Spring配置文件。 而且,当我尝试设置使用ActiveMQConnectionFactory的CachingConnectionFactory时,它带来了错误。然而,在这个站点(http
我正在使用WSO2ESB4.7.0和ActiveMQ5.8.0。我希望将消息存储在队列中,为此我尝试使用这段代码,但它不工作。我创建了存储库,这将有助于存储消息,我的conumeing过程已经在JAVA代码中完成,所以我不必担心消费,如果我这样做了,我的消息将出现在acivemq UI中。我的配置如下所示 我试图通过代理传递消息,为此我编写了简单的代理服务 在这种情况下,我的队列没有在Active
你好,这个问题与此相关,我想知道是否有任何方法可以在JMS上下文中的qpid中设置标头。我们正在使用和Spring的JMS库。 我试图找到一些使用扩展的方法,但找不到方法,或者甚至不可能。