spring-jms相关内容

spring jms 错误处理程序访问消息

我们使用 spring-jms 从队列中接收消息.但有时我们会遇到连接问题(侦听器线程上的下游 JDBC)，其中池中没有足够的连接.所以我们想再次重试该消息，如果我们仍然没有连接，那么我们将拒绝该消息 我们正在错误处理程序中尝试此操作，并且该错误处理程序实例被注入到 spring 默认消息侦听器容器中，但我不确定如何访问消息对象，因为它仅提供 Throwable 对象. 有人知道如何访 ..
发布时间：2021-08-20 20:47:36 其他开发

@JmsListener 上的 ActiveMq 事务

我尝试让带有 activeMq 代理的 Jms 消费者获得“事务性"确认.我想使用 spring boot 应用程序. 我读到我需要 JTA 事务，但我不知道如何开始. 我的主要课程: @SpringBootApplication@EnableJms公共类应用{公共静态无效主(字符串 [] args){SpringApplication.run(Application.class, ..
发布时间：2021-08-20 20:47:33 Java开发

配置多个 DefaultJmslistenercontainerfactory

在我的应用程序中，我有 2 个 diff mq conn 工厂 bean.为此，我有 2 个 diff DefaultJmslistenercontainerfactory beans ex cf1 n cf2.每个 DefaultJmslistenercontainerfactory bean 都在单独的 @JmsListener 中引用...现在我想以编程方式开始停止每个列表器，为此我覆盖了 ..
发布时间：2021-08-20 20:47:30 其他开发

安全终止 Spring JMS 应用程序

我正在开发一个严格使用 bean 注释设置的 Spring boot JMS 应用程序，并且正在从 WebshpereMQ 读取消息.一切正常，除了我不知道如何安全地关闭这个应用程序.一旦我的 JMSListener 方法读取了所有消息，它就会保持空闲状态.我与队列建立初始连接并访问队列深度，因此理想情况下，当队列深度为零时，它需要将其打包并关闭.我目前的解决方法(我根本不喜欢它)是当深度为零时我 ..
发布时间：2021-08-20 20:47:27 Java开发

如何停止/启动 spring DefaultMessageListenerContainer?

我已经开发了使用 Spring JMS 接收来自队列的消息的项目.并部署了Websphere Application Server (WAS 7.5) 集群环境.一旦部署在服务器中，它就可以正常工作.后来我更新了我的记录器信息并部署到服务器中.似乎服务器没有选择最新的代码库.即使我已经停止/启动集群. 请参考下面的配置xml. ..
发布时间：2021-08-20 20:47:13 其他开发

ThreadPoolExecutor :: 来自 Executor 的 TaskRejectedException

我的应用程序正在通过 Jms MessageListener 类读取消息，并且在某个时间点抛出 TaskRejectedException.我知道你们大多数人会说maxPoolSize超过了线程数，队列也满了. 但是我观察到了一些东西.发送到 MessageListener 类从中获取消息的队列的消息数为 10353，我的 threadPoolExecutor 的 spring 属性如下: ..
发布时间：2021-08-20 20:47:04 Java开发

如何在 JmsMessagingTemplate.sendAndReceive 上设置等待超时

我在 MVC 控制器中使用来自 JmsMessagingTemplate 的 sendAndReceive 但如果没有发送回复消息，它似乎一直在等待回复.文档指出: 返回:回复，如果无法接收消息，则可能为 null，例如由于超时 但是，我不知道给出超时多长时间或在哪里配置它.有人可以向我解释一下吗? 仅供参考:我使用的不是 spring-integration，而是 spring ..
发布时间：2021-08-20 20:47:01 Java开发

如何在队列上设置 ActiveMQ redeliveryPolicy?

如何在队列上的 ActiveMQ 中设置 redeliveryPolicy? 1) 在文档中，请参阅:activeMQ Redelivery，说明您应该在 ConnectionFactory 或 Connection 上设置它.但我想为不同的队列使用不同的值. 2)除此之外，我似乎无法让它发挥作用.在 Spring 的连接工厂上设置它(我使用的是 activemq 5.4.2. 和 S ..
发布时间：2021-08-20 20:46:58 其他开发

DefaultMessageListenerContainer 不从 IBM MQ 读取消息

我正在尝试创建一些使用 DefaultMessageListenerContainer 来侦听来自 IBM MQ 的消息的 Spring Boot 代码. 我可以创建 MQQueueConnectionFactory 并使用 JmsTemplate 发送和接收消息，但这是为了实现高吞吐量并且想要使用侦听器而不是轮询. 我已经将大部分代码整合到一个组件中，所以我希望我拥有所有相关的内容. ..
发布时间：2021-08-20 19:37:55 Java开发

到 TIBCO EMS 服务器的 Spring JMS 使用者会自行过期

我们构建了一个 Spring Boot 消息服务，它侦听托管在 TIBCO EMS(企业消息服务)服务器上的 JMS 队列.这是一个相当简单的应用程序，它接收 JMS 消息、执行一些数据操作并更新数据库. 问题是，有时队列中没有 JMS 使用者，并且不会处理传入的消息.但是，Spring Boot 应用程序已启动并正在运行(由 ps -ef 验证).重新启动应用程序会恢复消费者，但不幸的是， ..
发布时间：2021-08-20 19:15:46 其他开发

Spring JMS 侦听器即使出现异常也会确认

我正在使用 JMS 向我的 SQS 队列发送/接收消息，但是即使在使用 client_acknowledge 时出现异常，我也无法重新传递消息.如何实现这一目标?我尝试了一个简单的测试， @JmsListener(destination = "test-normalqueue")public void receiveNormalQueue(字符串消息){试试{logger.info("正常队列中 ..
发布时间：2021-08-20 18:49:34 Java开发

如何暂停/恢复单个 Spring JMS 消息侦听器

我的 Spring Boot JMS 应用程序正在使用来自多个 SQS 队列的消息.每个队列都需要连接到不同的外部资源以处理其消息.如果出现外部资源故障，我预计需要该资源的使用者会迅速将队列排空到 DLQ，这没什么意思. 当我的代码检测到其资源离线(例如，调用 REST 端点的通信异常)时，我需要能够独立地挂起(暂停)每个使用者的消息侦听器. 我该怎么做? 在为此搜索平台支持后， ..
发布时间：2021-08-20 18:47:25 其他开发

如何使用 Spring Boot 监听动态目的地?

我们有一个使用 Spring Boot 及其 JMS 工具的应用程序.在运行时，我们有不同的生产者在线跳转并告诉我们的应用程序要收听的主题或队列的名称.现在，我们有: @JmsListener(destination = "helloworld.q")公共无效接收(字符串消息){LOGGER.info("收到消息='{}'", message);} 当我们向 helloworld.q 主题发送 ..
发布时间：2021-08-20 18:41:20 Java开发

如何使用spring框架接收所有预取rabbitmq消息?

我正在学习如何使用 SimpleMessageListenerContainer 来接收 rabbitmq 消息.我的侦听器容器具有 prefetchCount = 1000.但是我的侦听器工作人员实现了一次只接收一条消息的 MessageListener 接口.是否有接收消息列表的接口?如果没有，我该如何接收消息列表?我不想一次处理一条消息，而是处理它们的列表，这样我就可以批量插入/更新.我还想 ..
发布时间：2021-07-02 18:42:48 Java开发

如何使用 JmsTemplate 进行手动确认并从 Rabbitmq 队列中删除消息

我正在使用带有 jmsTemplate 的 RabbitMq(带 JMS)我能够从 RabbitMq 队列使用消息，但它正在接受 AUTO 确认. 我有搜索 API，但无法找到它. 如何设置手动确认. 在下面的代码中，当消息从队列中被消耗时，我想使用该消息调用 Web 服务，并取决于来自我想从队列中删除该消息的响应.我创建了一个项目，其中使用 Listener 和其他项目，并调用 ..
发布时间：2021-07-02 18:36:11 其他开发