Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Channels / MsmqInputSessionChannel.cs / 1 / MsmqInputSessionChannel.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.Channels { using System.Runtime.InteropServices; using System.ServiceModel; using System.Threading; using System.Transactions; using SR=System.ServiceModel.SR; sealed class MsmqInputSessionChannel : InputChannel, IInputSessionChannel { IInputSession session; Transaction associatedTx; public MsmqInputSessionChannel(MsmqInputSessionChannelListener listener, Transaction associatedTx) : base(listener, new EndpointAddress(listener.Uri)) { this.session = new InputSession(); this.associatedTx = associatedTx; this.associatedTx.EnlistVolatile(new TransactionEnlistment(this, this.associatedTx), EnlistmentOptions.None); } public IInputSession Session { get { return this.session; } } public override Message Receive() { return this.Receive(this.DefaultReceiveTimeout); } public override Message Receive(TimeSpan timeout) { return InputChannel.HelpReceive(this, timeout); } public override IAsyncResult BeginReceive(AsyncCallback callback, object state) { return this.BeginReceive(this.DefaultReceiveTimeout, callback, state); } public override IAsyncResult BeginReceive(TimeSpan timeout, AsyncCallback callback, object state) { return InputChannel.HelpBeginReceive(this, timeout, callback, state); } public override bool TryReceive(TimeSpan timeout, out Message message) { ThrowIfFaulted(); if (CommunicationState.Closed == this.State || CommunicationState.Closing == this.State) { message = null; return true; } VerifyTransaction(); return base.TryReceive(timeout, out message); } public override IAsyncResult BeginTryReceive(TimeSpan timeout, AsyncCallback callback, object state) { ThrowIfFaulted(); if (CommunicationState.Closed == this.State || CommunicationState.Closing == this.State) { return new TypedCompletedAsyncResult(true, null, callback, state); } VerifyTransaction(); return base.BeginTryReceive(timeout, callback, state); } public override bool EndTryReceive(IAsyncResult result, out Message message) { TypedCompletedAsyncResult completedResult = result as TypedCompletedAsyncResult ; if (null != completedResult) return TypedCompletedAsyncResult .End(result, out message); else return base.EndTryReceive(result, out message); } public void FaultChannel() { this.Fault(); } void OnCloseCore(bool isAborting) { if (isAborting) { RollbackTransaction(); } else { VerifyTransaction(); if (this.InternalPendingItems > 0) { RollbackTransaction(); this.Fault(); throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqSessionMessagesNotConsumed))); } } } protected override void OnAbort() { OnCloseCore(true); base.OnAbort(); } protected override void OnClose(TimeSpan timeout) { OnCloseCore(false); base.OnClose(timeout); } protected override IAsyncResult OnBeginClose(TimeSpan timeout, AsyncCallback callback, object state) { OnCloseCore(false); return base.OnBeginClose(timeout, callback, state); } void RollbackTransaction() { try { if (TransactionStatus.Active == this.associatedTx.TransactionInformation.Status) this.associatedTx.Rollback(); } catch (TransactionAbortedException ex) { MsmqDiagnostics.ExpectedException(ex); } catch (ObjectDisposedException ex) { MsmqDiagnostics.ExpectedException(ex); } } void VerifyTransaction() { if (this.InternalPendingItems > 0) { if (this.associatedTx != Transaction.Current) { RollbackTransaction(); this.Fault(); throw DiagnosticUtility.ExceptionUtility.ThrowHelperCritical(new InvalidOperationException(SR.GetString(SR.MsmqSameTransactionExpected))); } if (TransactionStatus.Active != Transaction.Current.TransactionInformation.Status) { RollbackTransaction(); this.Fault(); throw DiagnosticUtility.ExceptionUtility.ThrowHelperCritical(new InvalidOperationException(SR.GetString(SR.MsmqTransactionNotActive))); } } } class InputSession : IInputSession { string id = "uuid://session-gram/" + Guid.NewGuid().ToString(); public string Id { get { return this.id; } } } class TransactionEnlistment : IEnlistmentNotification { MsmqInputSessionChannel channel; Transaction transaction; public TransactionEnlistment(MsmqInputSessionChannel channel, Transaction transaction) { this.channel = channel; this.transaction = transaction; } public void Prepare(PreparingEnlistment preparingEnlistment) { // Abort if this happens before all messges are consumed if (this.channel.State == CommunicationState.Opened && this.channel.InternalPendingItems > 0) { Exception e = DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqSessionChannelsMustBeClosed))); preparingEnlistment.ForceRollback(e); this.channel.Fault(); } else { preparingEnlistment.Done(); } } public void Commit(Enlistment enlistment) { enlistment.Done(); } public void Rollback(Enlistment enlistment) { channel.Fault(); enlistment.Done(); } public void InDoubt(Enlistment enlistment) { enlistment.Done(); } } } } // 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
- DSASignatureFormatter.cs
- Rotation3D.cs
- ReachFixedPageSerializerAsync.cs
- MimeXmlImporter.cs
- SharedUtils.cs
- TextViewBase.cs
- XmlSchemaCollection.cs
- ReadWriteSpinLock.cs
- Icon.cs
- ModulesEntry.cs
- SimpleTableProvider.cs
- RegexRunnerFactory.cs
- SecurityDocument.cs
- HandoffBehavior.cs
- DebugInfoGenerator.cs
- DataTrigger.cs
- TypeSource.cs
- RuleConditionDialog.cs
- CommandExpr.cs
- GridViewColumnCollection.cs
- StylusPointCollection.cs
- TemplatedMailWebEventProvider.cs
- DoubleLinkListEnumerator.cs
- Tracer.cs
- Point3DCollection.cs
- WebCategoryAttribute.cs
- RawMouseInputReport.cs
- SequentialOutput.cs
- CellRelation.cs
- NamedObject.cs
- InvalidProgramException.cs
- LinkLabel.cs
- CacheOutputQuery.cs
- StringInfo.cs
- StrongNameMembershipCondition.cs
- BindingSource.cs
- DataErrorValidationRule.cs
- ForeignKeyConstraint.cs
- PerformanceCounter.cs
- KnownTypeAttribute.cs
- TaskCanceledException.cs
- SystemIcons.cs
- QuaternionIndependentAnimationStorage.cs
- XmlSecureResolver.cs
- SynchronizationContext.cs
- DataTablePropertyDescriptor.cs
- ThemeableAttribute.cs
- ProjectionPruner.cs
- ApplicationFileParser.cs
- DataGridPagerStyle.cs
- MessageDesigner.cs
- WebBrowserContainer.cs
- ResourceDescriptionAttribute.cs
- PenCursorManager.cs
- ResourceDescriptionAttribute.cs
- ValidationVisibilityAttribute.cs
- OleDbCommandBuilder.cs
- SqlFunctionAttribute.cs
- PageTheme.cs
- WindowsSysHeader.cs
- MessageEncodingBindingElement.cs
- ConfigXmlSignificantWhitespace.cs
- SdlChannelSink.cs
- VirtualPath.cs
- DocumentSchemaValidator.cs
- ContentOperations.cs
- ResourcesBuildProvider.cs
- ToolStripProfessionalLowResolutionRenderer.cs
- DataGridPagerStyle.cs
- SqlWebEventProvider.cs
- UnauthorizedAccessException.cs
- WindowsToolbar.cs
- EditCommandColumn.cs
- assertwrapper.cs
- DocumentXPathNavigator.cs
- ManagementEventWatcher.cs
- PointCollection.cs
- ExternalException.cs
- WpfKnownTypeInvoker.cs
- DesignerLoader.cs
- OleDbCommand.cs
- ReflectPropertyDescriptor.cs
- EtwTrace.cs
- SqlRewriteScalarSubqueries.cs
- HtmlTableCell.cs
- OleDbConnectionInternal.cs
- ISAPIWorkerRequest.cs
- MasterPageBuildProvider.cs
- PagedControl.cs
- Table.cs
- ZipIOCentralDirectoryFileHeader.cs
- FontFamilyIdentifier.cs
- Compiler.cs
- DataControlField.cs
- ReceiveContent.cs
- String.cs
- HtmlInputRadioButton.cs
- DecodeHelper.cs
- LinearQuaternionKeyFrame.cs
- recordstate.cs