【问题标题】:Cannot publish to Queue on ActiveMQ on Linux无法在 Linux 上发布到 ActiveMQ 上的队列
【发布时间】: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

标签: java linux activemq


【解决方案1】:

通过将我在 Windows (5.10.0) 上的 ActiveMQ 工作版本复制到我的 linux 服务器(安装了 5.10.1 版本)解决了这个问题,并且它工作正常。我仍然不知道原来的问题是什么......

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2023-02-12
    • 2019-08-22
    • 2014-07-25
    • 2014-03-29
    • 1970-01-01
    • 2015-02-19
    • 1970-01-01
    相关资源
    最近更新 更多