首页 > TAG信息列表 > spring-jms
春季-Active MQ停止在大量消息上调度消息
我有一个基于Spring JMS和Active MQ(5.6)的系统,该系统具有大约12个Spring默认消息侦听器容器(每个容器最多有20个并发实例),所有这些容器都连接到同一活动mq目标(队列). 系统由每个处理程序(容器)工作,使用选择器从队列中发给自己的消息中提取消息,进行工作,然后将消息放回队列中,春季-单个JMSTemplate可以在多个生产者中共享吗？
我想为连接到ActiveMQ代理的多个生产者共享JMSTemplate的单个实例.样本配置： <bean id="ProducerJmsTemplate" class="org.springframework.jms.core.JmsTemplate"> <property name="connectionFactory"> <ref bean="gloProducerJmsFactory&qjava-从配置属性动态设置@JmsListener目标
我希望能够从application.properties设置@JMSlistener目标 我的代码看起来像这样 @Service public class ListenerService { private Logger log = Logger.getLogger(ListenerService.class); @Autowired QueueProperties queueProperties; public ListenerSer春季-无法刷新目标“ jmsinqueue”的JMS连接-在5000毫秒内重试
目标连接到Hornteq并将消息发送到队列并将其路由到一个主题或队列,并在路由之后和路由之前查看队列和主题中的内容 但是出现以下错误： Could not refresh JMS Connection for destination 'jmsinqueue' - retrying in 5000 ms. Cause: Failed to create session factory; nested exjava-如何在JmsMessagingTemplate.sendAndReceive上设置等待超时
我在MVC控制器中使用来自JmsMessagingTemplate的sendAndReceive,但是如果没有发送回复消息,它似乎永远都在等待回复.该文档指出： Returns: the reply, possibly null if the message could not be received, for example due to a timeout 但是我只是不知道在指定了多长时间或java-是否可以从另一个应用程序(在单独的进程中启动)连接到Spring Boot嵌入式ActiveMq实例？
我已经在Spring Boot中阅读了一些有关jms支持的examples. 通常,发送者,接收者和active-mq(实际上可以是任何其他与jms兼容的消息代理)都位于同一应用程序中. 我知道我可以使用独立的主动mq和use properties： spring.activemq.broker-url=tcp://192.168.1.210:9876 spring.activemq.如何在单个MessageListenerContainer中为Spring Java Config添加多个JMS MessageListners
我的spring-config.xml中有以下xml代码 <jms:listener-container acknowledge="auto" connection-factory="cachedConnectionFactory" container-type="default" error-handler="consumerErrorHandler" concurrency=&quojava-如何使用@JmsListener暂停和开始使用消息
我正在使用Spring Boot版本1.3.2.我正在使用@JmsListener消耗来自activemq的消息,以获取我使用JmsTemplate创建/产生的消息.这是代码： @JmsListener(destination = "myqueue") public void consumeMsg(Object requestBody) try { javaMailSender.send(requestBody);在Spring Boot Application中禁用Spring JMS Auto配置
在我的spring启动应用程序中,我配置了两个不同的MQQueueConnectionFactory实例(不同的id),因为它是应用程序的需要.为此,我添加了ibm客户端罐子. 我还在我的代码中添加了spring-jms依赖项,因为我想要JmsTemplate等类.添加此依赖项后,JmsAutoConfiguration在类路径中找到JmsTemplatejava – 无法在不同的Spring启动应用程序中的不同端口上启动2个嵌入式active-mq
我有2个spring-boot应用程序.每个应用程序都嵌入了活动的mq代理. 我需要在同一台PC上同时运行2个应用程序,但它现在不起作用.第一个应用始终成功启动： 2018-02-02 11:48:20.095 INFO 7660 --- [ main] s.c.a.AnnotationConfigApplicationContext : Refreshing org.sprinspring – 完成jms：侦听器迁移到JavaConfig
就像标题所说.. 我已经阅读了这个有价值的How to add multiple JMS MessageListners in a single MessageListenerContainer for Spring Java Config链接 这篇文章的作者正在努力 messageListenerContainer.setMessageListener(new TaskFinished()); 顺便说一句：我用 @Autowired如何在Spring的applicationContext中设置JMS配置？
如何为下面给出的Java代码设置应用程序？ Hashtable<String, String> properties = new Hashtable<String, String>(); properties.put(Context.INITIAL_CONTEXT_FACTORY, "com.test.factory"); properties.put("com.domain", "java – 添加动态侦听器数量(Spring JMS)
我需要添加多个侦听器,如application.properties文件中所述.像下面一样, InTopics=Sample.QUT4,Sample.T05,Sample.T01,Sample.JT7 注意：这个数字可以更多或更少. 我想把它们放在一个数组中, @Value("${InTopics}") private String[] inTopics; 但我不知道如何从数组创建多个侦spring – DefaultMessageListenerContainer不接收消息
我有一个DefaultMessageListenerContainer配置如下： DefaultMessageListenerContainer container = new DefaultMessageListenerContainer(); container.setConcurrentConsumers(4); container.setConnectionFactory(connectionFactory); container.setDestinationName(String.form如何使用spring boot jms听主题
我正在尝试使用以下代码段听取主题.但是它默认监听队列.在这种情况下没有xml配置.我完全依赖注释.此外,我完全依赖Spring引导提供的AutoConfiguration.我不知道如何将目标类型设置为主题,在JmsListener中. Spring JMS大师请帮忙. @Component public class MyTopicListenerSpring,JMS – 无法为XML模式名称空间找到Spring NamespaceHandler
我一遍又一遍地得到这个错误： 10:37:21,270 ERROR DispatcherServlet:466 – Context initialization failed org.springframework.beans.factory.parsing.BeanDefinitionParsingException: Configuration problem: Unable to locate Spring NamespaceHandler for XML schema najava – ThreadPoolExecutor :: Executor的TaskRejectedException
我的应用程序是通过Jms MessageListener类读取消息,并且在某些时候它抛出TaskRejectedException.我知道大多数人会说maxPoolSize超出了线程数,队列也已满. 但我发现了一些事情.发送到MessageListener类从中获取消息的队列的消息数是10353,我的threadPoolExecutor的spring属性如下：通过弹簧集成自动配置ActiveMQ
在当前版本中,spring boot还可以在检测到ActiveMQ在类路径上可用时配置ConnectionFactory.如果存在代理,则会自动启动并配置嵌入式代理. 使用JMSTemplate时似乎也是如此.如果我想使用spring集成自动配置,那么不幸的是这不起作用. ActiveMQ似乎是在弹簧集成后配置的.缺少连接工厂的Sspring – DefaultJmsListenerContainerFactory vs DefaultMessageListenerContainer
使用DefaultJmsListenerContainerFactory而不是DefaultMessageListenerContainer有什么好处？ >如果我直接配置DMLC,我会通过调用isRunning()来获取检查状态的句柄.我也有一个设施来启动和停止DMLC >但是,根据新的spring规范,如果我配置DefaultJmsListenerContainerFactory,我没有得java – Spring Bean自定义范围JMS
我正在使用Spring Framework使用DefaultMessageListenerContainer并发消耗JMS队列中的消息.我希望能够为每个进入的消息创建自动装配的bean的新实例.我认为设置scope =“prototype”会起作用,但它似乎没有完成这项工作.有没有人知道自定义bean范围会为每个JMS消息创建新实例？就像“使用Spring管理JMS事务
我正在尝试使用Spring和HornetQ管理JMS事务. 这是我写的代码： public void receive() { TransactionStatus status = transactionManager.getTransaction(new DefaultTransactionDefinition()); Message msg = jmsTemplate.receive(queue); boolean success = false;java – sessionTransacted和JmsTransactionManager之间的区别
使用sessionTransacted = true(在JmsTemplate和/或DefaultMessageListenerContainer中)和使用JmsTransactionManager之间的主要区别是什么？对于JmsTemplate和DefaultMessageListenerContainer用法,是否使用sessionTransacted = true？ (我不需要XA) 该文件说(setSessionTransacted setjava – JMS侦听器中异常的JMS消息重新传递
org.springframework.jms.listener.AbstractMessageListenerContainer的Javadoc说明,如果 “sessionAcknowledgeMode” set to “CLIENT_ACKNOWLEDGE”: Automatic message acknowledgment after successful listener execution; no redelivery in case of exception thrown. 我java – 多个QueueConnectionFactory上的异常
我必须连接到两个不同的MQ端点.我使用Spring Java配置定义了4个Beans：2 QueueConnectionFactory和2个JmsTemplate,它们具有不同的名称. 当我启动应用程序或运行测试时,它会抛出以下异常： java.lang.IllegalStateException: Failed to load ApplicationContext at org.springframjava – 将@JmsListener与多个有效负载类型用于同一目的地？
我可以将多种类型的实例写入给定目的地,例如： JmsTemplate template = ... Alpha alpha = new Alpha(...); Beta beta = new Beta(...); template.convertAndSend("my-destination", alpha); template.convertAndSend("my-destination", beta); 我以为我能够提供多个@JmsListener