diff options
Diffstat (limited to 'dotnet/client-010/client/transport/Channel.cs')
| -rw-r--r-- | dotnet/client-010/client/transport/Channel.cs | 174 |
1 files changed, 0 insertions, 174 deletions
diff --git a/dotnet/client-010/client/transport/Channel.cs b/dotnet/client-010/client/transport/Channel.cs deleted file mode 100644 index 48ba707182..0000000000 --- a/dotnet/client-010/client/transport/Channel.cs +++ /dev/null @@ -1,174 +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 org.apache.qpid.transport.network; -using org.apache.qpid.transport.util; - -namespace org.apache.qpid.transport -{ - /// <summary> - /// Channel - /// </summary> - public class Channel : Invoker, IProtocolDelegate<Object> - { - private static readonly Logger log = Logger.Get(typeof (Channel)); - - private readonly Connection _connection; - private readonly int _channel; - private readonly MethodDelegate<Channel> _methoddelegate; - private readonly SessionDelegate _sessionDelegate; - // session may be null - private Session _session; - - public Channel(Connection connection, int channel, SessionDelegate sessionDelegate) - { - _connection = connection; - _channel = channel; - _methoddelegate = new ChannelDelegate(); - _sessionDelegate = sessionDelegate; - } - - public Connection Connection - { - get { return _connection; } - } - - // Invoked when a network event is received - public void On_ReceivedEvent(object sender, ReceivedPayload<IProtocolEvent> payload) - { - if (payload.Payload.Channel == _channel) - { - payload.Payload.ProcessProtocolEvent(null, this); - } - } - - #region ProtocolDelegate<T> - - public void Init(Object v, ProtocolHeader hdr) - { - _connection.ConnectionDelegate.Init(this, hdr); - } - - public void Control(Object v, Method method) - { - switch (method.EncodedTrack) - { - case Frame.L1: - method.Dispatch(this, _connection.ConnectionDelegate); - break; - case Frame.L2: - method.Dispatch(this, _methoddelegate); - break; - case Frame.L3: - method.ProcessProtocolEvent(_session, _sessionDelegate); - break; - default: - throw new Exception("unknown track: " + method.EncodedTrack); - } - } - - public void Command(Object v, Method method) - { - method.ProcessProtocolEvent(_session, _sessionDelegate); - } - - public void Error(Object v, ProtocolError error) - { - throw new Exception(error.Message); - } - - #endregion - - public void Exception(Exception t) - { - _session.Exception(t); - } - - public void ClosedFromConnection() - { - log.Debug("channel Closed: ", this); - if (_session != null) - { - _session.Closed(); - } - } - - public void Closed() - { - log.Debug("channel Closed: ", this); - if (_session != null) - { - _session.Closed(); - } - _connection.RemoveChannel(_channel); - } - - public int EncodedChannel - { - get { return _channel; } - } - - public Session Session - { - get { return _session; } - set { _session = value; } - } - - public void CloseCode(ConnectionClose close) - { - if (_session != null) - { - _session.CloseCode(close); - } - } - - private void Emit(IProtocolEvent pevent) - { - pevent.Channel = _channel; - _connection.Send(pevent); - } - - public void Method(Method m) - { - Emit(m); - - if (!m.Batch) - { - _connection.Flush(); - } - } - - protected override void Invoke(Method m) - { - Method(m); - } - - public override IFuture Invoke(Method m, IFuture future) - { - throw new Exception("UnsupportedOperation"); - } - - public override String ToString() - { - return String.Format("{0}:{1}", _connection, _channel); - } - } -}
\ No newline at end of file |