Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / NetFx40 / System.ServiceModel.Activities / System / ServiceModel / Activities / WorkflowHostingEndpoint.cs / 1305376 / WorkflowHostingEndpoint.cs
//---------------------------------------------------------------- // Copyright (c) Microsoft Corporation. All rights reserved. //--------------------------------------------------------------- namespace System.ServiceModel.Activities { using System.Activities; using System.Collections.Generic; using System.Collections.ObjectModel; using System.Diagnostics.CodeAnalysis; using System.Globalization; using System.Runtime; using System.ServiceModel.Activities.Description; using System.ServiceModel.Activities.Dispatcher; using System.ServiceModel.Channels; using System.ServiceModel.Description; using System.ServiceModel.Dispatcher; public abstract class WorkflowHostingEndpoint : ServiceEndpoint { CollectioncorrelationQueries; protected WorkflowHostingEndpoint(Type contractType) : this(contractType, null, null) { } protected WorkflowHostingEndpoint(Type contractType, Binding binding, EndpointAddress address) : base(ContractDescription.GetContract(contractType), binding, address) { this.IsSystemEndpoint = true; this.Contract.Behaviors.Add(new ServiceMetadataContractBehavior(false)); this.Contract.Behaviors.Add(new WorkflowHostingContractBehavior()); Fx.Assert(!this.Behaviors.Contains(typeof(CorrelationQueryBehavior)), "Must not contain correlation query!"); this.correlationQueries = new Collection (); this.Behaviors.Add(new CorrelationQueryBehavior(this.correlationQueries)); // If TransactionFlowOption.Allowed or TransactionFlowOption.Mandatory is defined on an operation, we will set // TransactionScopeRequired = true for that operation. The operation will become transacted (use transaction flow, // or create one locally). For usability reason, we assume this is the majority usage. User could opt out by // setting TransactionScopeRequired to false or remove the TransactionFlowAttribute from the operation. foreach (OperationDescription operationDescription in this.Contract.Operations) { TransactionFlowAttribute transactionFlow = operationDescription.Behaviors.Find (); if (transactionFlow != null && transactionFlow.Transactions != TransactionFlowOption.NotAllowed) { OperationBehaviorAttribute operationAttribute = operationDescription.Behaviors.Find (); operationAttribute.TransactionScopeRequired = true; } } } public Collection CorrelationQueries { get { return this.correlationQueries; } } // There are two main scenario that user will override this api. // - For ResumeBookmark, User explicitly put or know how to extract InstanceId from Message. This enables user to provide // customized and lighter-weight (no InstanceKeys indirection) correlation. // - For Workflow Creation, User could provide a preferred Id for newly created Workflow Instance. protected internal virtual Guid OnGetInstanceId(object[] inputs, OperationContext operationContext) { return Guid.Empty; } protected internal virtual WorkflowCreationContext OnGetCreationContext( object[] inputs, OperationContext operationContext, Guid instanceId, WorkflowHostingResponseContext responseContext) { return null; } [SuppressMessage(FxCop.Category.Design, FxCop.Rule.AvoidOutParameters, Justification = "By design, return both Bookmark and its payload.")] protected internal virtual Bookmark OnResolveBookmark(object[] inputs, OperationContext operationContext, WorkflowHostingResponseContext responseContext, out object value) { value = null; return null; } internal static FaultException CreateDispatchFaultException() { FaultCode code = new FaultCode(FaultCodeConstants.Codes.InternalServiceFault, FaultCodeConstants.Namespaces.NetDispatch); code = FaultCode.CreateReceiverFaultCode(code); MessageFault dispatchFault = MessageFault.CreateFault(code, new FaultReason(new FaultReasonText(SR.InternalServerError, CultureInfo.CurrentCulture))); return new FaultException(dispatchFault, FaultCodeConstants.Actions.NetDispatcher); } class WorkflowHostingContractBehavior : IContractBehavior { public void AddBindingParameters(ContractDescription contractDescription, ServiceEndpoint endpoint, BindingParameterCollection bindingParameters) { } public void ApplyClientBehavior(ContractDescription contractDescription, ServiceEndpoint endpoint, ClientRuntime clientRuntime) { } public void ApplyDispatchBehavior(ContractDescription contractDescription, ServiceEndpoint endpoint, DispatchRuntime dispatchRuntime) { Fx.Assert(endpoint is WorkflowHostingEndpoint, "Must be hosting endpoint!"); foreach (OperationDescription operation in contractDescription.Operations) { if (operation.Behaviors.Find () == null) { operation.Behaviors.Add(new WorkflowHostingOperationBehavior((WorkflowHostingEndpoint)endpoint)); } } } public void Validate(ContractDescription contractDescription, ServiceEndpoint endpoint) { Fx.Assert(endpoint is WorkflowHostingEndpoint, "Must be hosting endpoint!"); } class WorkflowHostingOperationBehavior : WorkflowOperationBehavior { WorkflowHostingEndpoint hostingEndpoint; public WorkflowHostingOperationBehavior(WorkflowHostingEndpoint hostingEndpoint) : base(true) { this.hostingEndpoint = hostingEndpoint; } protected internal override Bookmark OnResolveBookmark(WorkflowOperationContext context, out BookmarkScope bookmarkScope, out object value) { CorrelationMessageProperty correlationMessageProperty; if (CorrelationMessageProperty.TryGet(context.OperationContext.IncomingMessageProperties, out correlationMessageProperty)) { bookmarkScope = new BookmarkScope(correlationMessageProperty.CorrelationKey.Value); } else { bookmarkScope = null; } WorkflowHostingResponseContext responseContext = new WorkflowHostingResponseContext(context); Bookmark bookmark = this.hostingEndpoint.OnResolveBookmark(context.Inputs, context.OperationContext, responseContext, out value); if (bookmark == null) { throw FxTrace.Exception.AsError(CreateDispatchFaultException()); } return bookmark; } } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- CredentialSelector.cs
- DataPager.cs
- TrackingWorkflowEventArgs.cs
- CriticalFinalizerObject.cs
- CharEntityEncoderFallback.cs
- ObjectConverter.cs
- StrokeDescriptor.cs
- DbDataReader.cs
- StorageEntityTypeMapping.cs
- ViewSimplifier.cs
- base64Transforms.cs
- CompositeScriptReference.cs
- MaskInputRejectedEventArgs.cs
- Exception.cs
- BaseTemplateCodeDomTreeGenerator.cs
- Converter.cs
- EventMap.cs
- DataControlPagerLinkButton.cs
- SystemIcmpV4Statistics.cs
- TypeExtension.cs
- SizeAnimationBase.cs
- ClientSponsor.cs
- MeasureData.cs
- ColorAnimationBase.cs
- DataSourceCache.cs
- ListControlBoundActionList.cs
- JsonFormatReaderGenerator.cs
- NullReferenceException.cs
- DynamicValueConverter.cs
- Script.cs
- Thread.cs
- XmlDictionary.cs
- UpWmlPageAdapter.cs
- WindowsTokenRoleProvider.cs
- SessionPageStatePersister.cs
- WsatTransactionHeader.cs
- BitmapEncoder.cs
- EmptyArray.cs
- TextEndOfLine.cs
- UTF7Encoding.cs
- XmlBaseReader.cs
- WebBrowserSiteBase.cs
- BevelBitmapEffect.cs
- XmlNamespaceMapping.cs
- HotSpot.cs
- HandleExceptionArgs.cs
- DependencySource.cs
- GCHandleCookieTable.cs
- PageContentAsyncResult.cs
- BamlRecordWriter.cs
- TypeGeneratedEventArgs.cs
- TrackBar.cs
- TypeUsage.cs
- InkPresenter.cs
- SafeSecurityHandles.cs
- CodeIdentifiers.cs
- ApplicationFileParser.cs
- RijndaelManaged.cs
- SafeNativeMethods.cs
- RegisteredHiddenField.cs
- NameObjectCollectionBase.cs
- FilePresentation.cs
- InputDevice.cs
- ProcessModuleDesigner.cs
- Formatter.cs
- WebRequestModuleElement.cs
- TranslateTransform.cs
- ObjectHelper.cs
- URL.cs
- StringValidatorAttribute.cs
- ImageListStreamer.cs
- XmlSerializationReader.cs
- VectorAnimation.cs
- GridView.cs
- RelationshipWrapper.cs
- ImageClickEventArgs.cs
- LinearGradientBrush.cs
- SqlCommandSet.cs
- baseaxisquery.cs
- TextEffectResolver.cs
- ConfigurationLocation.cs
- Animatable.cs
- KeyboardInputProviderAcquireFocusEventArgs.cs
- EntityConnectionStringBuilder.cs
- TrustSection.cs
- COM2Properties.cs
- DataObjectAttribute.cs
- ProfessionalColorTable.cs
- GridItemPatternIdentifiers.cs
- ReaderContextStackData.cs
- ControlDesigner.cs
- BrowserTree.cs
- XmlObjectSerializerReadContextComplex.cs
- EntityEntry.cs
- StoreContentChangedEventArgs.cs
- HostedElements.cs
- WebReferencesBuildProvider.cs
- ReaderWriterLock.cs
- DataGridRow.cs
- XmlException.cs