spring-jms相关内容
我们刚刚升级到Spring 4和JMS 2.0.我们使用CachingConnectionFactory和JmsTemplate来发布消息，并注意到在发布到目标位置时，第一次尝试有效，然后再尝试发布到相同的目的地会导致以下异常: 原因:javax.jms.IllegalStateException:生产者已关闭 所有内容在Spring 3.2和JMS 1.1上都运行良好，因此我做了一些
..
基于本文，我已将Jboss eap 6.2连接到外部ActivemQ 5.9.0.为了发送/接收消息，我使用了spring-jms 4.1.1中的JmsTemplate和DefaultMessageListenerContainer.接收消息运行正常，但是在发送消息时出现此错误: 11:33:37,059 ERROR [stderr] java.lang.reflect.Invocatio
..
Spring提供了@JMSListener批注，以侦听来自特定队列的消息.还有实施JmsListenerConfigurer 并注册MessageListener. 在两种情况下，都必须在应用程序启动时通过对代码进行硬编码或通过属性来知道队列的名称. 是否有一种方法可以监听在应用程序启动后很久才知道其名称的队列? 解决方案 这应该有效. 为@JmsListener配置一个
..
我有WildFly 10.1.0.Final，这有Artemis 1.1.0 配置jndi.properties的正确方法是什么?: java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory java.naming.provider.url=http-remoting:
..
我们正在尝试使用CCDT文件和JMS配置连接到IBMMQ. 我们可以连接到它，但是这里有一个问题: 由于我们正在使用spring来设置CCDT文件的连接工厂，因此在应用程序启动时将其初始化一次，但是不幸的是，它一次只选择一个队列管理器，即它将所有消息发送到同一队列管理器，并且它不会实现负载平衡. 尽管我观察到了，但是如果我在每个请求之前手动设置了CCDT文件，那么它就能够负载均衡队列管
..
两个单独的进程正在通过MQ上的JMS进行通信. 作者设置字符串属性: new MessageAction() { public void actOn(Message message) throws JMSException { logger.debug("Setting message property (GmmThreadId, CASHFLOW-1234)"
..
我想为以下内容编写测试； 在src/main中有一个名为state-info-1的侦听器. 它会对收到的任何消息进行一些更改，并在activemq主题state-info-2上发布新消息. 我将构建一条虚拟消息并将其发布到activemq主题state-info-1. 最后确认，收到的关于主题state-info-2的消息是否与我预期的一样. 我的听众就像; @
..
在以下测试中，我试图模拟以下情况: 消息队列已启动. 启动了一个在消息处理过程中失败的使用者. 产生一条消息. 消费者开始处理该消息. 在处理过程中会引发异常，以模拟消息处理失败.失败的使用者已停止. 另一个消费者开始接听重新传递的消息. 但是我的测试失败，并且消息没有重新发送给新使用者.我将对此表示感谢. MessageProcessingFailureAndRepr
..
我正在使用JMS将消息放入队列. 该队列与2个QueueConnection工厂和2个队列管理器链接. 在将消息发送到队列时，我想通过2个不同的队列连接工厂将消息平均分发/发送到2个不同的队列管理器. 示例: 在不同的时间点， 我的服务接收到来自某个用户的消息.我需要将消息平均放入2个QCF/QueueManager中.(负载平衡) 如果我收到第一条消息，则需要发送到第一台
..
当我收到此错误时，我尝试使用Spring连接到Tibco Ems主题. 这是配置:
..
我们正在尝试对某些JMS消息设置延迟，以便仅在x时间之后将消息添加到侦听器接收到的队列/中.到目前为止，我们已经尝试了两种无效的方法. 1)根据spring文档，我们可以在JMSTemplate上设置传递延迟.这是我们尝试的示例代码: @Autowired private JmsTemplate jmsTemplate; ... long deliveryDelay = ...; t
..
我需要添加多个侦听器，如application.properties文件中所述.像下面一样， InTopics=Sample.QUT4,Sample.T05,Sample.T01,Sample.JT7 注意:此数字可以更多或更少. 我正在考虑将它们排列成阵列， @Value("${InTopics}") private String[] inTopics; 但是我不知道如
..
与Spring有关的Java文档此处 CachingConnectionFactory有评论: 注意:此ConnectionFactory要求显式关闭从其共享Connection获得的所有Session.无论如何，这是对本机JMS访问代码的通常建议.但是，对于此ConnectionFactory，必须使用它，以便实际上允许Session重用. 我不清楚如何在我的应用程序中使用以下给定的
..
我想使用Spring的DefaultMessageListenerConatiner(通过重写doReceiveAndExecute)在一段时间内(从接收到第一条消息后300毫秒)从Queue接收消息块，如当队列中有太多消息时，我可以将批量大小为20的消息分组，而当队列中的消息很少时，我可以接收不到20条消息. 问题: 我看到即使队列已满，将消息发送到侦听器也要花费太多时间(有时1秒，
..
所以问题是如何使用休假方式临时停止和启动使用spring创建的jms侦听器:
..
我在项目上使用Spring(boot)，并且使用以下命令访问JMS队列(ActiveMQ): @JmsListener(destination = "mydestinationQueue") public void processMessage(String content) { //do something } 它运行良好，但是我需要能够以编程方式(REST调用或类似的东西)停
..
使用Spring-JMS可以通过 DefaultMessageListenerContainer 。 然而写消息的唯一记录方式是通过 JmsTemplate.send（...）我无法看到如何强制使用给定的 TransactionManager 。 任何人都可以指出我正朝着正确的方向前进？ 更多信息：确保事务管理器可用（ WebSphereUowTransactionManager
..
我正在设置一个JMS订阅者监听器，目标是实现一个5个线程池，监听topATopic，但是，我在运行时看到的是多个消费者处理相同的记录（recordCount *＃of consumers）。 / p> 考虑到我是春天新手，我假设我做错了什么。
..
这是我第一次使用 Spring JMS （以及一般的JMS），我对 JmsTemplate 回调的概念有些怀疑。 我知道 JmsTemplate 是一个从Spring提供的类： 减少样板代码。 透明地管理资源。 将已检查的异常转换为运行时等效项。 提供便利方法和回调。 并且它用于消息生成和同步消息接收。它简化了JMS的使用，因为它在发送或同步接收消息时处理资源的创建和释放。
..
我基于spring，jms和activemq创建了一个简单的生产者消费者模拟， 我试图从双方，生产者和消费者那里获得高性能， 连接设置：
..
