Я создал потребительский файл ActiveMQ в Java.
Когда я пытаюсь подключиться к activemq, он показывает:
исключение в методе выполнения :: javax.jms.JMSException: не удалось создать транспорт. Причина: java.io.IOException: Транспортная схема НЕ опознана: [tcp]
Когда я запускаю тот же потребительский файл, что и отдельный файл, он работает правильно.
Но с Ant сборка его не работает.
Я включил activemq-all.jar в путь сборки. Но все равно не работает.
URL-адрес соединения: tcp: // localhost: 61616.
Спасибо
import java.util.Map;
import java.util.HashMap;
import java.util.ArrayList;
import javax.jms.Connection;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.ExceptionListener;
import javax.jms.MessageListener;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
private void createConnection(String USER, String PASSWORD, String connectionURL) throws Exception{
this.connectionFactory = new ActiveMQConnectionFactory(USER, PASSWORD, connectionURL);
// connectionURL = tcp://localhost:61616
// Create a Connection
this.connection = connectionFactory.createConnection();
connection.start();
connection.setExceptionListener(this);
// Create a Session
this.session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
}