Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / NetFx40 / System.ServiceModel.Activities / System / ServiceModel / Activities / Receive.cs / 1305376 / Receive.cs
//------------------------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------------------------- namespace System.ServiceModel.Activities { using System.Activities; using System.Activities.Expressions; using System.Activities.Statements; using System.Collections.Generic; using System.Collections.ObjectModel; using System.ComponentModel; using System.Diagnostics.CodeAnalysis; using System.Net.Security; using System.Runtime; using System.ServiceModel.Activities.Description; using System.ServiceModel.Channels; using System.ServiceModel.Description; using System.ServiceModel.Dispatcher; using System.ServiceModel.XamlIntegration; using System.Windows.Markup; using System.Xml.Linq; [ContentProperty("Content")] public sealed class Receive : Activity { MessageQuerySet correlatesOn; CollectioncorrelationInitializers; Collection knownTypes; // Used by contract-inference to build the ServiceDescription IList followingReplies; IList followingFaults; // cached by base.Implementation invocation InternalReceiveMessage internalReceive; FromRequest requestFormatter; public Receive() : base() { base.Implementation = () => { // if CacheMetadata isn't called, bail early if (this.internalReceive == null) { return null; } // requestFormatter is null if we have an untyped message situation if (this.requestFormatter == null) { return this.internalReceive; } else { Variable request = new Variable { Name = "RequestMessage" }; Variable noPersistHandle = new Variable { Name = "ReceiveNoPersistHandle" }; this.internalReceive.Message = new OutArgument (request); this.requestFormatter.Message = new InOutArgument (request); this.internalReceive.NoPersistHandle = new InArgument (noPersistHandle); this.requestFormatter.NoPersistHandle = new InArgument (noPersistHandle); return new Sequence { Variables = { request, noPersistHandle }, Activities = { this.internalReceive, this.requestFormatter } }; } }; } [SuppressMessage(FxCop.Category.Usage, FxCop.Rule.CollectionPropertiesShouldBeReadOnly, Justification = "MessageQuerySet is a stand-alone class. We want to allow users to create their own.")] [SuppressMessage(FxCop.Category.Xaml, FxCop.Rule.PropertyExternalTypesMustBeKnown, Justification = "MessageQuerySet is a known XAML-serializable type in this assembly.")] public MessageQuerySet CorrelatesOn { get { if (this.correlatesOn == null) { this.correlatesOn = new MessageQuerySet(); } return this.correlatesOn; } set { this.correlatesOn = value; } } // the content to receive (either message or parameters-based) declared by the user [DefaultValue(null)] public ReceiveContent Content { get; set; } // Internally, we should always use InternalContent since this property may have default content that we added internal ReceiveContent InternalContent { get { return this.Content ?? ReceiveContent.DefaultReceiveContent; } } // For initializing additional correlations beyond the Correlation property for following // activiites. public Collection CorrelationInitializers { get { if (this.correlationInitializers == null) { this.correlationInitializers = new Collection (); } return this.correlationInitializers; } } // Allows the action for the message to be specified by the user/designer. // If not set, the value is constructed from the Name of the activity. // If specified on the Send side of a message, the Receive side needs to have the same value in order // for the message to be delivered correctly. [DefaultValue(null)] public string Action { get; set; } // If true, a new workflow instance is creted to process the message. If false, an existing workflow // instance is determined based on correlations. [DefaultValue(false)] public bool CanCreateInstance { get; set; } [DefaultValue(null)] public InArgument CorrelatesWith { get; set; } // This will be used to construct the default value for Action if the Action property is // not specifically set. It is also used in conjunction with CorrelatesWith and IsReply // to determine which Send and Receive activities make up a Request/Reply combination. // There is validation to make sure either this or Action has a value. // Used by IServiceDescriptionBuilder2 as well [DefaultValue(null)] public string OperationName { get; set; } // The protection level for the message. // If ValueType or Value.Expression.ExpressionType is MessageContract, the MessageContract definition may have additional settings. // Default if this is not specified is Sign. [DefaultValue(null)] public ProtectionLevel? ProtectionLevel { get; set; } [DefaultValue(SerializerOption.DataContractSerializer)] public SerializerOption SerializerOption { get; set; } // The service contract name. This allows the same workflow instance to implement multiple // servce "contracts". If not specified and this is the first Receive activity in the // workflow, contract inference uses this activity's Name as the service contract name. [DefaultValue(null)] [TypeConverter(typeof(ServiceXNameTypeConverter))] public XName ServiceContractName { get; set; } public Collection KnownTypes { get { if (this.knownTypes == null) { this.knownTypes = new Collection (); } return this.knownTypes; } } internal string OperationBookmarkName { get { Fx.Assert(this.internalReceive != null, "CacheMetadata must be called before this!"); return this.internalReceive.OperationBookmarkName; } } internal Collection InternalKnownTypes { get { // avoid the allocation if internal return this.knownTypes; } } internal bool HasCorrelatesOn { get { return this.correlatesOn != null && this.correlatesOn.Count > 0; } } internal bool HasCorrelationInitializers { get { return this.correlationInitializers != null && this.correlationInitializers.Count > 0; } } internal IList FollowingReplies { get { if (this.followingReplies == null) { this.followingReplies = new List (); } return this.followingReplies; } } internal IList FollowingFaults { get { if (this.followingFaults == null) { this.followingFaults = new List (); } return this.followingFaults; } } internal bool HasReply { get { return this.followingReplies != null && this.followingReplies.Count > 0; } } internal bool HasFault { get { return this.followingFaults != null && this.followingFaults.Count > 0; } } internal InternalReceiveMessage InternalReceive { get { return this.internalReceive; } } protected override void CacheMetadata(ActivityMetadata metadata) { if (string.IsNullOrEmpty(this.OperationName)) { metadata.AddValidationError(SR.MissingOperationName(this.DisplayName)); } // validate Correlation Initializers MessagingActivityHelper.ValidateCorrelationInitializer(metadata, this.correlationInitializers, false, this.DisplayName, this.OperationName); // Add runtime arguments MessagingActivityHelper.AddRuntimeArgument(this.CorrelatesWith, "CorrelatesWith", Constants.CorrelationHandleType, ArgumentDirection.In, metadata); // Validate Content this.InternalContent.CacheMetadata(metadata, this, this.OperationName); if (this.correlationInitializers != null) { for (int i = 0; i < this.correlationInitializers.Count; i++) { CorrelationInitializer initializer = this.correlationInitializers[i]; initializer.ArgumentName = Constants.Parameter + i; RuntimeArgument initializerArgument = new RuntimeArgument(initializer.ArgumentName, Constants.CorrelationHandleType, ArgumentDirection.In); metadata.Bind(initializer.CorrelationHandle, initializerArgument); metadata.AddArgument(initializerArgument); } } if (!metadata.HasViolations) { this.internalReceive = CreateInternalReceive(); this.InternalContent.ConfigureInternalReceive(this.internalReceive, out this.requestFormatter); } else { this.internalReceive = null; this.requestFormatter = null; } } InternalReceiveMessage CreateInternalReceive() { InternalReceiveMessage result = new InternalReceiveMessage { OperationName = this.OperationName, ServiceContractName = this.ServiceContractName, CorrelatesWith = new InArgument (new ArgumentValue { ArgumentName = "CorrelatesWith" }), IsOneWay = true // This will be updated by contract inference logic, }; if (this.correlationInitializers != null) { foreach (CorrelationInitializer correlation in this.correlationInitializers) { result.CorrelationInitializers.Add(correlation.Clone()); } } return result; } internal void SetIsOneWay(bool flag) { Fx.Assert(this.internalReceive != null, "InternalReceiveMessage cannot be null!"); this.internalReceive.IsOneWay = flag; // perf optimization if the receive is two way, null out the NoPersistHandle, // this optimization allows us not to access AEC in InternalReceiveMessage->Execute to null out the // NoPersistHandle in case of two-way. With this optimization, we just assert in InternalReceiveMessage if (!this.internalReceive.IsOneWay) { this.internalReceive.NoPersistHandle = null; if (this.requestFormatter != null) { this.requestFormatter.NoPersistHandle = null; } } else { // For oneway operations the FromRequest should close the message if (this.requestFormatter != null) { this.requestFormatter.CloseMessage = true; } } } internal void SetFormatter(IDispatchMessageFormatter formatter, IDispatchFaultFormatter faultFormatter, bool includeExceptionDetailInFaults) { Fx.Assert(this.requestFormatter != null, "FromRequest cannot be null!"); this.requestFormatter.Formatter = formatter; if (this.followingReplies != null) { for (int i = 0; i < this.followingReplies.Count; i++) { this.followingReplies[i].SetFormatter(formatter); } } if (this.followingFaults != null) { for (int i = 0; i < this.followingFaults.Count; i++) { this.followingFaults[i].SetFaultFormatter(faultFormatter, includeExceptionDetailInFaults); } } } [EditorBrowsable(EditorBrowsableState.Never)] public bool ShouldSerializeCorrelatesOn() { // don't serialize null nor default MessageQuerySet if (this.correlatesOn == null || (this.correlatesOn.Name == null && this.correlatesOn.Count == 0)) { return false; } return true; } } } // 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
- XmlSchemaException.cs
- InvocationExpression.cs
- MenuCommandsChangedEventArgs.cs
- UnmanagedBitmapWrapper.cs
- SoundPlayer.cs
- coordinator.cs
- Matrix3D.cs
- TableLayout.cs
- ObjectSecurity.cs
- SqlError.cs
- HandlerBase.cs
- UniqueEventHelper.cs
- SoundPlayer.cs
- BaseCollection.cs
- EntityContainerEmitter.cs
- mactripleDES.cs
- TextRenderingModeValidation.cs
- ListenerAdaptersInstallComponent.cs
- versioninfo.cs
- SafeNativeMethods.cs
- sitestring.cs
- HttpListenerRequestUriBuilder.cs
- ProcessModuleCollection.cs
- SrgsRule.cs
- LinqDataSourceStatusEventArgs.cs
- TaskFormBase.cs
- StateWorkerRequest.cs
- FlowDocumentView.cs
- VirtualPathData.cs
- EnvironmentPermission.cs
- DrawingContext.cs
- ConnectionPointConverter.cs
- RelatedImageListAttribute.cs
- KnowledgeBase.cs
- TextElementCollectionHelper.cs
- RequestQueue.cs
- SvcMapFileLoader.cs
- CodeChecksumPragma.cs
- PeerObject.cs
- SqlDuplicator.cs
- HttpConfigurationSystem.cs
- OracleLob.cs
- ResXResourceSet.cs
- PersistChildrenAttribute.cs
- ClientApiGenerator.cs
- ItemDragEvent.cs
- EventSinkActivity.cs
- FragmentNavigationEventArgs.cs
- ArrayTypeMismatchException.cs
- CopyOfAction.cs
- MimeWriter.cs
- XmlSerializerNamespaces.cs
- WasAdminWrapper.cs
- WebPartHelpVerb.cs
- MultiTrigger.cs
- DataControlFieldHeaderCell.cs
- SettingsSection.cs
- HtmlInputReset.cs
- ECDsaCng.cs
- WebServiceData.cs
- NavigationPropertyEmitter.cs
- ValidatedControlConverter.cs
- SerTrace.cs
- WebPartManagerInternals.cs
- WindowCollection.cs
- SystemIPAddressInformation.cs
- InvalidComObjectException.cs
- RuntimeConfigurationRecord.cs
- LazyTextWriterCreator.cs
- DataSourceControl.cs
- MenuCommands.cs
- ListViewInsertionMark.cs
- Point3D.cs
- CacheDependency.cs
- serverconfig.cs
- Scripts.cs
- AuthenticatingEventArgs.cs
- ExpressionsCollectionConverter.cs
- ApplicationFileParser.cs
- TextBlock.cs
- TemplateManager.cs
- TemplateKey.cs
- AttributeSetAction.cs
- TextOptionsInternal.cs
- ProcessRequestArgs.cs
- NavigationService.cs
- RawMouseInputReport.cs
- XmlSchemaExporter.cs
- QuadraticBezierSegment.cs
- CodeCommentStatementCollection.cs
- GridViewHeaderRowPresenterAutomationPeer.cs
- LayoutDump.cs
- ClientSideProviderDescription.cs
- XmlEncodedRawTextWriter.cs
- Debugger.cs
- ProfileManager.cs
- Crypto.cs
- DataGrid.cs
- BaseTreeIterator.cs
- BooleanSwitch.cs