客户端工具MQTT.fx上定义的主题未使用ActiveMQ Artemis消息
我的用例保证使用发布-订阅模型，因此我使用在我的Spring Boot客户端中定义的主题。我已经使用工具MQTT.fx和两个Spring Boot客户端进行了测试。两个Spring Boot客户端能够相互通信，但MQTT.fx客户端只连接到代理，不生成或使用消息。两个Spring Boot客户端都连接到端口61616，而MQTT.fx客户端连接到端口1883。 对于我的项目，我需要让MQTT
..
spring-jms相关内容
如何在Spring JMS侦听器中从JMS消息中获取自定义属性
我知道您可以使用如下内容访问Spring JMS侦听器中的标准标头： public void receive(String in, @Header(JmsHeaders.MESSAGE_ID) String messageId) 是否有用于访问自定义属性的类似批注？ 推荐答案 完全相同. 使用@Header注释(请参阅方法listen) 或 使用封装消息头
..
从 Camel Route 向 Weblogic JMS 队列发送消息
我正在尝试通过 Camel Route 将消息放在 Weblogic JMS 中的队列上. 我的目标是最终配置一个 Route 来使用 jms 队列中的消息，我将来自早期 Route 的数据发布到该队列. 这是我的配置:
..
将 Spring 的 JndiObjectFactoryBean 转换为 Solace-MQ JMS 的 ConnectionFactory 时出错
我有一个使用 JNDI 和 Spring 的 Camel Context 的良好工作 XML 配置 后来 Solace.JndiObjectFactoryBean 被用作 connectionFactory
..
如何使用 JmsTemplate 提供手动确认并从 Rabbitmq 队列中删除消息
我正在使用带有 jmsTemplate 的 RabbitMq(带 JMS)我能够从 RabbitMq 队列中使用消息，但它需要自动确认. 我有它的搜索 API，但无法找到它. 如何设置手动确认. 在下面的代码中，当从队列中使用消息时，我想使用该消息调用 Web 服务，并取决于来自我想从队列中删除该消息的响应.我创建了一个项目，其中我正在使用侦听器和其他项目调用从队列中读取消息
..
Spring 是否真的用 REQUIRES_NEW 启动了一个新事务?
我的 spring (4.1.1) 应用程序部署在 JBoss-6.10-final 实例上，因此它使用基于容器的事务管理器和数据源.对于消息传递，我使用 TIBCO EMS 8.1 和 XA 队列连接工厂设置.Java 版本为 1.8.0_20.所有这些都在我的 Ubuntu 14.04 笔记本电脑上运行. 我需要通过 JMS 发送请求，然后等待回复.我正在调用的 bean 将事务传播设置
..
使用来自 MQ 的消息并在 Spring JMS 中合并
我使用 spring + MQ + Websphere 应用服务器. 我想异步使用来自 MQ 的消息并将这些消息组合起来，以便在每次提交中轻松将 N 个实体持久化到数据库中.(没有强调我的目标 Oracle 数据库太多提交) 我使用 DefaultMessageListenerContainer 并使 onMessage 方法同步以添加消息(直到批量大小)，并创建线程以等待条件满足(时
..
Springframework.jms.support.JmsAccessor 没有 createConnection(userid,pwd) 方法
我正在编写示例 Apache Camel (2.16.2) 应用程序，该应用程序以客户端模式连接到 IBM MQ 队列管理器.Apache Camel 在底层使用 Spring JMS 连接到 JMS 提供者.我看到 Spring JmsAccessor 没有采用 UserId 和 Password 的 createConnection() 方法.它只有不带任何参数的 createConnecti
..
完整的异步 Web 服务通信 - 发送方和接收方无法同时使用
两个系统通过集成(使用 apache-camel)相互通信.假设系统 A 需要向系统 B 提交一个请求，系统 B 已经公开了一个 Web 服务来接收数据，并且集成正在根据系统 B 的 Web 服务转换数据. 在上面的场景中，A 和 B 必须同时可用，A 将不得不等待 B 的响应.我需要通过将队列放在集成层和异步通信来消除这种依赖关系.例如:
..
如何发送文本消息而不是字节消息
我正在使用与我的 JMS 队列对话的 blueprint.xml 构建一条骆驼路线.我一直收到神秘错误，其中充当队列使用者的 Spring Boot 应用程序将我的 xml 作为字节消息而不是文本消息发送，而 Spring 使用者对此感到窒息. 这是两条消息，其中一条有效: 2016-06-24 07:08:22,671 |信息 |发送消息:ActiveMQBytesMessage {co
..
从骆驼路由向 Weblogic JMS 队列发送消息
我正在尝试通过 Camel Route 将消息放入 Weblogic JMS 中的队列中. 我的目标是最终配置一个 Route 来使用 jms 队列中的消息，我将之前的 Route 中的数据发布到该队列. 这是我的配置: weblogic.jndi.WLInitialCont
..
将 Spring 的 JndiObjectFactoryBean 转换为用于 Solace-MQ JMS 的 ConnectionFactory 时出错
我有一个很好的工作 XML 配置，用于使用 JNDI 和 Spring 的 Camel 上下文 后来 Solace.JndiObjectFactoryBean 被用作 connectionFactory
..
如何使用 MQQueueConnectionFactory 设置 ApplicationIdData?
试图找出使用 JMS 设置 ApplicationIdData 的骆驼/Spring 配置. 我知道如下的java方法，我使用下面的设置MQOO_SET_IDENTITY_CONTEXT int putOptions = MQConstants.MQPMO_SET_IDENTITY_CONTEXT;pmo.options = putOptions; 然后我将 applicationIdD
..
Spring JMS 生产者和消费者交互
如何确定消费者是否已经收到了来自生产者的消息，或者如何通知生产者该消息已经在 Spring JMS 中发送/消费了? 解决方案 you need to use request/reply by using org.springframework.jms.core.JmsTemplate.sendAndReceive(...) on生产者端和消费者端在容器中设置的 MessageListen
..
Java:如何从 Spring 的 DMLC 取消订阅持久订阅者?
在普通的 JMS 中，我们可以这样做: session.unsubscribe("持久订阅的名称");但我们如何通过 DMLC 做到这一点?在其中找不到用于此目的的任何特定方法. 解决方案 据我所知，没有 Spring 特定的方式向 MQ 服务器发送“取消订阅"命令，但是您始终可以选择获取底层 JMS通过扩展 DefaultMessageListenerContainer 类并调用 get
..
在我的应用程序中显示侦听器及其状态
在我的 spring 应用程序中，我想显示侦听器及其运行状态.我正在使用 @JmsListener 注释.我从这个网址得到了提示 - 配置多个 DefaultJmslistenercontainerfactory 但是，我也面临着同样的挑战，我确实获得了听众的状态，但没有获得听众的 ID.此外，我想使用相同的 id 启动/停止侦听器 如何获取监听器的 id? 解决方案 目前没有
..
@JmsListener 突然停止消费消息，没有任何错误或异常
我有一个在生产中运行的应用程序，它使用 ActiveMQ 上的虚拟主题，例如 @JmsListener(destination = "Consumer.example-consumer.VirtualTopic.${spring.activemq.example.topic}")公共无效消费主题(字符串消息){...} 在 application.properties 中的位置 spring
..
Spring jms 无法连接到 Websphere MQ - 资源异常
问题: 在尝试连接到 websphere mq 以使用 spring 获取 jms 消息的运行时出现资源异常.我只是无法确定我错过了什么? 说明:尝试在此处设置示例.用于 Websphere MQ 的 Spring MDP 激活规范. http://stackoverflow.com/questions/14523572/spring-jms-and-websphere-mq M
..
消费客户端关闭后，ActiveMQ Artemis 队列被删除
我是 JMS 和 ActiveMQ Artemis 的新手，我遇到了以下问题.我通常将来自应用程序生产者的消息放入 requests 队列中: 从其他应用程序消费者那里之后，我尝试使用该消息.这样做没有问题. 但是当我关闭应用程序使用者时，request 队列被无故删除. 我的应用程序使用者是使用 Spring Boot 构建的，如下所示: @SpringBootApplica
..
ActiveMQ 消息消费延迟大
我们有一个经纪人网络，由不同服务器上的三个经纪人组成.网络连接器配置如下:
..