diff options
Diffstat (limited to 'qpid/dotnet/client-010/client/client/Client.cs')
| -rw-r--r-- | qpid/dotnet/client-010/client/client/Client.cs | 195 |
1 files changed, 195 insertions, 0 deletions
diff --git a/qpid/dotnet/client-010/client/client/Client.cs b/qpid/dotnet/client-010/client/client/Client.cs new file mode 100644 index 0000000000..fc9ff22191 --- /dev/null +++ b/qpid/dotnet/client-010/client/client/Client.cs @@ -0,0 +1,195 @@ +/* +* 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; +using System.Security.Cryptography.X509Certificates; + +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 ConnectionOpenOK; + 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 + + public void Connect(String host, int port, String virtualHost, String username, String password) + { + Connect(host, port, virtualHost, username, password, "PLAIN"); + } + + /// <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> + /// <param name="mechanism">SASL authentication mechanism, possible values: PLAIN, EXTERNAL, DIGEST-MD5, ANONYMOUS</param> + public void Connect(String host, int port, String virtualHost, String username, String password, String mechanism) + { + _log.Debug(String.Format("Client Connecting to host {0}; port {1}; virtualHost {2}; username {3}; mechanism {4}", + host, port, virtualHost, username, mechanism)); + ClientConnectionDelegate connectionDelegate = new ClientConnectionDelegate(this, username, password, mechanism); + 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="mechanism">SASL authentication mechanism, possible values: PLAIN, EXTERNAL, DIGEST-MD5, ANONYMOUS</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="certPass">Password to certificate file, pass null if no password is required</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 mechanism, string serverName, string certPath, String certPass, bool rejectUntrusted) + { + _log.Debug(String.Format("Client Connecting to host {0}; port {1}; virtualHost {2}; username {3}; mechanism {4}", + host, port, virtualHost, username, mechanism)); + _log.Debug(String.Format("SSL parameters: serverName: {0}; certPath: {1}; rejectUntrusted: {2}", serverName, certPath, rejectUntrusted)); + _conn = IoSSLTransport.Connect(host, port, virtualHost, mechanism, serverName, certPath, certPass, rejectUntrusted, this); + } + + /// <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="mechanism">SASL authentication mechanism, possible values: PLAIN, EXTERNAL, DIGEST-MD5, ANONYMOUS</param> + /// <param name="certificate">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 mechanism, X509Certificate certificate, bool rejectUntrusted) + { + _log.Debug(String.Format("Client Connecting to host {0}; port {1}; mechanism {2}", + host, port, mechanism)); + _log.Debug(String.Format("SSL parameters: certSubject: {0}; rejectUntrusted: {1}", + certificate.Subject, rejectUntrusted)); + + _conn = IoSSLTransport.Connect(host, port, mechanism, certificate, rejectUntrusted, this); + } + + 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)); + } + + internal void ConnectionOpenOk(Channel context, ConnectionOpenOk mstruct) + { + if (ConnectionOpenOK != null) + { + ConnectionOpenOK(this, new EventArgs()); + } + } + } +} |