jmstemplate

0热度

2回答

我通过org.springframework.jms.core.JmsTemplate将org.springframework.messaging.support.GenericMessage发送到ActiveMQ中的队列。在ActiveMQ中，我看到这条消息： Cannot display ObjectMessage body. Reason: Failed to build body from

1热度

1回答

春天批量写入ActiveMQ

我尝试将消息写入JMS队列，我在下一步中将其写入数据库。第一部分应该是第二个异步同步。 JMS部分非常慢（1分钟内1100个项目到队列中）。这就是我的工作。 @Bean public Job multiThreadedStepJob() { Flow flow1 = new FlowBuilder<Flow>("subflow1").from(step()).end();

0热度

1回答

春JMS到WebSphere MQ连接错误

AppConfig.xml设置： <bean id="connectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory"> <property name="hostName" value="abchost.com /> <property name="port" value="1414" /> <property name="

1热度

1回答

使用Spring JmsTemplate的/ ActiveMQ的使用请求/应答，而不在队列中

阻止了其他邮件，我们实施了，我们要等待响应特定的用例分布式请求/响应类型的架构。我们使用的JMS代理是ActiveMq，代码使用Spring连接在一起。我们看到的问题是，它看来，如果发送了一堆请求到相同的目的地，任何请求，比如，需要的时间显著量来完成，块跟在它后面的请求消息。消费者使用的SessionAwareMessageListener接口仅支持onMessage（）方法。在这里实现并行性的

0热度

3回答

如何从JMS队列中删除消息？

我有几个作业，每个作业都有多个排队的消息。每个作业的消息是随机交错的。如果用户决定取消作业，我想从队列中删除属于该作业一部分的所有消息。我已经能够使用browse()找到所有要删除的邮件，但一直未能弄清楚如何删除它们。我试图通过使用receiveSelected()摆脱他们，但它只是挂起。（我正在使用JmsTemplate）

2热度

1回答

Setsessiontransacted如何在JMSTemplate和DefaultMessageListenerContainer与Pub /子模型中工作

我正在使用发布者/订阅者模型，在该模型中使用JMSTemplate将消息发布到主题上。我使用defaultmessagelistenercontainer来订阅和接收消息。我知道我可以在两个配置中设置sessionTransacted true。但如果我把会发生什么情况1）只有JMSTemplate setsessionTransacted为true？ 2）only messagelisten

1热度

1回答

Spring JMS和参数化类型（@JmsListener，例如列表<String>参数）？

我希望能够发送List<String>类型的值使用JmsTemplate.convertAndSent(...)，然后使用注释为@JmsListener的方法接收它，该方法采用类型为List<String>的参数。但是，似乎将消息有效内容类型存储为消息属性的默认方法不支持泛型。如果我期待在MappingJackson2MessageConverter.getJavaTypeForMessage

0热度

1回答

在一个事务中发送多个jms消息

我必须向2个不同的队列（队列1和队列2）发送消息。但是，我想回滚，如果发送失败的任何队列（队列1或队列2）。我的源代码如下所示。任何人都可以通过这方面的一些投入 public void sendMessage(final Map<String, String> mapMessage) { jmsTemplate.send(queue1, session -> { MapM

0热度

1回答

如何使用JMS将预定消息发送到Azure服务总线

Azure服务总线能够发送预定消息。用此处描述的AMQP协议发送计划消息：https://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-amqp-request-response#message-operations 计划消息。请求该请求消息必须包括以下应用程序属性： | Key |值|类型|必需|价值内容

0热度

1回答

控制消息侦听器停止为一定时期并重新开始听

监听器： <bean id="msglistenerForAuditEvent" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> <property name="connectionFactory" ref="jmsFactory"/> <property name="ses