我正在尝试使用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) {
}