StateMachineSubscription.cs source code in C# .NET

                        
Code:
                         / 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / WF / Activities / StateMachineSubscription.cs / 1305376 / StateMachineSubscription.cs
                        

                        
                            #region Using directives 

using System;
using System.Collections;
using System.Collections.Generic; 
using System.Collections.Specialized;
using System.Reflection; 
using System.Diagnostics; 
using System.Runtime.Remoting.Messaging;
using System.Workflow.ComponentModel; 
using System.Workflow.ComponentModel.Design;
using System.Workflow.Runtime;
using System.Workflow.Runtime.Hosting;
 
#endregion Using directives
 
namespace System.Workflow.Activities 
{
    #region StateMachineSubscription 

    [Serializable]
    internal abstract class StateMachineSubscription : IActivityEventListener
    { 
        #region Member Variables
 
        private Guid _subscriptionId; 

        #endregion Member Variables 

        #region Properties

        internal Guid SubscriptionId 
        {
            get 
            { 
                return _subscriptionId;
            } 
            set
            {
                _subscriptionId = value;
            } 
        }
 
        #endregion Properties 

        void IActivityEventListener.OnEvent(object sender, QueueEventArgs e) 
        {
            ActivityExecutionContext context = sender as ActivityExecutionContext;
            if (context == null)
                throw new ArgumentException(SR.Error_SenderMustBeActivityExecutionContext, "sender"); 

            Enqueue(context); 
        } 

        protected abstract void Enqueue(ActivityExecutionContext context); 
        internal abstract void ProcessEvent(ActivityExecutionContext context);
    }

    #endregion StateMachineSubscription 

    #region EventActivitySubscription 
 
    [Serializable]
    internal class EventActivitySubscription : StateMachineSubscription 
    {
        #region Member Variables

        private string _eventActivityName = String.Empty; 
        private string _eventDrivenName = String.Empty;
        private string _stateName = String.Empty; 
        private IComparable _queueName; 

        #endregion Member Variables 

        #region Properties

        internal string EventActivityName 
        {
            get 
            { 
                return _eventActivityName;
            } 
        }

        internal string StateName
        { 
            get
            { 
                return _stateName; 
            }
        } 

        internal IComparable QueueName
        {
            get 
            {
                return _queueName; 
            } 
        }
 
        internal string EventDrivenName
        {
            get
            { 
                return _eventDrivenName;
            } 
        } 

        #endregion Properties 

        internal void Subscribe(ActivityExecutionContext context,
            StateActivity state,
            IEventActivity eventActivity) 
        {
            eventActivity.Subscribe(context, this); 
            Activity activity = (Activity)eventActivity; 
            this._queueName = eventActivity.QueueName;
            this._eventActivityName = activity.QualifiedName; 
            this._stateName = state.QualifiedName;
            this.SubscriptionId = Guid.NewGuid();
            EventDrivenActivity eventDriven = StateMachineHelpers.GetParentEventDriven(eventActivity);
            this._eventDrivenName = eventDriven.QualifiedName; 
        }
 
        internal void Unsubscribe(ActivityExecutionContext context, 
            IEventActivity eventActivity)
        { 
            eventActivity.Unsubscribe(context, this);
        }

        protected override void Enqueue(ActivityExecutionContext context) 
        {
            StateActivity rootState = StateMachineHelpers.GetRootState((StateActivity)context.Activity); 
            StateMachineExecutionState executionState = StateMachineExecutionState.Get(rootState); 
            executionState.SubscriptionManager.Enqueue(context, this.QueueName);
        } 

        internal override void ProcessEvent(ActivityExecutionContext context)
        {
            StateActivity rootState = StateMachineHelpers.GetRootState((StateActivity)context.Activity); 
            StateMachineExecutionState executionState = StateMachineExecutionState.Get(rootState);
            ExternalEventAction action = new ExternalEventAction(this.StateName, this.EventDrivenName); 
            Debug.Assert(!executionState.HasEnqueuedActions); 
            executionState.EnqueueAction(action);
            executionState.ProcessActions(context); 
        }
    }

    #endregion EventActivitySubscription 

    #region SetStateSubscription 
 
    [Serializable]
    internal class SetStateSubscription : StateMachineSubscription 
    {
        private Guid _instanceId;

        internal SetStateSubscription(Guid instanceId) 
        {
            this._instanceId = instanceId; 
        } 

        internal void CreateQueue(ActivityExecutionContext context) 
        {
            if (!StateMachineHelpers.IsRootExecutionContext(context))
            {
                // we only subscribe to the set state event if 
                // we're at the root level. If this instance is
                // being called, it is not possible to set the 
                // state from the host side directly 
                return;
            } 

            WorkflowQueuingService workflowQueuingService = context.GetService();

            MessageEventSubscription subscription = new MessageEventSubscription( 
                StateMachineWorkflowActivity.SetStateQueueName,
                this._instanceId); 
 
            WorkflowQueue workflowQueue = workflowQueuingService.CreateWorkflowQueue(
                StateMachineWorkflowActivity.SetStateQueueName, 
                true);
            this.SubscriptionId = subscription.SubscriptionId;
        }
 
        internal void DeleteQueue(ActivityExecutionContext context)
        { 
            if (!StateMachineHelpers.IsRootExecutionContext(context)) 
            {
                // we only subscribe to the set state event if 
                // we're at the root level. If this instance is
                // being called, it is not possible to set the
                // state from the host side directly
                return; 
            }
 
            WorkflowQueuingService workflowQueuingService = context.GetService(); 
            WorkflowQueue workflowQueue = workflowQueuingService.GetWorkflowQueue(StateMachineWorkflowActivity.SetStateQueueName);
            workflowQueuingService.DeleteWorkflowQueue(StateMachineWorkflowActivity.SetStateQueueName); 
        }

        internal void Subscribe(ActivityExecutionContext context)
        { 
            WorkflowQueuingService workflowQueuingService = context.GetService();
            WorkflowQueue workflowQueue = workflowQueuingService.GetWorkflowQueue(StateMachineWorkflowActivity.SetStateQueueName); 
            workflowQueue.RegisterForQueueItemAvailable(this); 
        }
 
        internal void Unsubscribe(ActivityExecutionContext context)
        {
            WorkflowQueuingService workflowQueuingService = context.GetService();
            WorkflowQueue workflowQueue = workflowQueuingService.GetWorkflowQueue(StateMachineWorkflowActivity.SetStateQueueName); 
            workflowQueue.UnregisterForQueueItemAvailable(this);
        } 
 
        protected override void Enqueue(ActivityExecutionContext context)
        { 
            StateActivity rootState = StateMachineHelpers.GetRootState((StateActivity)context.Activity);
            StateMachineExecutionState executionState = StateMachineExecutionState.Get(rootState);
            executionState.SubscriptionManager.Enqueue(context, this.SubscriptionId);
        } 

        internal override void ProcessEvent(ActivityExecutionContext context) 
        { 
            WorkflowQueuingService workflowQueuingService = context.GetService();
            WorkflowQueue workflowQueue = workflowQueuingService.GetWorkflowQueue(StateMachineWorkflowActivity.SetStateQueueName); 
            SetStateEventArgs eventArgs = workflowQueue.Dequeue() as SetStateEventArgs;
            StateActivity currentState = StateMachineHelpers.GetCurrentState(context);
            if (currentState == null)
                throw new InvalidOperationException(SR.GetStateMachineWorkflowMustHaveACurrentState()); 

            StateActivity rootState = StateMachineHelpers.GetRootState((StateActivity)context.Activity); 
            StateMachineExecutionState executionState = StateMachineExecutionState.Get(rootState); 
            SetStateAction action = new SetStateAction(currentState.QualifiedName, eventArgs.TargetStateName);
            Debug.Assert(!executionState.HasEnqueuedActions); 
            executionState.EnqueueAction(action);
            executionState.ProcessActions(context);
        }
    } 

    #endregion SetStateSubscription 
} 

// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
// Copyright (c) Microsoft Corporation. All rights reserved.
#region Using directives 

using System;
using System.Collections;
using System.Collections.Generic; 
using System.Collections.Specialized;
using System.Reflection; 
using System.Diagnostics; 
using System.Runtime.Remoting.Messaging;
using System.Workflow.ComponentModel; 
using System.Workflow.ComponentModel.Design;
using System.Workflow.Runtime;
using System.Workflow.Runtime.Hosting;
 
#endregion Using directives
 
namespace System.Workflow.Activities 
{
    #region StateMachineSubscription 

    [Serializable]
    internal abstract class StateMachineSubscription : IActivityEventListener
    { 
        #region Member Variables
 
        private Guid _subscriptionId; 

        #endregion Member Variables 

        #region Properties

        internal Guid SubscriptionId 
        {
            get 
            { 
                return _subscriptionId;
            } 
            set
            {
                _subscriptionId = value;
            } 
        }
 
        #endregion Properties 

        void IActivityEventListener.OnEvent(object sender, QueueEventArgs e) 
        {
            ActivityExecutionContext context = sender as ActivityExecutionContext;
            if (context == null)
                throw new ArgumentException(SR.Error_SenderMustBeActivityExecutionContext, "sender"); 

            Enqueue(context); 
        } 

        protected abstract void Enqueue(ActivityExecutionContext context); 
        internal abstract void ProcessEvent(ActivityExecutionContext context);
    }

    #endregion StateMachineSubscription 

    #region EventActivitySubscription 
 
    [Serializable]
    internal class EventActivitySubscription : StateMachineSubscription 
    {
        #region Member Variables

        private string _eventActivityName = String.Empty; 
        private string _eventDrivenName = String.Empty;
        private string _stateName = String.Empty; 
        private IComparable _queueName; 

        #endregion Member Variables 

        #region Properties

        internal string EventActivityName 
        {
            get 
            { 
                return _eventActivityName;
            } 
        }

        internal string StateName
        { 
            get
            { 
                return _stateName; 
            }
        } 

        internal IComparable QueueName
        {
            get 
            {
                return _queueName; 
            } 
        }
 
        internal string EventDrivenName
        {
            get
            { 
                return _eventDrivenName;
            } 
        } 

        #endregion Properties 

        internal void Subscribe(ActivityExecutionContext context,
            StateActivity state,
            IEventActivity eventActivity) 
        {
            eventActivity.Subscribe(context, this); 
            Activity activity = (Activity)eventActivity; 
            this._queueName = eventActivity.QueueName;
            this._eventActivityName = activity.QualifiedName; 
            this._stateName = state.QualifiedName;
            this.SubscriptionId = Guid.NewGuid();
            EventDrivenActivity eventDriven = StateMachineHelpers.GetParentEventDriven(eventActivity);
            this._eventDrivenName = eventDriven.QualifiedName; 
        }
 
        internal void Unsubscribe(ActivityExecutionContext context, 
            IEventActivity eventActivity)
        { 
            eventActivity.Unsubscribe(context, this);
        }

        protected override void Enqueue(ActivityExecutionContext context) 
        {
            StateActivity rootState = StateMachineHelpers.GetRootState((StateActivity)context.Activity); 
            StateMachineExecutionState executionState = StateMachineExecutionState.Get(rootState); 
            executionState.SubscriptionManager.Enqueue(context, this.QueueName);
        } 

        internal override void ProcessEvent(ActivityExecutionContext context)
        {
            StateActivity rootState = StateMachineHelpers.GetRootState((StateActivity)context.Activity); 
            StateMachineExecutionState executionState = StateMachineExecutionState.Get(rootState);
            ExternalEventAction action = new ExternalEventAction(this.StateName, this.EventDrivenName); 
            Debug.Assert(!executionState.HasEnqueuedActions); 
            executionState.EnqueueAction(action);
            executionState.ProcessActions(context); 
        }
    }

    #endregion EventActivitySubscription 

    #region SetStateSubscription 
 
    [Serializable]
    internal class SetStateSubscription : StateMachineSubscription 
    {
        private Guid _instanceId;

        internal SetStateSubscription(Guid instanceId) 
        {
            this._instanceId = instanceId; 
        } 

        internal void CreateQueue(ActivityExecutionContext context) 
        {
            if (!StateMachineHelpers.IsRootExecutionContext(context))
            {
                // we only subscribe to the set state event if 
                // we're at the root level. If this instance is
                // being called, it is not possible to set the 
                // state from the host side directly 
                return;
            } 

            WorkflowQueuingService workflowQueuingService = context.GetService();

            MessageEventSubscription subscription = new MessageEventSubscription( 
                StateMachineWorkflowActivity.SetStateQueueName,
                this._instanceId); 
 
            WorkflowQueue workflowQueue = workflowQueuingService.CreateWorkflowQueue(
                StateMachineWorkflowActivity.SetStateQueueName, 
                true);
            this.SubscriptionId = subscription.SubscriptionId;
        }
 
        internal void DeleteQueue(ActivityExecutionContext context)
        { 
            if (!StateMachineHelpers.IsRootExecutionContext(context)) 
            {
                // we only subscribe to the set state event if 
                // we're at the root level. If this instance is
                // being called, it is not possible to set the
                // state from the host side directly
                return; 
            }
 
            WorkflowQueuingService workflowQueuingService = context.GetService(); 
            WorkflowQueue workflowQueue = workflowQueuingService.GetWorkflowQueue(StateMachineWorkflowActivity.SetStateQueueName);
            workflowQueuingService.DeleteWorkflowQueue(StateMachineWorkflowActivity.SetStateQueueName); 
        }

        internal void Subscribe(ActivityExecutionContext context)
        { 
            WorkflowQueuingService workflowQueuingService = context.GetService();
            WorkflowQueue workflowQueue = workflowQueuingService.GetWorkflowQueue(StateMachineWorkflowActivity.SetStateQueueName); 
            workflowQueue.RegisterForQueueItemAvailable(this); 
        }
 
        internal void Unsubscribe(ActivityExecutionContext context)
        {
            WorkflowQueuingService workflowQueuingService = context.GetService();
            WorkflowQueue workflowQueue = workflowQueuingService.GetWorkflowQueue(StateMachineWorkflowActivity.SetStateQueueName); 
            workflowQueue.UnregisterForQueueItemAvailable(this);
        } 
 
        protected override void Enqueue(ActivityExecutionContext context)
        { 
            StateActivity rootState = StateMachineHelpers.GetRootState((StateActivity)context.Activity);
            StateMachineExecutionState executionState = StateMachineExecutionState.Get(rootState);
            executionState.SubscriptionManager.Enqueue(context, this.SubscriptionId);
        } 

        internal override void ProcessEvent(ActivityExecutionContext context) 
        { 
            WorkflowQueuingService workflowQueuingService = context.GetService();
            WorkflowQueue workflowQueue = workflowQueuingService.GetWorkflowQueue(StateMachineWorkflowActivity.SetStateQueueName); 
            SetStateEventArgs eventArgs = workflowQueue.Dequeue() as SetStateEventArgs;
            StateActivity currentState = StateMachineHelpers.GetCurrentState(context);
            if (currentState == null)
                throw new InvalidOperationException(SR.GetStateMachineWorkflowMustHaveACurrentState()); 

            StateActivity rootState = StateMachineHelpers.GetRootState((StateActivity)context.Activity); 
            StateMachineExecutionState executionState = StateMachineExecutionState.Get(rootState); 
            SetStateAction action = new SetStateAction(currentState.QualifiedName, eventArgs.TargetStateName);
            Debug.Assert(!executionState.HasEnqueuedActions); 
            executionState.EnqueueAction(action);
            executionState.ProcessActions(context);
        }
    } 

    #endregion SetStateSubscription 
} 

// 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

• ColumnReorderedEventArgs.cs
• LocalIdKeyIdentifierClause.cs
• PostBackOptions.cs
• EmulateRecognizeCompletedEventArgs.cs
• WebPartActionVerb.cs
• LinqDataSourceEditData.cs
• SecurityPolicySection.cs
• SafeBitVector32.cs
• Rules.cs
• XmlQualifiedNameTest.cs
• StickyNote.cs
• IndexedString.cs
• HttpInputStream.cs
• StorageRoot.cs
• ContentElementAutomationPeer.cs
• FixedElement.cs
• RadioButtonPopupAdapter.cs
• DateTimeUtil.cs
• AsyncResult.cs
• NetworkInterface.cs
• BlurBitmapEffect.cs
• SelectionPattern.cs
• ProviderConnectionPoint.cs
• SelectingProviderEventArgs.cs
• SafeRightsManagementPubHandle.cs
• ToolStripDropDownButton.cs
• Int32Collection.cs
• ReadContentAsBinaryHelper.cs
• SafeThreadHandle.cs
• AddDataControlFieldDialog.cs
• ExpressionVisitorHelpers.cs
• QuotedStringWriteStateInfo.cs
• AssociativeAggregationOperator.cs
• XmlSchemaException.cs
• SocketElement.cs
• OleDbDataReader.cs
• ApplicationManager.cs
• StylusPointPropertyInfoDefaults.cs
• ThicknessAnimationBase.cs
• FormatterServices.cs
• EmptyWorkItem.cs
• ExecutionContext.cs
• JournalNavigationScope.cs
• ErrorWebPart.cs
• DetailsViewRowCollection.cs
• XpsException.cs
• DefaultBinder.cs
• MatrixTransform3D.cs
• ToolStripSplitStackLayout.cs
• EndEvent.cs
• ErrorWrapper.cs
• GcSettings.cs
• ControlEvent.cs
• SystemDropShadowChrome.cs
• Win32Interop.cs
• BindingExpression.cs
• TailPinnedEventArgs.cs
• ScaleTransform3D.cs
• TableItemProviderWrapper.cs
• MulticastDelegate.cs
• GeneralTransform3D.cs
• ToolboxSnapDragDropEventArgs.cs
• LinqDataView.cs
• GridEntry.cs
• EntityDataSourceContextDisposingEventArgs.cs
• LambdaCompiler.cs
• PropertyPathWorker.cs
• XmlSchemaChoice.cs
• ObjectSelectorEditor.cs
• __ConsoleStream.cs
• SpotLight.cs
• RandomNumberGenerator.cs
• IPGlobalProperties.cs
• LayoutTable.cs
• Vector3DAnimation.cs
• Select.cs
• PolyLineSegmentFigureLogic.cs
• UnauthorizedWebPart.cs
• IsolatedStorageFilePermission.cs
• AnimatedTypeHelpers.cs
• RuleSetDialog.Designer.cs
• ObjectIDGenerator.cs
• RichTextBoxConstants.cs
• WebHeaderCollection.cs
• safex509handles.cs
• DesignerAttributeInfo.cs
• ListViewDataItem.cs
• ConnectionStringsSection.cs
• ObjectItemNoOpAssemblyLoader.cs
• PasswordBox.cs
• ProgressBarAutomationPeer.cs
• KeyGestureConverter.cs
• EntityDataSourceChangedEventArgs.cs
• LightweightCodeGenerator.cs
• DiscoveryServiceExtension.cs
• ToolStripDesignerUtils.cs
• ReflectionUtil.cs
• QueueSurrogate.cs
• OverrideMode.cs
• PropertyPathWorker.cs