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