Merged revisions 537015-537026 via svnmerge from

https://svn.apache.org/repos/asf/incubator/qpid/branches/M2

........
  r537015 | tomasr | 2007-05-10 17:16:49 -0500 (Thu, 10 May 2007) | 1 line
  
  QPID-435: Fix HeadersExchangeTest
........
  r537019 | tomasr | 2007-05-10 17:25:01 -0500 (Thu, 10 May 2007) | 1 line
  
  QPID-441 Fix handling of bounced messages
........
  r537026 | tomasr | 2007-05-10 17:46:46 -0500 (Thu, 10 May 2007) | 1 line
  
  QPID-398 SSL support for .NET client
........


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

1 files changed, 4 insertions, 4 deletions

diff --git a/dotnet/Qpid.Client/Client/AMQConnection.cs b/dotnet/Qpid.Client/Client/AMQConnection.cs
index a59670ef5a..da8498f938 100644
--- a/dotnet/Qpid.Client/Client/AMQConnection.cs
+++ b/dotnet/Qpid.Client/Client/AMQConnection.cs
@@ -672,9 +672,9 @@ namespace Qpid.Client
             }
         }
 
-        public bool AttemptReconnection(String host, int port, bool useSSL)
+        public bool AttemptReconnection(String host, int port, SslOptions sslConfig)
         {
-            IBrokerInfo bd = new AmqBrokerInfo("amqp", host, port, useSSL);
+            IBrokerInfo bd = new AmqBrokerInfo("amqp", host, port, sslConfig);
 
             _failoverPolicy.setBroker(bd);
 
@@ -708,10 +708,10 @@ namespace Qpid.Client
                 _transport = LoadTransportFromAssembly(brokerDetail.getHost(), brokerDetail.getPort(), assemblyName, transportType);
                 */
 
-                _transport = new BlockingSocketTransport(brokerDetail.Host, brokerDetail.Port, this);
+                _transport = new BlockingSocketTransport();
                 
                 // Connect.
-                _transport.Open();                
+                _transport.Connect(brokerDetail, this);                
                 _protocolWriter = new ProtocolWriter(_transport.ProtocolWriter, _protocolListener);
                 _protocolSession = new AMQProtocolSession(_transport.ProtocolWriter, _transport, this);
                 _protocolListener.ProtocolSession = _protocolSession;