diff options
Diffstat (limited to 'qpid/dotnet/client-010/client/transport/ConnectionDelegate.cs')
| -rw-r--r-- | qpid/dotnet/client-010/client/transport/ConnectionDelegate.cs | 108 |
1 files changed, 108 insertions, 0 deletions
diff --git a/qpid/dotnet/client-010/client/transport/ConnectionDelegate.cs b/qpid/dotnet/client-010/client/transport/ConnectionDelegate.cs new file mode 100644 index 0000000000..5d491bc06f --- /dev/null +++ b/qpid/dotnet/client-010/client/transport/ConnectionDelegate.cs @@ -0,0 +1,108 @@ +/* +* +* 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.Collections.Generic; +using System.Threading; +using Logger = org.apache.qpid.transport.util.Logger; + +namespace org.apache.qpid.transport +{ + /// <summary> + /// ConnectionDelegate + /// + /// Currently only implemented client specific methods + /// </summary> + public abstract class ConnectionDelegate : MethodDelegate<Channel> + { + private static readonly Logger log = Logger.Get(typeof(ConnectionDelegate)); + private String _virtualHost; + + protected ManualResetEvent _negotiationComplete; + + public abstract SessionDelegate GetSessionDelegate(); + + public abstract void RaiseException(Exception t); + + public abstract void Closed(); + + public void SetCondition(ManualResetEvent negotiationComplete) + { + _negotiationComplete = negotiationComplete; + } + + public virtual void Init(Channel ch, ProtocolHeader hdr) + { + ch.Connection.Send(new ProtocolHeader((byte)1, hdr.Major, hdr.Minor)); + List<Object> plain = new List<Object>(); + plain.Add("PLAIN"); + List<Object> utf8 = new List<Object>(); + utf8.Add("utf8"); + ch.ConnectionStart(null, plain, utf8); + } + + public String VirtualHost + { + get { return _virtualHost; } + set { _virtualHost = value; } + } + + // ---------------------------------------------- + // Client side + //----------------------------------------------- + public override void ConnectionStart(Channel context, ConnectionStart mstruct) + { + Dictionary<String, Object> props = new Dictionary<String, Object>(); + context.ConnectionStartOk(props, null, null, "utf8"); + } + + public override void ConnectionSecure(Channel context, ConnectionSecure mstruct) + { // todo SASL + context.ConnectionSecureOk(new byte[0]); + } + + public override void ConnectionTune(Channel context, ConnectionTune mstruct) + { + context.Connection.ChannelMax = mstruct.GetChannelMax(); + context.ConnectionTuneOk(mstruct.GetChannelMax(), mstruct.GetMaxFrameSize(), mstruct.GetHeartbeatMax()); + context.ConnectionOpen(_virtualHost, null, Option.INSIST); + } + + public override void ConnectionOpenOk(Channel context, ConnectionOpenOk mstruct) + { + List<Object> knownHosts = mstruct.GetKnownHosts(); + if (_negotiationComplete != null) + { + _negotiationComplete.Set(); + } + } + + public override void ConnectionRedirect(Channel context, ConnectionRedirect mstruct) + { + // not going to bother at the moment + } + + public override void ConnectionClose(Channel ch, ConnectionClose close) + { + ch.Connection.CloseCode(close); + ch.ConnectionCloseOk(); + } + } +}
\ No newline at end of file |