From b8cbcc61467d1d5cc25e1effee670abb98276336 Mon Sep 17 00:00:00 2001 From: Robert Gemmell Date: Thu, 18 Aug 2011 14:44:05 +0000 Subject: QPID-3434: Refactored 0-8..0-9-1 code paths to use same SSL configuration mechanisms as 0-10. Apply work by myself and Keith Wall git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1159255 13f79535-47bb-0310-9956-ffa450edef68 --- .../qpid/config/AMQConnectionFactoryInitialiser.java | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) (limited to 'java/perftests/src') diff --git a/java/perftests/src/main/java/org/apache/qpid/config/AMQConnectionFactoryInitialiser.java b/java/perftests/src/main/java/org/apache/qpid/config/AMQConnectionFactoryInitialiser.java index cac0064785..76fd318625 100644 --- a/java/perftests/src/main/java/org/apache/qpid/config/AMQConnectionFactoryInitialiser.java +++ b/java/perftests/src/main/java/org/apache/qpid/config/AMQConnectionFactoryInitialiser.java @@ -21,8 +21,11 @@ package org.apache.qpid.config; import org.apache.qpid.client.AMQConnectionFactory; +import org.apache.qpid.client.AMQConnectionURL; import org.apache.qpid.config.ConnectionFactoryInitialiser; import org.apache.qpid.config.ConnectorConfig; +import org.apache.qpid.jms.ConnectionURL; +import org.apache.qpid.url.URLSyntaxException; import javax.jms.ConnectionFactory; @@ -30,6 +33,15 @@ class AMQConnectionFactoryInitialiser implements ConnectionFactoryInitialiser { public ConnectionFactory getFactory(ConnectorConfig config) { - return new AMQConnectionFactory(config.getHost(), config.getPort(), "/test_path"); + try + { + final ConnectionURL connectionUrl = new AMQConnectionURL(ConnectionURL.AMQ_PROTOCOL + + "://guest:guest@/test_path?brokerlist='tcp://" + config.getHost() + ":" + config.getPort() + "'"); + return new AMQConnectionFactory(connectionUrl); + } + catch (URLSyntaxException e) + { + throw new RuntimeException("Problem building URL", e); + } } } -- cgit v1.2.1