Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / TransactionBridge / Microsoft / Transactions / Wsat / Messaging / Activation.cs / 1 / Activation.cs
//------------------------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------------------------- // Define the interfaces and infrastructure needed to receive activation messages using System; using System.ServiceModel.Channels; using System.Diagnostics; using System.ServiceModel; using System.Transactions; using Microsoft.Transactions.Wsat.Protocol; using DiagnosticUtility = Microsoft.Transactions.Bridge.DiagnosticUtility; namespace Microsoft.Transactions.Wsat.Messaging { // // Activation Interfaces // interface IActivationCoordinator { void CreateCoordinationContext (Message message, RequestAsyncResult result); } class ActivationCoordinatorDispatcher : RequestMessageDispatcher { CoordinationService service; IActivationCoordinator dispatch; public ActivationCoordinatorDispatcher(CoordinationService service, IActivationCoordinator dispatch) { this.service = service; this.dispatch = dispatch; } protected override void SendFaultReply(RequestAsyncResult result, Fault fault) { ActivationProxy.SendFaultResponse(result, fault); } public IAsyncResult BeginCreateCoordinationContext(Message message, AsyncCallback callback, object state) { if (DebugTrace.Verbose) { DebugTrace.Trace(TraceLevel.Verbose, "Dispatching CreateCoordinationContext request"); if (DebugTrace.Pii) DebugTrace.TracePii(TraceLevel.Verbose, "Sender is {0}", CoordinationServiceSecurity.GetSenderName(message)); } RequestAsyncResult result = new RequestAsyncResult(message, callback, state); try { this.dispatch.CreateCoordinationContext(message, result); } catch (InvalidMessageException e) { DiagnosticUtility.ExceptionUtility.TraceHandledException(e, TraceEventType.Warning); this.OnMessageException(result, message, e, Faults.Version(this.service.ProtocolVersion).InvalidParameters); } catch (CommunicationException e) { DiagnosticUtility.ExceptionUtility.TraceHandledException(e, TraceEventType.Warning); this.OnMessageException(result, message, e, Faults.Version(this.service.ProtocolVersion).CreateContextDispatchFailed); } #pragma warning suppress 56500 // Only catch Exception for InvokeFinalHandler catch (Exception e) { DebugTrace.Trace( TraceLevel.Error, "Unhandled exception {0} dispatching CreateCoordinationContext message: {1}", e.GetType().Name, e ); // Contractually the dispatch object can only throw CommunicationException. // Our implementation is very careful to only throw this type of exception // (e.g. when deserializing a malformed message body or header...) // Any other exception indicates that things have gone seriously wrong, // so we cannot be trusted to process further messages. This is a QFE-worthy event. DiagnosticUtility.InvokeFinalHandler(e); } return result; } public Message EndCreateCoordinationContext(IAsyncResult ar) { RequestAsyncResult result = (RequestAsyncResult) ar; result.End(); return result.Reply; } public static IWSActivationCoordinator Instance(CoordinationService service, IActivationCoordinator dispatch) { ProtocolVersionHelper.AssertProtocolVersion(service.ProtocolVersion, typeof(ActivationCoordinatorDispatcher), "Instance"); //assert valid protocol version switch (service.ProtocolVersion) { case ProtocolVersion.Version10: return new ActivationCoordinatorDispatcher10(service, dispatch); case ProtocolVersion.Version11: return new ActivationCoordinatorDispatcher11(service, dispatch); default: return null; // inaccessible path because we have asserted the protocol version } } } [ServiceBehavior( InstanceContextMode = InstanceContextMode.Single, ConcurrencyMode = ConcurrencyMode.Multiple)] class ActivationCoordinatorDispatcher10 : IWSActivationCoordinator10 { ActivationCoordinatorDispatcher activationCoordinatorDispatcher; public ActivationCoordinatorDispatcher10(CoordinationService service, IActivationCoordinator dispatch) { ProtocolVersionHelper.AssertProtocolVersion10(service.ProtocolVersion, typeof(ActivationCoordinatorDispatcher10), "constr"); this.activationCoordinatorDispatcher = new ActivationCoordinatorDispatcher(service, dispatch); } public Type ContractType { get { return typeof(IWSActivationCoordinator10); } } public IAsyncResult BeginCreateCoordinationContext(Message message, AsyncCallback callback, object state) { return this.activationCoordinatorDispatcher.BeginCreateCoordinationContext(message, callback, state); } public Message EndCreateCoordinationContext(IAsyncResult ar) { return this.activationCoordinatorDispatcher.EndCreateCoordinationContext(ar); } } [ServiceBehavior( InstanceContextMode = InstanceContextMode.Single, ConcurrencyMode = ConcurrencyMode.Multiple)] class ActivationCoordinatorDispatcher11 : IWSActivationCoordinator11 { ActivationCoordinatorDispatcher activationCoordinatorDispatcher; public ActivationCoordinatorDispatcher11(CoordinationService service, IActivationCoordinator dispatch) { ProtocolVersionHelper.AssertProtocolVersion11(service.ProtocolVersion, typeof(ActivationCoordinatorDispatcher11), "constr"); this.activationCoordinatorDispatcher = new ActivationCoordinatorDispatcher(service, dispatch); } public Type ContractType { get { return typeof(IWSActivationCoordinator11); } } public IAsyncResult BeginCreateCoordinationContext(Message message, AsyncCallback callback, object state) { return this.activationCoordinatorDispatcher.BeginCreateCoordinationContext(message, callback, state); } public Message EndCreateCoordinationContext(IAsyncResult ar) { return this.activationCoordinatorDispatcher.EndCreateCoordinationContext(ar); } } } // 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
- ImpersonateTokenRef.cs
- TransformerInfoCollection.cs
- WSDualHttpSecurityMode.cs
- EraserBehavior.cs
- SearchForVirtualItemEventArgs.cs
- RayMeshGeometry3DHitTestResult.cs
- SendingRequestEventArgs.cs
- IPCCacheManager.cs
- ICspAsymmetricAlgorithm.cs
- SortDescriptionCollection.cs
- BufferedWebEventProvider.cs
- ColumnWidthChangedEvent.cs
- PeerContact.cs
- MultipleViewPatternIdentifiers.cs
- IgnoreSection.cs
- RepeaterDesigner.cs
- GCHandleCookieTable.cs
- BitArray.cs
- SQLGuidStorage.cs
- CompositeFontFamily.cs
- KeyMatchBuilder.cs
- StringUtil.cs
- PrintEvent.cs
- MimePart.cs
- GridView.cs
- SwitchCase.cs
- MailAddress.cs
- ViewKeyConstraint.cs
- EnumMember.cs
- ProxyWebPart.cs
- PrintControllerWithStatusDialog.cs
- OutputCacheProfileCollection.cs
- TraceHandler.cs
- ThreadStartException.cs
- ExpressionBuilder.cs
- AutoGeneratedFieldProperties.cs
- Cursor.cs
- WCFModelStrings.Designer.cs
- HashCodeCombiner.cs
- ReadOnlyTernaryTree.cs
- Journal.cs
- _StreamFramer.cs
- keycontainerpermission.cs
- ScopelessEnumAttribute.cs
- ProgressiveCrcCalculatingStream.cs
- Style.cs
- FormsAuthenticationConfiguration.cs
- SecurityDescriptor.cs
- NTAccount.cs
- VariantWrapper.cs
- GC.cs
- CacheVirtualItemsEvent.cs
- configsystem.cs
- DbParameterCollectionHelper.cs
- ZipIOExtraFieldElement.cs
- MobileControlsSection.cs
- BaseTemplatedMobileComponentEditor.cs
- Assembly.cs
- Compress.cs
- ReadOnlyObservableCollection.cs
- ImportedNamespaceContextItem.cs
- GetRecipientListRequest.cs
- DecimalConverter.cs
- MLangCodePageEncoding.cs
- DataList.cs
- SqlRowUpdatingEvent.cs
- _NegoStream.cs
- FrameworkEventSource.cs
- SelectionRange.cs
- DoubleLink.cs
- TableParaClient.cs
- AdornerHitTestResult.cs
- TypedServiceChannelBuilder.cs
- XmlNodeReader.cs
- AttributeCollection.cs
- SoapEnumAttribute.cs
- CodeDOMUtility.cs
- SelectionPattern.cs
- IdleTimeoutMonitor.cs
- ReadWriteObjectLock.cs
- WindowsFormsHost.cs
- SqlXml.cs
- DataList.cs
- WasHttpModulesInstallComponent.cs
- FirstMatchCodeGroup.cs
- ClientUtils.cs
- SchemaCollectionCompiler.cs
- ObsoleteAttribute.cs
- ComponentTray.cs
- PersonalizationStateInfo.cs
- BufferedWebEventProvider.cs
- FacetEnabledSchemaElement.cs
- x509store.cs
- DataGridBoolColumn.cs
- ObjectStateEntryDbDataRecord.cs
- MultiBindingExpression.cs
- FontFaceLayoutInfo.cs
- WebPartAuthorizationEventArgs.cs
- DBBindings.cs
- ConversionContext.cs