From b4f74c44b73e0e3ca21a0c39487135bdab12e4af Mon Sep 17 00:00:00 2001 From: Robert Gemmell Date: Thu, 14 Jul 2011 08:15:31 +0000 Subject: QPID-3345: restore/add ability to use sys props to select the NetworkTransport used to make/accept connections Applied patch by Keith Wall git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1146594 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpid/client/AMQConnectionDelegate_8_0.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'java/client') diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_8_0.java b/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_8_0.java index 22d1936463..0cd1d49224 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_8_0.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_8_0.java @@ -52,7 +52,7 @@ import org.apache.qpid.ssl.SSLContextFactory; import org.apache.qpid.transport.ConnectionSettings; import org.apache.qpid.transport.network.NetworkConnection; import org.apache.qpid.transport.network.OutgoingNetworkTransport; -import org.apache.qpid.transport.network.mina.MinaNetworkTransport; +import org.apache.qpid.transport.network.Transport; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -105,7 +105,7 @@ public class AMQConnectionDelegate_8_0 implements AMQConnectionDelegate sslFactory = new SSLContextFactory(sslConfig.getKeystorePath(), sslConfig.getKeystorePassword(), sslConfig.getCertType()); } - OutgoingNetworkTransport transport = new MinaNetworkTransport(); + OutgoingNetworkTransport transport = Transport.getOutgoingTransportInstance(getProtocolVersion()); NetworkConnection network = transport.connect(settings, _conn._protocolHandler, sslFactory); _conn._protocolHandler.setNetworkConnection(network); _conn._protocolHandler.getProtocolSession().init(); -- cgit v1.2.1