Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@activemq.apache.org
Received-SPF: unknown (athena.apache.org: error in processing during lookup of
 ping.li@firemon.com)
Date: Fri, 29 Aug 2014 13:53:01 -0700 (PDT)
From: opks <ping.li@firemon.com>
To: dev@activemq.apache.org
Message-ID: <1409345581171-4685161.post@n4.nabble.com>
Subject: question related to
 "org/apache/activemq/transport/TransportFactory.java"
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit

I got the following error message: "Invalid connect parameters:
{wireFormat.host=localhost}"

After tracing the source code, I find this function in
org/apache/activemq/transport/TransportFactory.java:

The options is always not empty and this always triggers exception for
"Invalid connect parameters: ". Am I reading the code correctly?


    public Transport doConnect(URI location) throws Exception {
        try {
            Map<String, String> options = new HashMap<String,
String>(URISupport.parseParameters(location));
            if( !options.containsKey("wireFormat.host") ) {
                options.put("wireFormat.host", location.getHost());
            }
            WireFormat wf = createWireFormat(options);
            Transport transport = createTransport(location, wf);
            Transport rc = configure(transport, wf, options);
            if (!options.isEmpty()) {
                throw new IllegalArgumentException("Invalid connect
parameters: " + options);
            }
            return rc;
        } catch (URISyntaxException e) {
            throw IOExceptionSupport.create(e);
        }
    }


--
View this message in context: http://activemq.2283324.n4.nabble.com/question-related-to-org-apache-activemq-transport-TransportFactory-java-tp4685161.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.