-
2 votesanswersviews
使用ActiveMq和Atomikos两次使JMS消息出列
我使用ActiveMq作为JMS服务器,使用Atomikos作为事务管理器 . 在ActiveMq Admin Web界面上,我看到一条消息已入队,但2(!)条消息已出列 . 但是,jms消费者进程消息只有一次,处理中没有重复 . 当我使用简单的Spring JmsTransactionManager时,有一个排队的消息和一个排队的消息 . 该问题仅出现在Atomikos JTA事务管理器中 . ... -
1 votesanswersviews
activeMQ不参与Weblogic XA事务
我尝试使用部署到Weblogic的Spring webapp中的jdbc和jms DataSource进行XA事务处理 . 使用本地Atomikos TransactionManager,这是有效的 - 我在ActiveMQ中看到XA调试消息,并且东西保持一致 . 但是,在Weblogic中,数据库和ActiveMQ在事务上不一致 . 我在Weblogic中添加了一个外部JMS服务器 JNDI初始... -
0 votesanswersviews
spring-jms 5.x是否需要JMS 2.0?
我可以在spring-jms.gradle中看到从5.0.0开始,对JMS API的依赖从1.1变为2.0 . 但是,我的问题是:这是否意味着spring-jms 5.x实际上是 requires 实现JMS 2.0的提供程序? 在spring spring-jms类的Javadoc(如 @EnableJms )中,我无法在spring文档中找到对JMS版本的明确要求 . 对于其他JEE API,... -
1 votesanswersviews
Spring tomee JTA交易
我一直在努力构建一个非常简单的应用程序,该应用程序使用spring,hibernate和JMS进行部署 . 我相信我的所有配置都是正确的(有mysql xa数据源和xa活动的mq连接工厂)但事情并没有像我期望的那样工作 . 目前我有一个简单的服务,使用注入的实体管理器写入,然后在一个注释为事务性(spring注释)的方法中推送到JMS,但我的消息监听器在 Spring 天提交事务之前传递这些消息 ... -
0 votesanswersviews
我的xml配置有什么问题?
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"... -
5 votesanswersviews
正确关闭ActiveMQ和Spring DefaultMessageListenerContainer
从Tomcat管理器发出“停止”命令时,我们的系统不会关闭 . 我已经确定它与ActiveMQ / Spring有关 . 我甚至想出了如何让它关闭,但我的解决方案是一个黑客(至少我希望这不是“正确”的方式) . 我想知道关闭ActiveMQ的正确方法,以便我可以删除我的黑客 . 我继承了这个组件,我没有关于为什么做出某些架构决策的信息,经过大量的挖掘后我觉得我理解他的想法,但我可能会遗漏一些东西 ... -
1 votesanswersviews
计时器已取消AbstarctInactivityMonitor activemq 5.14中的异常
当我向我的spring-jms应用程序发出大约100个线程时,持续面对这个异常 . 看起来它无法在PooledConnectionFactory中添加新连接,即使池中没有活动连接 . javax.jms.JMSException: Error while attempting to add new Connection to the pool at org.apache.activemq.... -
4 votesanswersviews
通过 spring 集成自动配置ActiveMQ
在当前版本中,spring boot还可以在检测到ActiveMQ在类路径上可用时配置ConnectionFactory . 如果存在代理,则会自动启动并配置嵌入式代理 . 使用JMSTemplate时似乎也是如此 . 如果我想使用spring集成自动配置,那么不幸的是这不起作用 . ActiveMQ似乎是在 spring 集成后配置的 . 缺少连接工厂的Spring引导报告错误 . 我正在使用... -
2 votesanswersviews
PooledConnectionFactory池中的ActiveMQ连接/会话不用于故障转移:uri
我在AMQ 5.12.0上有一个2代理群集,我正在通过Tomcat 8 Web应用程序发送消息 . 我有以下Camel(2.15.2)/ Spring(4.2.1)配置 . 我正在使用它来配置AMQ PooledConnectionFactory . <camel:camelContext id="camel-client"> <camel:templ... -
7 votesanswersviews
使用JMS 2.0的Spring 4 CachingConnectionFactory无法正确缓存 生产环境 者
我们刚刚升级到Spring 4和JMS 2.0 . 我们使用 CachingConnectionFactory 和 JmsTemplate 来发布消息,并注意到在发布到目标时,第一次尝试有效,然后进一步尝试发布到同一目标会导致以下异常: 引起:javax.jms.IllegalStateException: 生产环境 者已关闭 Spring 3.2和JMS 1.1一切正常,所以我做了一些挖掘,... -
1 votesanswersviews
Spring Integration jms消息驱动的通道适配器失败
我正在使用spring integration 4.1.0使用jms-int从TIBCO EMS队列实现消息消耗:message-driven-channel-adapter 我有9个不同的消息驱动通道适配器在不同的队列中的不同服务器上监听 下面是如何定义消息驱动的通道适配器 <int-jms:message-driven-channel-adapter id="m... -
1 votesanswersviews
不使用消息驱动通道适配器调用Spring Integration错误通道
注意:由于我正在处理的项目的依赖性要求,我使用的是Spring Integration 3.0.5.RELEASE . 我已经使用重新传递策略配置了连接工厂(我们使用的是Active MQ 5.7) <amq:connectionFactory id="cms.jmsConnectionFactory" brokerURL="${cms.jms.brok... -
0 votesanswersviews
Spring ActiveMQ JMS - TopicSession不支持队列
我有以下代码配置为使用Spring框架和ActiveMQ作为代理发送JMS消息 . 但是当我尝试将消息发送到目标队列时,我得到了以下异常 . 事情是,如果我更改“jmsTemplate " connectionFactory to " amqConnectionFactory”ActiveMQ连接工厂,它可以工作(没有例外) . 但是,这不会破坏使用Spring缓存连接的目的吗... -
2 votesanswersviews
一段时间后,activemq队列中没有新的消费者
从一个月开始,我们就遇到了activemq和spring的重复问题 . 经过一段时间(一天到一周之间),我们没有更多的消费者,没有新的消费者开始,队列开始填满 . 这个设置运行了一年多,没有任何问题,只要我们看到没有任何相关的改变 . 我们使用的另一个队列也开始显示相同的行为,但不太常见 . 来自activemq webconsole(因为你可以看到许多待处理的消息,没有消费者) Name ↑ N... -
5 votesanswersviews
Spring作为Broker Relay使用外部Message Broker
我想使用 Spring Messaging 为我的webapp为已登录用户创建实时通知系统 . 我将 AbstractWebSocketMessageBrokerConfigurer 定义如下: @Override public void registerStompEndpoints(StompEndpointRegistry registry) { registry.addEndpoin... -
1 votesanswersviews
Spring JMS事务回滚 - 消息从ActiveMQ中退出
我有一个简单的Spring Boot应用程序(Spring Boot Version 1.5.3.RELEASE),用于从ActiveMQ(版本5.14.5)Queue中使用JMS消息 . 我希望消息在JMS事务中使用 . 如果在消息消耗期间存在异常,我希望回滚事务并且消息不被出列(从消息队列中取消) . 我可以看到事务在Spring日志中回滚,但是消息仍然从ActiveMQ队列中出队(在六次重新... -
1 votesanswersviews
Spring Integration Control Bus消息,用于更改JMS入站通道适配器的选择器
我目前正在基于Spring Integration的(版本3.0.1.RELEASE)应用程序上实现一个流程,该应用程序需要将消息存储在JMS队列中以便稍后获取 . 为此,我一直在尝试将Spring Integration JMS入站通道适配器与自定义选择器一起使用,然后通过将JMSDestinationPollingSource的JMS选择器更改为包含为标头属性的某个匹配ID来从队列中获取消息 ... -
1 votesanswersviews
Spring集成JMS消息驱动的通道适配器在一定时间间隔后停止选择消息
我正在使用spring集成来使用jms-int:message-driven-channel-adapter从TIBCO EMS队列中读取消息 . 我面临的问题是:经过一段时间说5-10小时(随机间隔发生),即使jms队列中有消息,jms通道适配器也会停止选择消息 下面是我的spring集成上下文: <bean id="jmsConnectionFactory" clas... -
1 votesanswersviews
Spring-ActiveMQ:DefaultMessageListenerContainer没有被破坏
我使用Spring JMS DefaultMessageListenerContainer并在spring的init方法上初始化队列并在destroy方法上销毁listnereContainer . 但是当我使用“./catalina.sh stop”命令关闭tomcat服务器时,我在使用线程转储时遇到以下异常: “localhost-startStop-2”#155 daemon prio =... -
1 votesanswersviews
由于“收到过期消息”而无法消耗来自ActiveMQ的消息
我在调试语句之下,我的消息监听器没有消耗任何消息 . 22:25:17.870 [org.springframework.jms.listener.DefaultMessageListenerContainer#0-1] DEBUG oaactivemq.ActiveMQMessageConsumer - ID:CONSUM-1401814509338-1:1:1:1收到过期消息:Messa... -
1 votesanswersviews
查询Spring消息驱动通道适配器
我正在使用Spring的消息驱动通道适配器 . 我的组件正在消费来自Tibco主题和发布到RabbitMQ主题的消息 所以消息流如下:Tibco->(订阅者)组件(发布到) - > RabbitMQ 服务激活器如下所示:我们看到有一个输入通道和一个输出通道 . bean storeAndForwardActivator将具有业务逻辑(在方法createIssueOfInterestO... -
1 votesanswersviews
Spring jms activemq
我使用activemq和spring jms . 我有个问题 . 这是我的EmailSender @Service @PropertySource("classpath:/properties/dev/application.properties") public class EmailSenderImpl implements EmailSender { privat... -
-2 votesanswersviews
为什么messageConverter.fromMessage()没有转换arraylist? java.lang.ClassCastException:java.lang.String无法强制转换
我想发送一条包含销售清单的JMS消息,并通过 onMessage() 接收它 . 据我所知, springframework.jms.support.converter.MessageConverter 应该扮演转换或转换消息的角色,所以我不必创建XSD或额外的映射类 . 我的意思是,我期待测试波纹管发送一条消息,并且 (SalesMessage) messageConverter.fromMes... -
0 votesanswersviews
使用Control总线停止使用事务会话的消息驱动通道适配器
我的要求是使用事务会话与消息驱动通道适配器(JmsMessageDrivenEndpoint) . 我可以使用sessionTransacted = true为DefaultMessageListenerContainer设置配置购买 . 工作流程:接收消息 - >调用服务激活器 - >服务激活器调用dao类 在成功提交数据库时,spring框架调用commit(),并且在任何运行时异... -
1 votesanswersviews
如何在使用来自上游消息驱动通道适配器的会话时在出站通道适配器中缓存 生产环境 者
我设计了以下消息流 1) message-driven-channel-adapter -> 1.1) service-activator -> outbound-channel-adapter (for sending response) 1.2) in a chain - transformer ... -
1 votesanswersviews
JMS Poller Transactional
我正在使用Spring Integration 4.1.5并试图对事务做一些事情,但遗憾的是我无法找到工作示例 . 我正在尝试设置正在查找消息的JMS轮询器 . 收到消息后,服务激活器会在数据库中插入一行,并将消息传递给另一个服务激活器 . 我想制作前两个部分,消息提取和数据库插入事务 . 我不希望其余的流程是事务性的 . 我使用Weblogic作为应用程序容器,因此将使用WebLogicJtaT... -
1 votesanswersviews
使用Message-Driven-Channel-Adapter和DMLC时的事务设置
我正在使用DMLC的消息驱动通道适配器 . Should i set both ? 1) acknowledge="transacted" in Message-Driven-Channel-Adapter and 2) sessionTransacted as true in DMLC Or is it enough to set acknowledge... -
0 votesanswersviews
Spring Integration:接收消息时的异常
在我们的Spring Integration应用程序中,当收到消息时,抛出异常并且变换器不接收消息 . 我认为这可能是由于消息的内容,因为String类型的消息被正确处理 . 以下是此消息类型的变换器签名: @Transformer public String transform(Message inboundMessage){ 也试过了 @Transformer public String t... -
0 votesanswersviews
使用ArtemisMQ Spring JMSTemplate UncategorizedJmsException
它很久以前正常工作 . 当我尝试循环10000个项目并逐个发送到jms队列时,就会发生此错误 . 尝试将消息发送到我的JMS队列时收到以下错误: org.springframework.jms.UncategorizedJmsException:在JMS处理期间发生了未分类的异常;嵌套异常是org.springframework.jms.support.JmsAccessor.convertJm... -
2 votesanswersviews
多台计算机侦听同一个activemq队列
我已经配置了两台机器,每台机器有10个消费者,它们监听在第三台机器上运行的同一个activemq队列 . 但是只有一台机器的消费者正在从队列中读取消息而另一台正在闲置 我期待在activemq web控制台上有20个消费者,但只能看到10个 .可能是什么问题呢?应用程序端或activemq端的任何配置更改? 我使用的是spring-jms(org.springframework.jms.liste...