Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Channels / MsmqInputChannelBase.cs / 1 / MsmqInputChannelBase.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.Channels { using System.Runtime.CompilerServices; using System.Runtime.InteropServices; using System.ServiceModel; using System.Transactions; abstract class MsmqInputChannelBase : ChannelBase, IInputChannel { EndpointAddress localAddress; MsmqReceiveHelper receiver; MsmqReceiveParameters receiveParameters; MsmqInputChannelListenerBase listener; public MsmqInputChannelBase(MsmqInputChannelListenerBase listener, IMsmqMessagePool messagePool) : base(listener) { this.receiveParameters = listener.ReceiveParameters; this.receiver = new MsmqReceiveHelper(listener.ReceiveParameters, listener.Uri, messagePool, this, listener); this.localAddress = new EndpointAddress(listener.Uri); this.listener = listener; } public EndpointAddress LocalAddress { get { return this.localAddress; } } protected MsmqReceiveHelper MsmqReceiveHelper { get { return this.receiver; } } protected MsmqReceiveParameters ReceiveParameters { get { return this.receiveParameters; } } protected virtual void OnCloseCore(bool isAborting) { receiver.Close(); } protected virtual void OnOpenCore() { try { receiver.Open(); } catch (MsmqException ex) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(ex.Normalized); } } protected override IAsyncResult OnBeginOpen(TimeSpan timeout, AsyncCallback callback, object state) { OnOpenCore(); return new CompletedAsyncResult(callback, state); } protected override void OnOpen(TimeSpan timeout) { OnOpenCore(); } protected override void OnEndOpen(IAsyncResult result) { CompletedAsyncResult.End(result); } protected override void OnAbort() { OnCloseCore(true); } protected override IAsyncResult OnBeginClose(TimeSpan timeout, AsyncCallback callback, object state) { OnCloseCore(false); return new CompletedAsyncResult(callback, state); } protected override void OnClose(TimeSpan timeout) { OnCloseCore(false); } protected override void OnEndClose(IAsyncResult result) { CompletedAsyncResult.End(result); } abstract protected Message DecodeMsmqMessage(MsmqInputMessage msmqMessage, MsmqMessageProperty property); internal void FaultChannel() { this.Fault(); } // Receive public Message Receive() { return this.Receive(this.DefaultReceiveTimeout); } // public Message Receive(TimeSpan timeout) { return InputChannel.HelpReceive(this, timeout); } // public IAsyncResult BeginReceive(AsyncCallback callback, object state) { return this.BeginReceive(this.DefaultReceiveTimeout, callback, state); } public IAsyncResult BeginReceive(TimeSpan timeout, AsyncCallback callback, object state) { using (MsmqDiagnostics.BoundReceiveOperation(this.receiver)) { return InputChannel.HelpBeginReceive(this, timeout, callback, state); } } public Message EndReceive(IAsyncResult result) { return InputChannel.HelpEndReceive(result); } // TryReceive public bool TryReceive(TimeSpan timeout, out Message message) { message = null; if (DoneReceivingInCurrentState()) return true; using (MsmqDiagnostics.BoundReceiveOperation(this.receiver)) { MsmqInputMessage msmqMessage = this.receiver.TakeMessage(); try { MsmqMessageProperty property; bool retval = this.receiver.TryReceive( msmqMessage, timeout, this.ReceiveParameters.ExactlyOnce ? MsmqTransactionMode.CurrentOrNone : MsmqTransactionMode.None, out property); if (retval) { if (null != property) { message = DecodeMsmqMessage(msmqMessage, property); message.Properties[MsmqMessageProperty.Name] = property; MsmqDiagnostics.DatagramReceived(msmqMessage.MessageId, message); this.listener.RaiseMessageReceived(); } else if (CommunicationState.Opened == this.State) { this.listener.FaultListener(); this.Fault(); } } return retval; } catch (MsmqException ex) { if (ex.FaultReceiver) { this.listener.FaultListener(); this.Fault(); } throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(ex.Normalized); } finally { this.receiver.ReturnMessage(msmqMessage); } } } public IAsyncResult BeginTryReceive(TimeSpan timeout, AsyncCallback callback, object state) { if (DoneReceivingInCurrentState()) return new DoneReceivingAsyncResult(callback, state); MsmqInputMessage msmqMessage = this.receiver.TakeMessage(); return this.receiver.BeginTryReceive( msmqMessage, timeout, this.ReceiveParameters.ExactlyOnce ? MsmqTransactionMode.CurrentOrNone : MsmqTransactionMode.None, callback, state); } public bool EndTryReceive(IAsyncResult result, out Message message) { message = null; if (null == result) throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("result"); DoneReceivingAsyncResult doneRecevingResult = result as DoneReceivingAsyncResult; if (doneRecevingResult != null) return DoneReceivingAsyncResult.End(doneRecevingResult); MsmqInputMessage msmqMessage = null; MsmqMessageProperty property = null; try { bool retval = this.receiver.EndTryReceive(result, out msmqMessage, out property); if (retval) { if(null != property) { message = DecodeMsmqMessage(msmqMessage, property); message.Properties[MsmqMessageProperty.Name] = property; MsmqDiagnostics.DatagramReceived(msmqMessage.MessageId, message); this.listener.RaiseMessageReceived(); } else if (CommunicationState.Opened == this.State) { this.listener.FaultListener(); this.Fault(); } } return retval; } catch (MsmqException ex) { if (ex.FaultReceiver) { this.listener.FaultListener(); this.Fault(); } throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(ex.Normalized); } finally { if (null != msmqMessage) this.receiver.ReturnMessage(msmqMessage); } } // WaitForMessage public bool WaitForMessage(TimeSpan timeout) { if (DoneReceivingInCurrentState()) return true; try { return this.receiver.WaitForMessage(timeout); } catch (MsmqException ex) { if (ex.FaultReceiver) { this.listener.FaultListener(); this.Fault(); } throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(ex.Normalized); } } public IAsyncResult BeginWaitForMessage(TimeSpan timeout, AsyncCallback callback, object state) { if (DoneReceivingInCurrentState()) return new DoneReceivingAsyncResult(callback, state); return this.receiver.BeginWaitForMessage(timeout, callback, state); } public bool EndWaitForMessage(IAsyncResult result) { if (null == result) throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("result"); DoneReceivingAsyncResult doneRecevingResult = result as DoneReceivingAsyncResult; if (doneRecevingResult != null) return DoneReceivingAsyncResult.End(doneRecevingResult); try { return this.receiver.EndWaitForMessage(result); } catch (MsmqException ex) { if (ex.FaultReceiver) { this.listener.FaultListener(); this.Fault(); } throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(ex.Normalized); } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // Copyright (c) Microsoft Corporation. All rights reserved.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- ApplyImportsAction.cs
- NameScopePropertyAttribute.cs
- XPathPatternParser.cs
- ScaleTransform3D.cs
- BindingGroup.cs
- ApplicationFileCodeDomTreeGenerator.cs
- ReverseInheritProperty.cs
- SafeEventLogWriteHandle.cs
- MetafileHeaderWmf.cs
- SecUtil.cs
- IdentityManager.cs
- MultipleViewPattern.cs
- SelectionRangeConverter.cs
- RawStylusInputReport.cs
- HttpHandlersSection.cs
- MultipleViewPattern.cs
- serverconfig.cs
- NativeMethods.cs
- HttpRequest.cs
- LinkAreaEditor.cs
- xmlsaver.cs
- NavigationEventArgs.cs
- Transform.cs
- TextFragmentEngine.cs
- ThemeDictionaryExtension.cs
- PrintPreviewGraphics.cs
- Socket.cs
- ProtectedUri.cs
- ConstraintStruct.cs
- PerformanceCounterPermissionEntryCollection.cs
- ParameterBuilder.cs
- PreviousTrackingServiceAttribute.cs
- DynamicPropertyHolder.cs
- InternalCache.cs
- ArgumentsParser.cs
- SecUtil.cs
- RedirectionProxy.cs
- SessionConnectionReader.cs
- Vector.cs
- URLBuilder.cs
- StorageTypeMapping.cs
- DiscoveryDocumentSerializer.cs
- DelegateSerializationHolder.cs
- BrowserCapabilitiesCodeGenerator.cs
- UnmanagedBitmapWrapper.cs
- EntityDataSourceReferenceGroup.cs
- TreeNode.cs
- X509CertificateChain.cs
- ControllableStoryboardAction.cs
- DescendantBaseQuery.cs
- ArrangedElement.cs
- DSASignatureDeformatter.cs
- ErrorStyle.cs
- FormsAuthenticationEventArgs.cs
- BitmapPalettes.cs
- ComboBoxRenderer.cs
- RectValueSerializer.cs
- Rule.cs
- CursorConverter.cs
- RegexMatch.cs
- XmlDataSource.cs
- ModelUIElement3D.cs
- ConnectionManagementElement.cs
- CodeIdentifiers.cs
- OverlappedAsyncResult.cs
- MenuAdapter.cs
- AssemblyBuilder.cs
- BaseDataList.cs
- SerialStream.cs
- ExtendedProperty.cs
- TemplateControlParser.cs
- XhtmlConformanceSection.cs
- ScopelessEnumAttribute.cs
- Utilities.cs
- MouseCaptureWithinProperty.cs
- LiteralControl.cs
- OleStrCAMarshaler.cs
- SerializerDescriptor.cs
- SqlConnection.cs
- XmlSchemaGroup.cs
- AdRotatorDesigner.cs
- WinInetCache.cs
- DocumentSchemaValidator.cs
- OutputBuffer.cs
- ManipulationCompletedEventArgs.cs
- InkCollectionBehavior.cs
- BamlResourceDeserializer.cs
- CompositeCollectionView.cs
- EncryptedPackage.cs
- CheckBoxRenderer.cs
- PrtCap_Reader.cs
- SoundPlayer.cs
- MethodBody.cs
- BaseEntityWrapper.cs
- ColumnPropertiesGroup.cs
- HandlerWithFactory.cs
- BaseCodePageEncoding.cs
- SimpleType.cs
- CodeAccessPermission.cs
- Dispatcher.cs