diff options
Diffstat (limited to 'qpid/dotnet/client-010/wcf/model/QpidInputChannelBase.cs')
| -rw-r--r-- | qpid/dotnet/client-010/wcf/model/QpidInputChannelBase.cs | 101 |
1 files changed, 0 insertions, 101 deletions
diff --git a/qpid/dotnet/client-010/wcf/model/QpidInputChannelBase.cs b/qpid/dotnet/client-010/wcf/model/QpidInputChannelBase.cs deleted file mode 100644 index 0bd9e85c0a..0000000000 --- a/qpid/dotnet/client-010/wcf/model/QpidInputChannelBase.cs +++ /dev/null @@ -1,101 +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.ServiceModel; -using System.ServiceModel.Channels; - -namespace org.apache.qpid.wcf.model -{ - internal abstract class QpidInputChannelBase : QpidChannelBase, IInputChannel - { - private readonly EndpointAddress _localAddress; - private readonly CommunicationOperation<Message> _receiveMethod; - private readonly CommunicationOperation<bool, Message> _tryReceiveMethod; - private readonly CommunicationOperation<bool> _waitForMessage; - - - protected QpidInputChannelBase(BindingContext context, EndpointAddress localAddress) - :base(context) - { - _localAddress = localAddress; - _receiveMethod = Receive; - _tryReceiveMethod = TryReceive; - _waitForMessage = WaitForMessage; - } - - - #region Async Methods - public virtual IAsyncResult BeginReceive(TimeSpan timeout, AsyncCallback callback, object state) - { - return _receiveMethod.BeginInvoke(timeout, callback, state); - } - - public virtual IAsyncResult BeginReceive(AsyncCallback callback, object state) - { - return _receiveMethod.BeginInvoke(Context.Binding.ReceiveTimeout, callback, state); - } - - public virtual IAsyncResult BeginTryReceive(TimeSpan timeout, AsyncCallback callback, object state) - { - Message message; - return _tryReceiveMethod.BeginInvoke(timeout, out message, callback, state); - } - - public virtual IAsyncResult BeginWaitForMessage(TimeSpan timeout, AsyncCallback callback, object state) - { - return _waitForMessage.BeginInvoke(timeout, callback, state); - } - - public virtual Message EndReceive(IAsyncResult result) - { - return _receiveMethod.EndInvoke(result); - } - - public virtual bool EndTryReceive(IAsyncResult result, out Message message) - { - return _tryReceiveMethod.EndInvoke(out message, result); - } - - public virtual bool EndWaitForMessage(IAsyncResult result) - { - return _waitForMessage.EndInvoke(result); - } - #endregion - - public abstract Message Receive(TimeSpan timeout); - - public abstract bool TryReceive(TimeSpan timeout, out Message message); - - public abstract bool WaitForMessage(TimeSpan timeout); - - public virtual Message Receive() - { - return Receive(Context.Binding.ReceiveTimeout); - } - - - public EndpointAddress LocalAddress - { - get { return _localAddress; } - } - } -} |
