ACTIVEMQ-发布者订户你好世界示例

您的问题是使用者正在运行，然后立即关闭。

尝试将其添加到您的使用者中：

    consumer.setMessageListener(listner);    try {        System.in.read();    } catch (IOException e) {        e.printStackTrace();    }    connection.close();

这将一直等到您按下某个键后才停止。

要考虑的其他事项：

• 使用finally块结束
• Java命名约定鼓励将大写字母用于类的首字母