diff options
Diffstat (limited to 'trunk/qpid/dotnet/client-010/client/client/Client.cs')
| -rw-r--r-- | trunk/qpid/dotnet/client-010/client/client/Client.cs | 170 |
1 files changed, 0 insertions, 170 deletions
diff --git a/trunk/qpid/dotnet/client-010/client/client/Client.cs b/trunk/qpid/dotnet/client-010/client/client/Client.cs deleted file mode 100644 index 864cf65186..0000000000 --- a/trunk/qpid/dotnet/client-010/client/client/Client.cs +++ /dev/null @@ -1,170 +0,0 @@ -/* -* Licensed to the Apache Software Foundation (ASF) under one -* or more contributor license agreements. See the NOTICE file -* distributed with this work for additional information -* regarding copyright ownership. The ASF licenses this file -* to you under the Apache License, Version 2.0 (the -* "License"); you may not use this file except in compliance -* with the License. You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, -* software distributed under the License is distributed on an -* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -* KIND, either express or implied. See the License for the -* specific language governing permissions and limitations -* under the License. -*/ -using System; -using System.Text; -using System.Threading; -using org.apache.qpid.transport; -using org.apache.qpid.transport.network.io; -using org.apache.qpid.transport.util; - -namespace org.apache.qpid.client -{ - public class Client : IClient - { - private Connection _conn; - private static readonly Logger _log = Logger.Get(typeof (Client)); - private const long timeout = 60000; - private bool _isClosed; - private readonly Object _closeOK; - private IClosedListener _closedListner; - - public event EventHandler<ExceptionArgs> ExceptionRaised; - public event EventHandler ConnectionLost; - - public bool IsClosed - { - get { return _isClosed; } - set - { - _isClosed = value; - if(_isClosed && ConnectionLost != null) - ConnectionLost(this, EventArgs.Empty); - } - } - - public Object CloseOk - { - get { return _closeOK; } - } - - public Client() - { - _isClosed = false; - _closeOK = new object(); - } - - #region Interface IClient - - /// <summary> - /// Establishes a connection with a broker using the provided user auths - /// - /// </summary> - /// <param name="host">Host name on which a broker is deployed</param> - /// <param name="port">Broker port </param> - /// <param name="virtualHost">virtual host name</param> - /// <param name="username">User Name</param> - /// <param name="password">Password</param> - public void Connect(String host, int port, String virtualHost, String username, String password) - { - _log.Debug(String.Format("Client Connecting to host {0}; port {1}; virtualHost {2}; username {3}", host, - port, virtualHost, username)); - ClientConnectionDelegate connectionDelegate = new ClientConnectionDelegate(this, username, password); - ManualResetEvent negotiationComplete = new ManualResetEvent(false); - connectionDelegate.SetCondition(negotiationComplete); - connectionDelegate.VirtualHost = virtualHost; - _conn = IoTransport.Connect(host, port, connectionDelegate); - - _conn.Send(new ProtocolHeader(1, 0, 10)); - negotiationComplete.WaitOne(); - - if (connectionDelegate.Exception != null) - throw connectionDelegate.Exception; - - connectionDelegate.SetCondition(null); - - } - - /// <summary> - /// Establishes a connection with a broker using SSL - /// - /// </summary> - /// <param name="host">Host name on which a broker is deployed</param> - /// <param name="port">Broker port </param> - /// <param name="virtualHost">virtual host name</param> - /// <param name="username">User Name</param> - /// <param name="password">Password</param> - /// <param name="serverName">Name of the SSL server</param> - /// <param name="certPath">Path to the X509 certificate to be used for client authentication</param> - /// <param name="rejectUntrusted">If true connection will not be established if the broker is not trusted</param> - public void ConnectSSL(String host, int port, String virtualHost, String username, String password, string serverName, string certPath, bool rejectUntrusted) - { - _log.Debug(String.Format("Client Connecting to host {0}; port {1}; virtualHost {2}; username {3}", host, - port, virtualHost, username)); - _log.Debug(String.Format("SSL paramters: serverName: {0}; certPath: {1}; rejectUntrusted: {2}", serverName, certPath, rejectUntrusted)); - ClientConnectionDelegate connectionDelegate = new ClientConnectionDelegate(this, username, password); - ManualResetEvent negotiationComplete = new ManualResetEvent(false); - connectionDelegate.SetCondition(negotiationComplete); - connectionDelegate.VirtualHost = virtualHost; - _conn = IoSSLTransport.Connect(host, port, serverName, certPath, rejectUntrusted, connectionDelegate); - - _conn.Send(new ProtocolHeader(1, 0, 10)); - negotiationComplete.WaitOne(); - - if (connectionDelegate.Exception != null) - throw connectionDelegate.Exception; - - connectionDelegate.SetCondition(null); - } - - public void Close() - { - Channel ch = _conn.GetChannel(0); - ch.ConnectionClose(ConnectionCloseCode.NORMAL, "client is closing"); - lock (CloseOk) - { - DateTime start = DateTime.Now; - long elapsed = 0; - while (!IsClosed && elapsed < timeout) - { - Monitor.Wait(CloseOk, (int) (timeout - elapsed)); - elapsed = DateTime.Now.Subtract(start).Milliseconds; - } - if (!IsClosed) - { - throw new Exception("Timed out when closing connection"); - } - _conn.Close(); - } - } - - public IClientSession CreateSession(long expiryInSeconds) - { - Channel ch = _conn.GetChannel(); - ClientSession ssn = new ClientSession(Encoding.UTF8.GetBytes(UUID.RandomUuid().ToString())); - ssn.Attach(ch); - ssn.SessionAttach(ssn.GetName()); - ssn.SessionRequestTimeout(expiryInSeconds); - return ssn; - } - - public IClosedListener ClosedListener - { - set { _closedListner = value; } - get { return _closedListner; } - } - - #endregion - - public void RaiseException(Exception exception) - { - if (ExceptionRaised != null) - ExceptionRaised(this, new ExceptionArgs(exception)); - } - } -} |