运输方案未得到承认:[amqp]

Question

我试图使用AMQP与ActiveMQ,并得到以下错误

Transport scheme NOT recognized: [amqp]

这是我的代码

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
        "amqp://localhost:61616");

Connection connection = null;
try {
    connection = connectionFactory.createConnection();
    connection.start();

    Session session = connection.createSession(false,
            Session.AUTO_ACKNOWLEDGE);

    Queue queue = session.createQueue("somequeue");

    MessageProducer producer = session.createProducer(queue);

    // We will send a small text message saying 'Hello'
    TextMessage message = session.createTextMessage();
    message.setText("Publishing : New Message ");
    producer.send(message);

    connection.close();
} catch (Exception e) {

}

Answer 1

请注意,ActiveMQ中的AMQP仅在服务器中实现,而不是在JMS客户端中实现.JMS客户端实际上实现了"默认"OpenWire协议(以及JVM内部传输).

你应该使用一些其他的客户端库使用AMQP的ActiveMQ,如沟通的Apache QPID这是由ActiveMQ的建议.