jms

0热度

1回答

我有我的JBoss 5.1的Web应用程序兼容验证码： public class SendNotification { @Resource(mappedName="queue/QueueNotification") private Queue destination; @Resource(mappedName="ConnectionFactory") pr

0热度

1回答

如何从春监听

得到消息ID我有以下代码： @JmsListener(destination = "myQueue", containerFactory = "myFactory") public void receiveMessage(MyClass message) { service.process(message); } 现在，我想获得的JMS消息ID。我知道我可以重写MappingJa

0热度

1回答

JMS QPID队列与主题

当谈到JMS队列/主题时，我感到困惑。我想要的是消息应该发送给每个用户，我希望订阅者在活动时从非活动时间接收消息。但是，我无法控制订阅者是否拥有持久订阅。有没有办法建立一个持续队列，并设置它，以便每个用户都会收到相同的消息？以及如何设置这个使用弹簧配置非常感谢。

0热度

1回答

JEE 6 JMS示例

我正在尝试使用JMS和glasfish 3做一个简单消息发送者的虚拟示例。我创建了一个无状态bean，并且已在glasfish 3中定义了jsm/factory和jms/queue。是以下一个： package converter.ejb.impl; import javax.annotation.Resource; import javax.ejb.Stateless; import j

0热度

1回答

限制在ActiveMq主题中发送消息的订户的最大数量

假设有一个ActiveMq实例，并且有100个客户端正在监听主题。当在主题中发布新消息时，是否可以限制接收它的订阅者数量（仅示例10）？如果现在有其他消息传递组件能够做到这一点，或者存在解决方案/合并最佳实践？

0热度

1回答

Activemq - 通过不稳定连接发送大文件的最佳协议

使用案例：需要在队列上从一台服务器向另一台发送大型文件（100 MB的倍数）。目前，我正在使用Activemq Artemis服务器发送大文件作为ByteMessage，通过tcp协议输入流的帮助，重新尝试间隔为-1，无限次失败重试。这里的主要问题是消费者终端连接将大部分是不稳定的，即由于移动性原因断开与网络的连接。因此，当在队列中发送文件时，如果连接断开并且重新连接的代理应该从事务中断的地方

-1热度

1回答

Java ActiveMQ：如何发送消息从客户端到服务器

我见过很多关于如何从服务器/生产者发送消息到客户端的代码和示例，但我失去了如何从客户端发送消息到服务器。它是否遵循相同的格式？例如，假设我的服务器有5个主题：A，B，C，D，E。我的客户端只收听主题C. 所以我的服务器创建一个队列并发送消息给订阅者/客户端。我的客户端获取主题C上的消息。它执行一些计算，并且我想要将消息发回给发布者（例如int）。什么是必需的步骤？我是否需要为制作人设定一个目

1热度

1回答

Activemq PooledConnectionFactory中到期超时的含义是什么？

我不明白在Activemq PooledConnectionFactory中应用expiryTimeout字段。 java doc表示“允许连接过期，而不考虑负载或空闲时间，这对于故障转移强制从池中重新连接，重新建立负载平衡或使用主后期恢复很有用”。请给我举一个例子，其中expiryTimeout场效应真实场景。

0热度

1回答

ActiveMQ将现有的队列转换为CompositeQueue

我会尽我所能解释这一点。正如我存储我的数据，我从我的ActiveMQ的队列接收在若干不同的位置，我已决定建立一个复合队列，所以我可以分别处理每个位置的数据。我遇到的问题是，我目前拥有的队列在生产环境中。看起来，将名为A的队列更改为也称为A的组合队列A具有名为B和C的虚拟目标，这会导致我失去现有队列中的所有数据。它不会启动前面的消息。目前，我正在创建一个名称不同的新CompositeQueue，

0热度

1回答

Tibjms javax.jms.JMSException：服务器连接未知

我正在使用Tibjms jar for JMS连接，它在正常情况下工作正常，但是在连接到jms提供程序的连接丢失并返回时出现问题。要重现此问题，我执行了以下步骤 - 连接到Intranet并启动服务器。工作正常。从内网断开。它开始尝试重新连接服务器。精细。再次连接到内部网。它抛出未知的异常，并再次连接。问题。所以，我的问题是“的javax.jms.JMSException：通过连接服务器未知