- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在使用 XMS 7.5 客户端访问 IBM MQ,想了解有关 MessageListener 的一件事。当队列中存在多条消息时,
代码如下:
private XMSFactoryFactory xMSFactoryFactory;
private IConnectionFactory connectionFactory;
private IConnection connectionWMQ;
private ISession sessionWMQ;
private IDestination destination;
private IMessageConsumer messageConsumer;
xMSFactoryFactory= XMSFactoryFactory.GetInstance(XMSC.CT_WMQ);
connectionFactory = _xMSFactoryFactory.CreateConnectionFactory();
// Set queue manager name, set server names, channel, use
// XMSC.WMQ_CM_CLIENT as WMQ_CONNECTION_MODE
connectionWMQ = _connectionFactory.CreateConnection();
sessionWMQ = _connectionWMQ.CreateSession(true, AcknowledgeMode.SessionTransacted);
destination = sessionWMQ.CreateQueue(_queueSettings.QueueName);
messageConsumer = sessionWMQ.CreateConsumer(_destination);
messageConsumer.MessageListener = new MessageListener(ProcessNewMessage)
最佳答案
消息一次一个地传递给消费者,消费者是否正在调用 receive()
或是否已设置消息监听器来接收消息并不重要。
如果是消息监听器,MQ 将等待 OnMessage
(在您的情况下是 ProcessNewMessage
)方法返回,然后再传送下一条合适的消息。
关于c# - MessageListener,会不会获取并发消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/31813384/
我正在使用 XMS 7.5 客户端访问 IBM MQ,想了解有关 MessageListener 的一件事。当队列中存在多条消息时, 相关的 MessageListener 方法(即下面代码中的 Pr
this question的答案|解释如何将原型(prototype)范围与 一起使用当监听器不是线程安全的时,在 Spring AMQP 中。 另一位用户询问(在评论中)如何仅使用 Java 配置
如何对实现 spring-kafka MessageListener 接口(interface)的类进行单元测试?我有一个监听器类,我正在使用 onMessage 函数手动监听主题。这个函数很简单,就
我正在尝试使用 JMS 实现在 #Solace Appliance 上发送/接收消息。 我正在使用 SolConnectionFactoryImpl 工厂来创建连接。一切看起来都不错,但是当我尝试将
我正在使用 ActiveMQ。我的消费者代码是从 main 方法调用的。一旦主类终止,我希望 JMSMessageListener 已在队列中注册,并且每当“TestTopic”上有消息时,将调用 o
有没有办法在 MessageListener 中注入(inject)服务? @Autowired @Qualifier("myServices") MyServices myService
订阅附近的服务总是声明订阅成功但 MessageListener 从未调用过: 主 Activity .java SubscribeOptions options = new SubscribeOpt
我使用 Spring Boot 2.2,需要通过 JMS 接收消息。 我看到我们可以使用注释 @Component public class JMSReceiver { @JmsListene
我使用 Spring Boot 2.2,需要通过 JMS 接收消息。 我看到我们可以使用注释 @Component public class JMSReceiver { @JmsListene
我正在测试使用 Camel 和 ActiveMQ 的 JMS 请求/回复的示例。当camel为你创建监听器时,我可以让这个例子工作。即。 from("direct:entryPoint").inOut
我有一个 spring 应用程序,我想使用 JMS Message Groups处理特定 block 中的 JMS 消息(以及相同的事务等)。基本上说我有 5 个相关事件,我有一个 JMSTempla
我正在尝试使用 Nearby API 将来 self 的 Eddystone Beacon (micro:bit) 的 Beacon 消息发送到我的 Android 应用程序.我从文档中复制了所有代码
我已经实现了 Oracle Advanced Queue,并且正在编写一个监听器程序。以下是我的示例: package com.myprog; import java.io.File; import
我一直在使用 JMS 和 ActiveMQ。一切都在创造奇迹。我没有使用 spring,我也不会。 javax.jms.MessageListener 接口(interface)只有一个方法,onMe
我有一个使用 Spring 框架的 Java 应用程序。它是一个监听器应用程序,可以非常快速地使用线程从某个源异步获取消息并将其保存到数据库中。 我正在使用 ExecutorService,它在 Se
如何确保有两个监听器容器: 接收来自不同主题的消息。线程安全吗? 正如您所看到的,它们使
我正在尝试使用 spring amqp 来使用 rabbitmq,下面是我的配置。 这是一个简单的消息监听器类, import org.springframework.amqp
如果我为 MessageConsumer 设置一个 MessageListener 对象,然后对该消费者调用 receive(),会发生什么?提供者会将消息交给 receive(),还是在消息被 Me
使用 spring 部署应用程序后如何启动 ActiveMQ messageListener? 下面给出了我的 xml 文件, -->
当我在我的队列 MessageConsumer 对象上设置一个 messageListener 时,到底发生了什么。 MessageConsumer 对象是否在后台进行某种轮询,或者这是 JMS 服务
我是一名优秀的程序员,十分优秀!