spring-jms

0热度

1回答

我计划有一个经纪人主题，并有多个默认消息侦听器或简单的消息侦听器。所有的监听者都执行相同的代码。是否每个侦听器代码执行独立于另一个侦听器。我想问的是，如果访问相同方法时听众之间会有冲突吗？我有点像多线程执行一样工作。我正在使用JMS和activemq作为代理。需要了解的一些代码：每个侦听器都会调用这个方法来发送事件的“事件处理”。该方法将依次调用其他方法。句柄方法将依次调用其他方法。 p

0热度

1回答

JMSListener选择器不工作

我有一个JMS生产者发送2种消息：业务逻辑和心跳信息。目前，两者都由同一个接收器处理，但我现在正在尝试通过使用选择器为每个接收器分配专用类。我遇到的问题是每当将选择器添加到接收器时，它都会停止接收消息。这是我到目前为止。为简单起见，我只增加了心脏的跳动代码：要发送信息，我有这样的： private void sendHeartBeat() { this.buildTemplate().

0热度

1回答

JMS连接在发送消息给未授权的路由时不抛出JMSSecurityException

我使用Apache Camel和Spring从我的Java服务发送消息。如果在交换时发生任何错误，我需要处理/触发某些事件。我正在使用下面的代码来实现我的目标。 try { producerTemplate.sendBody(endPoint, bytes); } catch (final RuntimeCamelException exception)

2热度

2回答

当JMS侦听器发生异常时会发生什么

我正在使用默认消息侦听器容器。我在配置中将会话事务属性设置为true。我onMessage()方法是这样的： public void onMessage(Message message) { try { // Some code here } catch (JmsException jmse) { log.error(jmse); } cat

0热度

1回答

耐用侦听器/消费者的使用案例场景

因此，我正在为一个主题（即多个侦听器）创建并发使用者。我将它们配置为耐用。 @Bean public DefaultMessageListenerContainer listenerContainers() { DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();

2热度

1回答

更改Sprint启动中嵌入式ActiveMQ的活动MQ RedeliveryPolicy

如何在使用Spring Boot时更改嵌入式ActiveMQ的交付策略？我试着在DefaultJmsListenerContainerFactory上指定FixedBackOff，但它没有帮助。下面是我用来初始化jms工厂bean的代码。我有一个消息使用者正在处理队列中的传入消息。在处理期间由于不可用的资源，我抛出一个检查异常。我希望在固定的时间间隔后重新传递消息进行处理。春季启动：1.5.7.

-1热度

1回答

Spring 4.x的最稳定版本。升级需要从3.0.5

我想升级我的应用程序从春季3.0.5版本到春季4.x版本，我想知道哪一个是最稳定的（没有错误）..感谢您的帮助：）我想知道我们应该用于升级的主版本和次版本吗？

0热度

1回答

MessageConversionException的通用处理程序

我想在队列中具有特定格式并可以反序列化到某个Java类时处理队列中的消息。为了做到这一点，我创建了以下方法。 @JmsListener(destination = "myQueue", containerFactory = "myFactory") public void receiveMessage(Message message) { service.process(message

0热度

1回答

如何从春监听

得到消息ID我有以下代码： @JmsListener(destination = "myQueue", containerFactory = "myFactory") public void receiveMessage(MyClass message) { service.process(message); } 现在，我想获得的JMS消息ID。我知道我可以重写MappingJa

1热度

1回答

如何从两个不同的连接工厂加入Spring JMS事务？

我正在使用不同的连接工厂来发送和接收消息，在部分提交问题中遇到了发送失败的问题。 jms:message-driven-channel-adapter使用receiveConnectionFactory ro从队列中接收消息。 jms:outbound-channel-adapter使用deliverConnectionFactory将消息发送到下游队列。我们只有一个JmsTransactionM