我是WSO2 ESB中的新手，我在创建扩展WSO2 WSO2类的自定义消息处理器时遇到了以下问题。因此，为了实现我的自定义消息处理器，我使用这个pom.xml文件创建了一个Maven项目(它应该适合构建自定义消息处理器的要求)：
<project xmlns="http://maven.apache.org它工作得很好，但是当消息处理器初始化时，这些方法只执行一次。我需要知道每次从transferFromMessageStore消息存储中检索元素时所执行的方法是什么，因
浏览 3提问于2017-07-21得票数 1
我遇到了一种情况，如果我从应用程序中动态调用我的消费者，它就会与下面的代码一起工作。如何从不同的应用程序接收此消息？null) { } }我使用的是同一个artemis，如果我检查控制台，消费者和生产者显示，但消息总是为空的TextMessage messageReceived = (TextMessage) messageReceived，如果我使用MessageConsumer</e
浏览 16提问于2022-03-24得票数 -1
message-selector> destinationInstance IN(a', 'b','c')</message-selector>.的ejb-jar.xml我试过这个。它有效吗..。Session.AUTO_ACKNOWLEDGE);
Queue queue = session
浏览 2提问于2016-08-10得票数 1
1回答
据我所了解，我可以让一些消息生成器将生成的消息放入队列中，然后有一些使用消息的。每条消息都可以由单个MessageConsumer.来使用。现在我的疑问是：MessageConsumer使用特定MessageProducer插入队列的消息( MessageConsumer和MessageProducer)之间有1到1的关系，或者MessageProducer放置了与特定MessageConsumer相关的id，必须读取它放入队列的<e
浏览 1提问于2015-03-05得票数 0
回答已采纳
1回答
嗨，我遇到了两种从ActiveMQ代理接收消息的方法：(下面提到的所有类都在javax.jmx package中)2)为MessageListener注册一个MessageConsumer，侦听器有一个onMessage()
请问这两种方式下究竟发生了什么？
浏览 3提问于2013-11-15得票数 3
回答已采纳
7.0.4
await Task.Delay(1000, stoppingToken); }}当我创建第二个控制台应用程序来只托管
浏览 10提问于2022-06-27得票数 1
回答已采纳
以下是我的消费者： // Getting JMS connectionGetting the queue 'TESTQUEUE'
// MessageConsumeris used for receiving (con
浏览 2提问于2012-06-21得票数 0
回答已采纳
我必须接收消息1)所有的消息(2)只在输入=‘液体’的地方。我创造了两个消费者 Queuesession.createBrowser(queue); MessageConsumerconsumer = sessi
浏览 0提问于2019-04-18得票数 0
回答已采纳
Brocker C++，客户端java jms 向一个主题发送消息，然后在此主题上创建一个消费者，这是正确的吗？然后在相同的会话和主题上创建消费者(topicSend等同于tempTopic MessageConsumer messageConsumer = session.createConsumer(tempTopic
浏览 30提问于2020-12-01得票数 1
回答已采纳
我正在努力在java中接收消息，我为c#找到了一个(在我看来)很好的解决方案。我在构造函数中传递了一个对方法的引用，它将被保存，稍后如果收到消息，我可以直接从父类调用这个方法。
浏览 2提问于2018-08-09得票数 1
回答已采纳
这个类将拦截和处理传入的消息(细节并不重要，但它使用的是activemq库)。这个消费者类的大纲是 ...runConsumer();}
其中，runConsumer()设置连接并开始侦听，并在接收到消息时调用我的问题是:使用这段代码的人每个人都有自己处理不同消息的方法。我如何保持MessageConsumer通用，但提
浏览 4提问于2010-11-10得票数 4
回答已采纳
1回答
我有一个关于JMS主题的耐用消费者。我设置了客户端ID，可以看到它作为持久消费者列在队列中。destination = session.createTopic("beacons");
messageConsumer或者，这是否会告诉队列，当您重新连接时，您不再需要传递消息？
浏览 2提问于2011-04-30得票数 2
1回答
未使用消息服务总线队列的使用者
、、、、
但由于某些原因，我不能使用该消息。消息生产者代码控制器： [HttpGet] public async Task SendUsingAzureServiceBusQeueservices.AddMassTransitHostedService(true); } 消费者代码消费者类： public class M
浏览 26提问于2021-09-21得票数 0
回答已采纳
这些消费者使用MessageListener以异步方式收集消息。当一个消费者关闭时，我也想关闭用来创建这个消费者的会话，但是我不能访问用于创建我将要关闭的特定消费者的会话(这个方法不存在于消费者的"MessageConsumer“对象中)。有没有办法访问用于创建使用MessageListener的特定“使用者”(MessageConsumer对象)的“会话”？当使用MessageListerner的消费者关闭会话时，是否有其
浏览 0提问于2021-01-16得票数 0
大家好，我无法使用active mq接收异步消息，下面的代码是我用于发布消息和订阅消息。connectionFactory.createTopicConnection(); connection.start(); e.printStackTrace(); }
浏览 0提问于2012-09-28得票数 1
，但是每当我一个接一个地运行它们(所以只运行整个测试类)，那么第二个就失败了，--消费者做的事情没有收到任何消息。messageConsumer;
说：
通常建议将该规则作为@ClassRule使用，以避免在测试之间启动/停止
浏览 1提问于2017-11-15得票数 1
回答已采纳
1回答
在JMS侦听器容器上调用关机后，它正在等待消息侦听器调用者被关闭。我们在作业完成后的作业事件侦听器中调用此关闭，并且请求队列中没有要使用的消息，因此不确定这些消息侦听器为什么不关闭。
浏览 0提问于2021-05-12得票数 0
回答已采纳
1回答
对于具有一个主题和两个持久订阅者的JMS pub/sub，在大多数情况下，当消息被发送到主题时，我们希望这两个订阅者都使用该消息。
但在特定的场景中，我们可能希望消息只由特定的订阅者使用。
浏览 3提问于2021-04-14得票数 0
我读到过有很多种方法来处理JMS(Java消息传递服务)消息，MDB(消息驱动Bean)只是其中之一。那么，除了MDB之外，Java中还存在哪些其他可能性来编程消息使用者呢？
浏览 2提问于2019-12-04得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
