jms-topic

1热度

1回答

我建立使用的ActiveMQ和MQTT协议，我使用的独立的服务器上，其模型包含两个应用如下大设备的系统： App1的：企业应用程序从大量的接收的消息设备：设备每3分钟通过主题发布到服务器： [设备] --- MQTT协议 - > [ActiveMQ] --- Openwire协议 - > [Glassfish with EJB using MDB to subscribe topic] - >

3热度

1回答

对一个主题的JMS多次持久订阅

我现在开始了JMS一周。我使用Netbeans，maven和glassfish创建了JMS。我一个生产者和一个耐用消费品，我想另一个耐用消费品添加到同一话题（不排队）。是否有可能这样做？，因为我希望所有消费者都消费生产者发送的所有消息，无论消费者是否脱机。有什么建议吗？感谢 public class DurableReceive { @Resource(lookup = "jms/my

0热度

1回答

Jms消息确认

我有一个与java消息服务有关的问题... 问题：假设我的JMS发布者向我发送5条消息...当我收到前两条消息时，我的应用程序处理它n确认它...因此，它是从主题中删除...温我recv第3 msg bcz的一些问题我的应用程序无法处理第3条消息和dint承认...但第4和第5条消息得到处理和承认...但是我chk管理控制台我发现第三条消息也被确认... 我想知道如何分别确认每条消息。任何人有想法

2热度

1回答

一位JMS消费者停止监听活跃的mq主题，而第二位则不要

春季石英工艺每隔15分钟在我的项目中运行，即每天工作96次。这从数据库获取某些记录并将其发布到REST服务（在JBoss 7上运行）。这些记录通常在50到100个计数中。关于REST服务，有jms事件发布者将该消息发布在主题上。这个主题有两个消费者。这一进程消息，并在移动交谈第三方发送推送通知的消息（一般需要4至5秒以完成呼叫）由于它是主题对消费者接收的所有消息但是它们会根据某些属性将它们

0热度

1回答

无法发送消息到Solace JMS队列

我需要将消息推送到Solace JMS队列Webpshere，但在发送消息期间出现错误。我还增加了消息监听器大小但未解决问题。 Error: 503: Spool Over Quota. Message VPN limit exceeded Caused by: com.solacesystems.jcsmp.JCSMPErrorResponseException: 503: Spool O

1热度

1回答

骆驼路线中使用的ActiveMQ递归通配符

Apache ActiveMQ支持例如骆驼路线中的主题/队列等通配符的通配符。 The documentation显示有递归matche这样的模式的可能性： PRICE.STOCK.> 匹配 PRICE.STOCK.FR.SOUTH PRICE.STOCK.FR PRICE.STOCK.UK.NORTH.MANCHESTER 等等... 然而，在我的例子，我有以匹配类似的东西，但以特定

0热度

1回答

在异步读取消息时检查JMS类型

我的JMS中有一个队列。在发送消息到队列时，我提到JMStype为'XYZ'。在消费者端，我有一个onMessage监听器。我想知道的是以下在听者的onMessage我如何检查的消息的JMSType没有出队的消息。如果我的运行实例发现JMStype不是'XYZ'，那么它不应该做任何事情，也不应该将它从我的队列中退出。只有需要JMStype为'XYZ'的消息的实例才能将消息出队并进一步处理。感谢

0热度

1回答

JMS使用JMS调用传递消息的API

我想知道在以下情况下使用JMS是否可行。我添加了一个调用API服务的功能，它将邮件发送给客户。所以我想在我的应用程序中实现JMS，在那里我将事件或消息放入队列中，并在同一个应用程序中编写一个监听器，它将处理该消息并调用其余的API服务调用，以便将消息发送给客户。我的问题是在其他调用和我们的应用程序之间有一个JMS是很好的吗？或者我应该直接调用其余的api来发送消息给客户？

1热度

1回答

的Kaazing主题订阅

使用的Kaazing JMS演示与AMQP 1.0和ActiveMQ的 https://demo.kaazing.com/demo/jms/javascript/jms-javascript.html 注册/订阅新队列和处理它的应用服务器和从应用server.However，客户端发送消息返回到客户端[的Kaazing]订阅同一队列没有收到任何消息，有什么理由？

0热度

1回答

JMS主题订阅者重新连接

我正在使用Glassfish 3.1.2.2和OpemMQ 4.5.2（远程模式）。在我的应用程序中，有一个JMS主题的订阅者，它使用MessageListener异步接收消息。如果代理在一段时间后停止并启动，则重新启动后发布到JMS主题的消息不会被订户接收。恢复主题订户的最佳方法是什么？我试过ExceptionListener，但显然它在Glassfish上运行我的应用程序时不受支持。