summaryrefslogtreecommitdiff
path: root/qpid/dotnet/client-010/client/transport/SessionDelegate.cs
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/dotnet/client-010/client/transport/SessionDelegate.cs')
-rw-r--r--qpid/dotnet/client-010/client/transport/SessionDelegate.cs126
1 files changed, 0 insertions, 126 deletions
diff --git a/qpid/dotnet/client-010/client/transport/SessionDelegate.cs b/qpid/dotnet/client-010/client/transport/SessionDelegate.cs
deleted file mode 100644
index 973e22df16..0000000000
--- a/qpid/dotnet/client-010/client/transport/SessionDelegate.cs
+++ /dev/null
@@ -1,126 +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.
-*
-*/
-
-namespace org.apache.qpid.transport
-{
- /// <summary>
- /// SessionDelegate
- ///
- /// </summary>
- public abstract class SessionDelegate : MethodDelegate<Session>, IProtocolDelegate<Session>
- {
- public void Init(Session ssn, ProtocolHeader hdr)
- {
- }
-
- public void Control(Session ssn, Method method)
- {
- method.Dispatch(ssn, this);
- }
-
- public void Command(Session ssn, Method method)
- {
- ssn.Identify(method);
- method.Dispatch(ssn, this);
- if (!method.HasPayload())
- {
- ssn.Processed(method);
- }
- }
-
- public void Error(Session ssn, ProtocolError error)
- {
- }
-
- public override void ExecutionResult(Session ssn, ExecutionResult result)
- {
- ssn.Result(result.GetCommandId(), result.GetValue());
- }
-
- public override void ExecutionException(Session ssn, ExecutionException exc)
- {
- ssn.AddException(exc);
- }
-
- public override void SessionCompleted(Session ssn, SessionCompleted cmp)
- {
- RangeSet ranges = cmp.GetCommands();
- RangeSet known = null;
- if (cmp.GetTimelyReply())
- {
- known = new RangeSet();
- }
-
- if (ranges != null)
- {
- foreach (Range range in ranges)
- {
- bool advanced = ssn.Complete(range.Lower, range.Upper);
- if (advanced && known != null)
- {
- known.Add(range);
- }
- }
- }
-
- if (known != null)
- {
- ssn.SessionKnownCompleted(known);
- }
- }
-
- public override void SessionKnownCompleted(Session ssn, SessionKnownCompleted kcmp)
- {
- RangeSet kc = kcmp.GetCommands();
- if (kc != null)
- {
- ssn.KnownComplete(kc);
- }
- }
-
- public override void SessionFlush(Session ssn, SessionFlush flush)
- {
- if (flush.GetCompleted())
- {
- ssn.FlushProcessed();
- }
- if (flush.GetConfirmed())
- {
- ssn.FlushProcessed();
- }
- if (flush.GetExpected())
- {
- // to be done
- //throw new Exception("not implemented");
- }
- }
-
- public override void SessionCommandPoint(Session ssn, SessionCommandPoint scp)
- {
- ssn.CommandsIn = scp.GetCommandId();
- }
-
- public override void ExecutionSync(Session ssn, ExecutionSync sync)
- {
- ssn.SyncPoint();
- }
- }
-}