Author: rgodfrey
Date: Tue Feb 10 16:23:27 2015
New Revision: 1658752
URL: http://svn.apache.org/r1658752
Log:
QPID-6352 : Always check TCP transports without looking for service loader
Modified:
qpid/trunk/qpid/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Connection.java
Modified:
qpid/trunk/qpid/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Connection.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Connection.java?rev=1658752&r1=1658751&r2=1658752&view=diff
==============================================================================
---
qpid/trunk/qpid/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Connection.java
(original)
+++
qpid/trunk/qpid/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Connection.java
Tue Feb 10 16:23:27 2015
@@ -291,6 +291,12 @@ public class Connection implements Excep
private TransportProvider getTransportProvider(final String protocol)
throws ConnectionException
{
+ TCPTransportProviderFactory tcpTransportProviderFactory = new
TCPTransportProviderFactory();
+
if(tcpTransportProviderFactory.getSupportedTransports().contains(protocol))
+ {
+ return tcpTransportProviderFactory.getProvider(protocol);
+ }
+
ClassLoader classLoader =
Thread.currentThread().getContextClassLoader();
ServiceLoader<TransportProviderFactory> providerFactories =
ServiceLoader.load(TransportProviderFactory.class, classLoader);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
