Patch for Qpid-239 applied. BlockingSocketTransport instantiated directly.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@493064 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 7 insertions, 2 deletions

diff --git a/qpid/dotnet/Qpid.Client/Client/AMQConnection.cs b/qpid/dotnet/Qpid.Client/Client/AMQConnection.cs
index 64a30c1981..c620412cab 100644
--- a/qpid/dotnet/Qpid.Client/Client/AMQConnection.cs
+++ b/qpid/dotnet/Qpid.Client/Client/AMQConnection.cs
@@ -29,6 +29,7 @@ using Qpid.Client.Protocol;
 using Qpid.Client.qms;
 using Qpid.Client.State;
 using Qpid.Client.Transport;
+using Qpid.Client.Transport.Socket.Blocking;
 using Qpid.Collections;
 using Qpid.Framing;
 using Qpid.Messaging;
@@ -177,7 +178,7 @@ namespace Qpid.Client
             }
         }
 
-        private ITransport LoadTransportFromAssembly(string host, int port, String assemblyName, String transportType)
+        /*private ITransport LoadTransportFromAssembly(string host, int port, String assemblyName, String transportType)
         {
             //Assembly assembly = Assembly.LoadFrom(assemblyName);
             Assembly assembly = Assembly.Load(assemblyName);
@@ -205,7 +206,7 @@ namespace Qpid.Client
             _log.Info("transport = " + result);
 
             return result;
-        }
+        }*/
 
         public void Disconnect()
         {
@@ -688,12 +689,16 @@ namespace Qpid.Client
                 _protocolListener = new AMQProtocolListener(this, _stateManager);
                 _protocolListener.AddFrameListener(_stateManager);
 
+                /*
                 // Currently there is only one transport option - BlockingSocket.
                 String assemblyName = "Qpid.Client.Transport.Socket.Blocking.dll";
                 String transportType = "Qpid.Client.Transport.Socket.Blocking.BlockingSocketTransport";
 
                 // Load the transport assembly dynamically.
                 _transport = LoadTransportFromAssembly(brokerDetail.getHost(), brokerDetail.getPort(), assemblyName, transportType);
+                */
+
+                _transport = new BlockingSocketTransport(brokerDetail.getHost(), brokerDetail.getPort(), this);
                 
                 // Connect.
                 _transport.Open();