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
- PropertyMap.cs
- SchemaAttDef.cs
- Char.cs
- Visual3D.cs
- BamlStream.cs
- MethodCallExpression.cs
- FactoryGenerator.cs
- DeferredBinaryDeserializerExtension.cs
- SevenBitStream.cs
- DoubleLinkList.cs
- SystemWebSectionGroup.cs
- FieldBuilder.cs
- BulletChrome.cs
- COM2Enum.cs
- _NegoState.cs
- OperationAbortedException.cs
- DesignerTextViewAdapter.cs
- InputLangChangeRequestEvent.cs
- SurrogateSelector.cs
- InputMethod.cs
- Assembly.cs
- TraceLog.cs
- MsmqIntegrationMessageProperty.cs
- MobileRedirect.cs
- TrailingSpaceComparer.cs
- AmbientProperties.cs
- PersonalizationStateInfoCollection.cs
- WorkflowDefinitionContext.cs
- SecurityTokenReferenceStyle.cs
- WriteFileContext.cs
- ScrollData.cs
- ReaderWriterLock.cs
- TextPointer.cs
- Relationship.cs
- ContextStaticAttribute.cs
- XhtmlBasicValidatorAdapter.cs
- Directory.cs
- PkcsUtils.cs
- SHA384CryptoServiceProvider.cs
- QueryOutputWriterV1.cs
- ProcessStartInfo.cs
- Int16Converter.cs
- DataPager.cs
- StrokeCollectionConverter.cs
- SQLBinary.cs
- MatchSingleFxEngineOpcode.cs
- ToolStripDropDownDesigner.cs
- InternalsVisibleToAttribute.cs
- GrammarBuilderPhrase.cs
- SetStoryboardSpeedRatio.cs
- RequestNavigateEventArgs.cs
- PartialCachingControl.cs
- Timer.cs
- TextRangeAdaptor.cs
- CodeTryCatchFinallyStatement.cs
- UrlPath.cs
- SourceCollection.cs
- Image.cs
- MsmqIntegrationProcessProtocolHandler.cs
- PageSettings.cs
- OrderedHashRepartitionEnumerator.cs
- uribuilder.cs
- Context.cs
- WebPartConnectVerb.cs
- SqlDataRecord.cs
- ButtonAutomationPeer.cs
- HttpModuleActionCollection.cs
- LineGeometry.cs
- UnsafeNativeMethods.cs
- HighContrastHelper.cs
- MessageTransmitTraceRecord.cs
- EffectiveValueEntry.cs
- WindowsSlider.cs
- MailWriter.cs
- OverlappedAsyncResult.cs
- CategoryGridEntry.cs
- RegionIterator.cs
- Crc32.cs
- sortedlist.cs
- AppSecurityManager.cs
- CharacterHit.cs
- MdiWindowListItemConverter.cs
- GridViewPageEventArgs.cs
- MatchingStyle.cs
- ServiceSettingsResponseInfo.cs
- FixedSOMImage.cs
- WebBrowserUriTypeConverter.cs
- Logging.cs
- UICuesEvent.cs
- ConcurrencyMode.cs
- BaseTemplateBuildProvider.cs
- LabelDesigner.cs
- StreamGeometryContext.cs
- EventItfInfo.cs
- StructuredCompositeActivityDesigner.cs
- StorageTypeMapping.cs
- SQLString.cs
- TextRangeEdit.cs
- ProfilePropertyNameValidator.cs
- XamlNamespaceHelper.cs