-
2 votesanswersviews
JMS主题上下文查找问题
我试图在Websphere Application Server中使用JNDI查找JMS TopicConnectionFactory . 我已经在服务器中正确完成了jndi设置 . 我已在服务器中部署了我的应用程序 . 我为Sender / Reciever / Listener设计了3个java类 . 然后在服务器中部署WAR之后,我首先尝试将Receiver Code作为独立的Java应用程... -
0 votesanswersviews
ActiveMQ Redelivery警察仅用于消息容器
在这段代码中,我试图仅为特定主题中的消息设置一个重新发送警察: RedeliveryPolicy redeliveryPolicy = new RedeliveryPolicy(); emailByFolioRedeliveryPolicy.setInitialRedeliveryDelay(5000); emailByFolioRedeliveryPolicy.setRedeli... -
2 votesanswersviews
ActiveMQ中的setBackOffMultiplier(double backOffMultiplier)如何工作
我正在使用activemq编写应用程序,我正在使用重新传递策略来重新传递消息 . 我正在使用ActiveMQ的ExponentialBackOff概念 . 我的问题是这个ExponentialBackOff / setBackOffMultiplier是如何工作的 . 例如,在我的情况下,我想重新发送消息,直到消息到期时间为15分钟 . 我想尝试在15分钟内重新发送10次 . 但Exponenti... -
1 votesanswersviews
带有JMS主题的ActiveMQ - 一些消息未出列的消息
我们正在尝试使用JMS主题将ActiveMQ 5.9.0设置为消息代理,但我们在使用消息时遇到了一些问题 . 出于测试目的,我们有1个主题,1个事件生成器和1个使用者的简单配置 . 我们一个接一个地发送10条消息,但每次运行应用程序时,都不会消耗1-3条消息!其他消息被消耗并且处理得很好 . 我们可以看到我们在ActiveMQ管理控制台中发布到主题的所有消息,但它们从未到达消费者,即使我们重新申请... -
1 votesanswersviews
MQTT连接到ActiveMQ TOPIC在WSO2 CEP的事件接收器中花费了大量时间
Update 在碳分析的共同项目MQTTAdapterListener的源代码中link run() 将睡眠线程,我相信这就是MQTT连接需要这么长时间的原因 . @Override public void run() { while (!connectionSucceeded) { try { MQTTEventAdapterConstants.i...