Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / NetFx40 / System.ServiceModel.Activities / System / ServiceModel / Activities / SendReply.cs / 1480445 / SendReply.cs
//------------------------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------------------------- namespace System.ServiceModel.Activities { using System.Activities; using System.Activities.Statements; using System.Collections.ObjectModel; using System.ComponentModel; using System.Runtime; using System.ServiceModel.Channels; using System.ServiceModel.Dispatcher; using System.Windows.Markup; using System.Xml.Linq; // Used to send the reply in a request/reply messaging pattern. Must be paired with // a corresponding Receive activity. [ContentProperty("Content")] public sealed class SendReply : Activity { CollectioncorrelationInitializers; ToReply responseFormatter; InternalSendMessage internalSend; public SendReply() : base() { base.Implementation = () => { // if CacheMetadata isn't called, bail early if (this.internalSend == null) { return null; } if (this.responseFormatter == null) // untyped message { return this.internalSend; } else { Variable response = new Variable { Name = "ResponseMessage" }; this.responseFormatter.Message = new OutArgument (response); this.internalSend.Message = new InArgument (response); // This is used to clear out the response variable this.internalSend.MessageOut = new OutArgument (response); return new Sequence { Variables = { response }, Activities = { this.responseFormatter, this.internalSend } }; } }; } // the content to send (either message or parameters-based) declared by the user [DefaultValue(null)] public SendContent Content { get; set; } // Internally, we should always use InternalContent since this property may have default content that we added internal SendContent InternalContent { get { return this.Content ?? SendContent.DefaultSendContent; } } // Reference to the Receive activity that is responsible for receiving the Request part of the // request/reply pattern. This cannot be null. [DefaultValue(null)] public Receive Request { get; set; } [DefaultValue(null)] public string Action { get; set; } // Additional correlations allow situations where a "session" involves multiple // messages between two workflow instances. [DefaultValue(null)] public Collection CorrelationInitializers { get { if (this.correlationInitializers == null) { this.correlationInitializers = new Collection (); } return this.correlationInitializers; } } // used to ensure that the other side gets ALO behavior [DefaultValue(false)] public bool PersistBeforeSend { get; set; } protected override void CacheMetadata(ActivityMetadata metadata) { if (this.Request == null) { metadata.AddValidationError(SR.SendReplyRequestCannotBeNull(this.DisplayName)); } // validate Correlation Initializers MessagingActivityHelper.ValidateCorrelationInitializer(metadata, this.correlationInitializers, true, this.DisplayName, (this.Request != null ? this.Request.OperationName : String.Empty)); // Validate Content string operationName = this.Request != null ? this.Request.OperationName : null; this.InternalContent.CacheMetadata(metadata, 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.internalSend = CreateInternalSend(); this.InternalContent.ConfigureInternalSendReply(this.internalSend, out this.responseFormatter); InArgument requestReplyHandleFromReceive = GetReplyHandleFromReceive(); if (requestReplyHandleFromReceive != null) { InArgument internalSendCorrelatesWith = MessagingActivityHelper.CreateReplyCorrelatesWith(requestReplyHandleFromReceive); RuntimeArgument internalSendCorrelatesWithArgument = new RuntimeArgument("InternalSendCorrelatesWith", Constants.CorrelationHandleType, ArgumentDirection.In); metadata.Bind(internalSendCorrelatesWith, internalSendCorrelatesWithArgument); metadata.AddArgument(internalSendCorrelatesWithArgument); this.internalSend.CorrelatesWith = (InArgument )InArgument.CreateReference(internalSendCorrelatesWith, "InternalSendCorrelatesWith"); if (this.responseFormatter != null) { InArgument responseFormatterCorrelatesWith = MessagingActivityHelper.CreateReplyCorrelatesWith(requestReplyHandleFromReceive); RuntimeArgument responseFormatterCorrelatesWithArgument = new RuntimeArgument("ResponseFormatterCorrelatesWith", Constants.CorrelationHandleType, ArgumentDirection.In); metadata.Bind(responseFormatterCorrelatesWith, responseFormatterCorrelatesWithArgument); metadata.AddArgument(responseFormatterCorrelatesWithArgument); responseFormatter.CorrelatesWith = (InArgument )InArgument.CreateReference(responseFormatterCorrelatesWith, "ResponseFormatterCorrelatesWith"); } } } else { this.internalSend = null; this.responseFormatter = null; } // We don't have any imported children despite referencing the Request metadata.SetImportedChildrenCollection(new Collection ()); } // responseFormatter is null if we have an untyped message situation InternalSendMessage CreateInternalSend() { InternalSendMessage result = new InternalSendMessage { IsSendReply = true, //indicates that we are sending a reply(server-side) ShouldPersistBeforeSend = this.PersistBeforeSend, OperationName = this.Request.OperationName, //need this for displaying error messages }; if (this.correlationInitializers != null) { foreach (CorrelationInitializer correlation in this.correlationInitializers) { result.CorrelationInitializers.Add(correlation.Clone()); } } return result; } internal void SetFormatter(IDispatchMessageFormatter formatter) { Fx.Assert(this.responseFormatter != null, "ToReply cannot be null!"); this.responseFormatter.Formatter = formatter; } internal void SetFaultFormatter(IDispatchFaultFormatter faultFormatter, bool includeExceptionDetailInFaults) { Fx.Assert(this.responseFormatter != null, "ToReply cannot be null!"); this.responseFormatter.FaultFormatter = faultFormatter; this.responseFormatter.IncludeExceptionDetailInFaults = includeExceptionDetailInFaults; } internal void SetContractName(XName contractName) { Fx.Assert(this.internalSend != null, "InternalSend cannot be null!"); this.internalSend.ServiceContractName = contractName; } InArgument GetReplyHandleFromReceive() { if (this.Request != null) { //if the user has set AdditionalCorrelations, then we need to first look for requestReply Handle there foreach(CorrelationInitializer correlation in this.Request.CorrelationInitializers) { RequestReplyCorrelationInitializer requestReplyCorrelation = correlation as RequestReplyCorrelationInitializer; if (requestReplyCorrelation != null && requestReplyCorrelation.CorrelationHandle != null) { return requestReplyCorrelation.CorrelationHandle; } } } return null; } } } // 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
- RegistryConfigurationProvider.cs
- ComboBox.cs
- SafeFileHandle.cs
- LongPath.cs
- Cloud.cs
- ChannelManager.cs
- EncryptedReference.cs
- ProfilePropertyNameValidator.cs
- CustomCredentialPolicy.cs
- AdvancedBindingEditor.cs
- FillBehavior.cs
- TextSimpleMarkerProperties.cs
- BaseValidator.cs
- GroupJoinQueryOperator.cs
- WorkflowMarkupSerializationManager.cs
- IriParsingElement.cs
- odbcmetadatafactory.cs
- DataError.cs
- TcpHostedTransportConfiguration.cs
- TreeNodeConverter.cs
- DataGridViewColumnHeaderCell.cs
- WMIGenerator.cs
- XPathQueryGenerator.cs
- TextBoxDesigner.cs
- ParserExtension.cs
- XsdBuildProvider.cs
- securitycriticaldata.cs
- CollectionChangeEventArgs.cs
- NetWebProxyFinder.cs
- ManagementQuery.cs
- MultiPropertyDescriptorGridEntry.cs
- PtsCache.cs
- XmlSchemaAny.cs
- TakeQueryOptionExpression.cs
- Assert.cs
- FacetDescriptionElement.cs
- TileModeValidation.cs
- TdsRecordBufferSetter.cs
- KerberosTokenFactoryCredential.cs
- SmiMetaDataProperty.cs
- HttpRuntime.cs
- Model3DGroup.cs
- WebReferencesBuildProvider.cs
- XmlCharacterData.cs
- Paragraph.cs
- Transform3D.cs
- GridViewUpdatedEventArgs.cs
- StateChangeEvent.cs
- ObjectViewListener.cs
- GenericUI.cs
- NativeMethods.cs
- PointHitTestResult.cs
- GridViewRow.cs
- GeneralTransformGroup.cs
- WorkflowServiceNamespace.cs
- EntitySqlQueryBuilder.cs
- PropertyValueUIItem.cs
- ProxyWebPart.cs
- DataSet.cs
- Query.cs
- TextBoxRenderer.cs
- securitycriticaldataClass.cs
- HtmlEmptyTagControlBuilder.cs
- TemplatedWizardStep.cs
- OuterGlowBitmapEffect.cs
- MeasureItemEvent.cs
- DataGridViewLayoutData.cs
- SqlCaseSimplifier.cs
- CompilerInfo.cs
- TrackBar.cs
- StateMachineHistory.cs
- PageCatalogPart.cs
- CodeDirectionExpression.cs
- DataGridToolTip.cs
- DataGridRowHeader.cs
- RequestCacheEntry.cs
- CheckBoxStandardAdapter.cs
- EntityViewGenerationAttribute.cs
- EncryptedPackageFilter.cs
- WmlObjectListAdapter.cs
- XhtmlBasicImageAdapter.cs
- PropertyGridDesigner.cs
- WindowsFormsSynchronizationContext.cs
- SamlAuthorizationDecisionClaimResource.cs
- System.Data.OracleClient_BID.cs
- SafeTimerHandle.cs
- DataTemplateKey.cs
- ConnectionsZone.cs
- OwnerDrawPropertyBag.cs
- DispatcherExceptionEventArgs.cs
- RegistryKey.cs
- XmlComplianceUtil.cs
- selecteditemcollection.cs
- ContextBase.cs
- Function.cs
- DataReceivedEventArgs.cs
- SendSecurityHeaderElement.cs
- TextRangeAdaptor.cs
- RectKeyFrameCollection.cs
- RuntimeResourceSet.cs