【发布时间】:2015-03-21 13:21:23
【问题描述】:
我正在尝试将消息发布到安装在 ubuntu 12.04 上的 ActiveMQ 上的队列。
我可以毫无问题地发布到安装在 Windows 上的 ActiveMQ,但我无法在 ubuntu 上发布。如果我从控制台创建消息,我可以使用它。
当我查看 Wireshark 上的 AMQP 转储时,我看到以下消息:
“试图获取长度为 42 的无符号整数”。
客户端和服务器都在 JDK 1.6 上运行
这是我的代码:
public void addMessage(String text) throws Exception {
TextMessage msg = session.createTextMessage(text);
msg.setStringProperty("odd", "no");
msgProducer.send(msg);
}
private void init() throws Exception {
ConnectionFactoryImpl factory = new ConnectionFactoryImpl(host, port, user, password);
connection = factory.createConnection(user, password);
connection.start();
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination dest = new QueueImpl(queue);
msgProducer = session.createProducer(dest);
msgProducer.setDeliveryMode(DeliveryMode.PERSISTENT);
}
【问题讨论】:
-
您需要提供更多信息。 “不能发表”是什么意思?代理端的日志中必须有条目(可能具有更高的日志级别)或客户端中的异常/日志。您还需要指定 AMQ 版本。
-
我在日志中看不到任何条目,并且我已将日志记录级别设置为调试。我正在使用 AMQ 5.10