Клиент Java ActiveMQ выбрасывает Транспортную схему НЕ распознается: [tcp] - PullRequest
0 голосов
/ 27 мая 2019

Я создал потребительский файл 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);
    }

1 Ответ

0 голосов
/ 28 мая 2019

Эта проблема связана со сборкой ANT. Я удалил META-INF при создании банки назначения <zipfileset src="activemq-all.jar" excludes="META-INF/**" />

тогда я заменил его одной только нижеприведенной командой: <zipfileset src="activemq-all.jar">

...