5

ActiveMQ で AMQP を使用しようとすると、次のエラーが発生します

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) {

}
4

1 に答える 1

10

ActiveMQ の AMQP はサーバーにのみ実装され、JMS クライアントには実装されないことに注意してください。JMS クライアントは、実際には「デフォルト」の OpenWire プロトコル (および JVM 内トランスポート) を実装します。

ActiveMQで推奨されているApache QPIDなど、AMQP を使用して ActiveMQ と通信するには、他のクライアント ライブラリを使用する必要があります。

于 2013-04-03T13:58:44.690 に答える