问题标签 [jmstemplate]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
3128 浏览

jboss - JmsTemplate 和 CachingConnectionFactory

在将消息发送到 Jboss 队列时,我发现尝试减少连接和会话创建时遇到了一些困难。

我正在使用 JmsTemplate 发送消息:

jbmConnectionFactory 定义如下:

我正在使用这段代码向 Jboss 发送消息:

我试图通过使用 CachingConnectionFactory 来避免创建和关闭我发送的每条消息的连接和会话,但据我所知,在使用 JmsTemplate 时,无论我使用什么类型的 connectionFactory,连接和会话都会总是被终止:

我调用了错误的方法吗?有什么我不明白的吗?

0 投票
0 回答
533 浏览

spring - Spring JmsTemplate 连接池

我们有基于特定事务动态更改队列名称的场景,我们将使用 IBM mq 进行排队。我的问题是,如果我定义JmsTemplate为请求范围 bean,它将允许为每个请求动态修改队列名称,将连接池化机制与JmsTemplate. 我们正在使用弹簧缓存工厂机制。

请帮助解决这个问题。

0 投票
1 回答
1034 浏览

java - 如何检查我们是否已从 MQ 读取所有消息

需要您帮助更新以下代码,目前此代码从 IBM MQ 获取第一个 msg,但我的要求是获取直到 MQ 为空

0 投票
1 回答
231 浏览

transactions - 事务处理批量发布 Spring JMS 和 Websphere MQ

我需要一次向 N 个主题发送多条消息。消息知道如何路由自己。如果任何一个发布失败,所有之前的发布都需要回滚。这在 Websphere MQ 上是否可行,如果可以,如何实现?

0 投票
1 回答
1021 浏览

java - spring jmstemplate 属性配置

我正在使用带有 JBOSS MQ 的 Spring JmsTemplate。我是否需要在我的 jmsTemplate 配置文件中使用“sessionTransacted”属性?如果我不专门配置它,它的默认值是什么?

0 投票
0 回答
136 浏览

spring - JmsTemplate - 代理名称问题 (ObjectName)

我们在 junit 测试中使用了一些 activemq 操作(通过 jmx)。

我们有两个主要环境:

1) 本地

2) 质量保证

作为 JMS 操作代码的一部分,我们使用 activemq objectName。

问题是 - 在一个环境中

在另一个环境中:

不幸的是,我们的代码使用了对象名称的硬编码名称,如下所示:

这当然适用于一个环境,但不适用于另一个环境,有没有办法设置对象名?或在连接到 JMS 之前获取对象名称(我们使用的是 JmsTemplate)

谢谢

0 投票
0 回答
531 浏览

java - 关于 Spring Batch 块行为的说明

我们正在使用 Spring Batch Chunk 从 JMS 目标读取消息并写入平面文件。在这方面,我们有以下观察,

  1. 如果消息代理在阅读器读取消息并且未达到提交计数时关闭,则到目前为止读取的消息数量都将传递给 Writer,然后批处理进入 FAILED 状态。这是 Chunk 的默认行为吗?

  2. 如果第 1 点的答案是肯定的,我们如何确保这部分块不发送给 Writer。(为了提供更多关于这个问题的背景知识,我们在 JMS 模板中处理了 JMS 会话,因此当块无法读取等于 Commit Count 的完整消息数时,部分块中读取的所有消息都将回滚到JMS 目标,其中相同的部分块被写入文件。当我们重新启动批处理作业时,这会导致文件中的重复)。

任何帮助将不胜感激。

编辑

配置如下图,

块:

作家(平面文件):

阅读器(JMS):

编辑 2

下面是我正在使用的核心阅读器逻辑,

读者

0 投票
1 回答
2311 浏览

java - 带有 Spring Boot 的 ActiveMQ。消息持久性不起作用

我想在 Spring Boot 应用程序中使用 ActiveMQ 作为嵌入式服务器。为了设置 ActiveMQ,我使用了以下教程:Spring Boot。使用 JMS 进行消息传递。我的应用程序将成为代理和消费者。有多个线程创建这样的消息:

我有另一个具有以下方法的类:

在测试期间,我可以看到消息被生成和消费。如您所见message.acknowledge(),已评论。所以我希望在重新运行我的应用程序后重新发送消息。然而它不会发生。

0 投票
0 回答
536 浏览

java - Spring jmsTemplate messageConvertor.fromMessage() 未被调用

我有以下转换器:

我的 bean 定义如下所示:

toMessage()函数是直接从我那里调用的,EventConverter这很棒。

问题是fromMessage()没有从我的EventConvertor. (顺便说一句:org.springframework.jms.support.converter.SimpleMessageConverter确实被调用了fromMessage(),就像我EventConverter没有在特定函数中覆盖它 - fromMessage()。)

有任何想法吗?

0 投票
1 回答
1159 浏览

spring - WebLogic 10.3.6 在使用 lookupOnStartup false 配置时抛出 JMSClientExceptions:055142

我有一个简单的 Java Spring 应用程序,它使用 JNDI 查找 JMS 对象并将消息发布到 JMS 主题。在 WebLogic 10.3.6 上配置的 JNDI 和 JMS。只要 WebLogic 服务器启动并运行,所有这些都可以正常工作。

即使 WebLogic 服务器关闭,我也需要启动应用程序。我已将“lookupOnStartup”配置为“false”的 JNDI 对象。

下面是我的 Spring 配置。

在运行时,我得到以下异常:

任何帮助深表感谢。谢谢!