问题标签 [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.
jboss - JmsTemplate 和 CachingConnectionFactory
在将消息发送到 Jboss 队列时,我发现尝试减少连接和会话创建时遇到了一些困难。
我正在使用 JmsTemplate 发送消息:
jbmConnectionFactory 定义如下:
我正在使用这段代码向 Jboss 发送消息:
我试图通过使用 CachingConnectionFactory 来避免创建和关闭我发送的每条消息的连接和会话,但据我所知,在使用 JmsTemplate 时,无论我使用什么类型的 connectionFactory,连接和会话都会总是被终止:
我调用了错误的方法吗?有什么我不明白的吗?
spring - Spring JmsTemplate 连接池
我们有基于特定事务动态更改队列名称的场景,我们将使用 IBM mq 进行排队。我的问题是,如果我定义JmsTemplate
为请求范围 bean,它将允许为每个请求动态修改队列名称,将连接池化机制与JmsTemplate
. 我们正在使用弹簧缓存工厂机制。
请帮助解决这个问题。
java - 如何检查我们是否已从 MQ 读取所有消息
需要您帮助更新以下代码,目前此代码从 IBM MQ 获取第一个 msg,但我的要求是获取直到 MQ 为空
transactions - 事务处理批量发布 Spring JMS 和 Websphere MQ
我需要一次向 N 个主题发送多条消息。消息知道如何路由自己。如果任何一个发布失败,所有之前的发布都需要回滚。这在 Websphere MQ 上是否可行,如果可以,如何实现?
java - spring jmstemplate 属性配置
我正在使用带有 JBOSS MQ 的 Spring JmsTemplate。我是否需要在我的 jmsTemplate 配置文件中使用“sessionTransacted”属性?如果我不专门配置它,它的默认值是什么?
spring - JmsTemplate - 代理名称问题 (ObjectName)
我们在 junit 测试中使用了一些 activemq 操作(通过 jmx)。
我们有两个主要环境:
1) 本地
2) 质量保证
作为 JMS 操作代码的一部分,我们使用 activemq objectName。
问题是 - 在一个环境中
在另一个环境中:
不幸的是,我们的代码使用了对象名称的硬编码名称,如下所示:
这当然适用于一个环境,但不适用于另一个环境,有没有办法设置对象名?或在连接到 JMS 之前获取对象名称(我们使用的是 JmsTemplate)
谢谢
java - 关于 Spring Batch 块行为的说明
我们正在使用 Spring Batch Chunk 从 JMS 目标读取消息并写入平面文件。在这方面,我们有以下观察,
如果消息代理在阅读器读取消息并且未达到提交计数时关闭,则到目前为止读取的消息数量都将传递给 Writer,然后批处理进入 FAILED 状态。这是 Chunk 的默认行为吗?
如果第 1 点的答案是肯定的,我们如何确保这部分块不发送给 Writer。(为了提供更多关于这个问题的背景知识,我们在 JMS 模板中处理了 JMS 会话,因此当块无法读取等于 Commit Count 的完整消息数时,部分块中读取的所有消息都将回滚到JMS 目标,其中相同的部分块被写入文件。当我们重新启动批处理作业时,这会导致文件中的重复)。
任何帮助将不胜感激。
编辑
配置如下图,
块:
作家(平面文件):
阅读器(JMS):
编辑 2
下面是我正在使用的核心阅读器逻辑,
读者
java - 带有 Spring Boot 的 ActiveMQ。消息持久性不起作用
我想在 Spring Boot 应用程序中使用 ActiveMQ 作为嵌入式服务器。为了设置 ActiveMQ,我使用了以下教程:Spring Boot。使用 JMS 进行消息传递。我的应用程序将成为代理和消费者。有多个线程创建这样的消息:
我有另一个具有以下方法的类:
在测试期间,我可以看到消息被生成和消费。如您所见message.acknowledge()
,已评论。所以我希望在重新运行我的应用程序后重新发送消息。然而它不会发生。
java - Spring jmsTemplate messageConvertor.fromMessage() 未被调用
我有以下转换器:
我的 bean 定义如下所示:
该toMessage()
函数是直接从我那里调用的,EventConverter
这很棒。
问题是fromMessage()
没有从我的EventConvertor
. (顺便说一句:org.springframework.jms.support.converter.SimpleMessageConverter
确实被调用了fromMessage()
,就像我EventConverter
没有在特定函数中覆盖它 - fromMessage()
。)
有任何想法吗?
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 配置。
在运行时,我得到以下异常:
任何帮助深表感谢。谢谢!