7得票1回答
无法让ActiveMQ重新发送我的消息

我有一个用Java编写的单线程ActiveMQ消费者。我想要做的就是从队列中接收()一条消息,试图将其发送到Web服务,并在成功时确认()它。如果Web服务调用失败,我希望消息留在队列中,在一段时间后重新发送。 大体上来说,它已经实现了,除了重新发送部分:每次重新启动我的消费者时,它会得到每...

8得票2回答
ActiveMQ独立服务器部署或嵌入Spring Webapp中

我需要设计一个应用程序来通知/发布其子系统发送电子邮件。我计划使用JMS发布/订阅(主题)消息来实现这一目的。 目前看,大约有20到30个订阅者,并且每天发布的消息数量将在30000到50000之间。 我计划使用ActiveMQ JMS+Spring 3+Tomcat 6实现。 以下是一...

18得票1回答
Spring Websocket 是一个功能齐全的代理服务器,支持 Stomp 协议,并具备故障转移功能。

我有这些 Spring 和完整功能的 Stomp 代理(ActiveMQ)的配置:@Configuration @EnableWebSocketMessageBroker public class WebsocketConfig extends AbstractWebSocketMessage...

10得票2回答
修复PAHO JS + Activemq中的AMQJS0008I套接字关闭错误

有时我在onConnectionLost上经常收到AMQJS0008I Socket closed错误。我正在使用最新的Activemq版本。这是因为接收到的一些格式错误的消息吗?因为有时它可以正常处理所有消息,而有时则会在其中间显示出错信息。

8得票1回答
ActiveMQ Web控制台无法与嵌入式代理一起使用。

我有一个完全通过Java代码配置的嵌入式代理(没有可部署的XML文件)。当我将浏览器指向Web控制台时,只会得到404错误,并且lsof显示在8161端口上没有任何内容正在侦听。是否可以仅使用Java代码使用Web控制台?我可以使用ActiveMQ附带的Web服务器,并且我可以使用8161端口。

10得票1回答
从JMS返回字符串

我正在编写一个独立的主方法,它调用生产者(将数据推送到队列中),然后调用一个消费者来持续监听此主题。 我已经重写了onMessage方法,并能够从队列中获取消息,但无法将消息返回给调用方法。 实际上,我想要将消息传递到浏览器,因此想测试是否至少可以在主方法中传递它。 请帮忙;class ...

12得票4回答
Activemq无法在我的Ubuntu虚拟机上启动

我试图在我的Ubuntu虚拟机上运行ActiveMQ,但始终无法启动。我尝试了下载二进制文件和源代码,但都失败了。目前,我已经下载了源代码,并运行了"mvn clean install -Dmaven.test.skip=true"命令,Maven报告安装成功。然后我在.m2文件夹中搜索到ap...

7得票1回答
ActiveMQ连接超时问题

我有以下问题: 我正在尝试使用下面的代码连接到一个现在已经停止运行的ActiveMQ代理: connectionFactory = new ActiveMQConnectionFactory(this.url + "?timeout=2000"); connection = connecti...

7得票1回答
DefaultMessageListenerContainer未能接收到消息。

我有一个如下配置的DefaultMessageListenerContainer: DefaultMessageListenerContainer container = new DefaultMessageListenerContainer(); container.setConcurre...

10得票3回答
如何在使用Stomp和ActiveMQ(以及Perl)时使用事务?

我正在尝试使用ActiveMQ替换一些定制的消息队列,并且需要使用Perl从中频繁地发送和接收消息。ActiveMQ提供了一个Stomp接口,而Perl则有Net::Stomp,看起来这应该是可行的,但实际上不是这样。 即使我发送一个BEGIN帧到Stomp,使用SEND发送的消息也会立即发布...