java - ActiveMQ Java消费者抛出传输方案无法识别: [tcp]

Question

我已经用 Java 创建了 ActiveMQ 使用者文件。当我尝试连接到 ActiveMQ 时，它显示:

exception in run method::javax.jms.JMSException: Could not create Transport. Reason: java.io.IOException: Transport scheme NOT recognized: [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);
    }

Answer 1

此问题是由于 ANT 构 build 成的。我在创建目标 jar 时删除了 META-INF <zipfileset src="activemq-all.jar" excludes="META-INF/**" />

然后我将其替换为单独的下面提到的命令: <zipfileset src="activemq-all.jar">