FollowerQueueCreator.cs source code in C# .NET

Source code for the .NET framework in C#

                        
Code:

                         / 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / WF / Activities / LocalService / FollowerQueueCreator.cs / 1305376 / FollowerQueueCreator.cs
                        

                        
                            #region Using directives 

using System;
using System.Diagnostics;
using System.Collections.Generic; 
using System.Collections;
using System.Reflection; 
using System.Runtime.Serialization; 
using System.Workflow.ComponentModel;
using System.Workflow.Runtime; 
using System.Workflow.Runtime.Hosting;
using System.Runtime.Remoting.Messaging;

#endregion 

namespace System.Workflow.Activities 
{ 
    [Serializable]
    internal sealed class FollowerQueueCreator : IActivityEventListener 
    {
        string followerOperation;
        object [....] = new object();
 
        internal FollowerQueueCreator(string operation)
        { 
            this.followerOperation = operation; 
        }
 
        public override bool Equals(object obj)
        {
            if (obj == null)
                return false; 
            FollowerQueueCreator equalsObject = obj as FollowerQueueCreator;
            if (this.followerOperation == equalsObject.followerOperation) 
                return true; 
            return false;
        } 
        public override int GetHashCode()
        {
            return this.followerOperation.GetHashCode();
        } 

        #region IActivityEventListener Members 
 
        void IActivityEventListener.OnEvent(object sender, QueueEventArgs args)
        { 
            lock ([....])
            {
                WorkflowQueue queue = (WorkflowQueue)sender;
 
                // create the queue after extracting the correlation values from the message
                EventQueueName staticId = (EventQueueName)queue.QueueName; 
                WorkflowActivityTrace.Activity.TraceEvent(TraceEventType.Information, 0, "FollowerQueueCreator: initialized on operation {0} for follower {1}", staticId.InterfaceType.Name + staticId.MethodName, this.followerOperation); 

                IMethodMessage message = queue.Peek() as IMethodMessage; 

                ICollection corrValues = CorrelationResolver.ResolveCorrelationValues(staticId.InterfaceType, staticId.MethodName, message.Args, false);

                EventQueueName queueName = new EventQueueName(staticId.InterfaceType, this.followerOperation, corrValues); 
                if (!queue.QueuingService.Exists(queueName))
                { 
                    WorkflowActivityTrace.Activity.TraceEvent(TraceEventType.Information, 0, "FollowerQueueCreator::CreateQueue creating q {0}", queueName.GetHashCode()); 
                    queue.QueuingService.CreateWorkflowQueue(queueName, true);
                } 
            }
        }

        #endregion 
    }
} 

// 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.Diagnostics;
using System.Collections.Generic; 
using System.Collections;
using System.Reflection; 
using System.Runtime.Serialization; 
using System.Workflow.ComponentModel;
using System.Workflow.Runtime; 
using System.Workflow.Runtime.Hosting;
using System.Runtime.Remoting.Messaging;

#endregion 

namespace System.Workflow.Activities 
{ 
    [Serializable]
    internal sealed class FollowerQueueCreator : IActivityEventListener 
    {
        string followerOperation;
        object [....] = new object();
 
        internal FollowerQueueCreator(string operation)
        { 
            this.followerOperation = operation; 
        }
 
        public override bool Equals(object obj)
        {
            if (obj == null)
                return false; 
            FollowerQueueCreator equalsObject = obj as FollowerQueueCreator;
            if (this.followerOperation == equalsObject.followerOperation) 
                return true; 
            return false;
        } 
        public override int GetHashCode()
        {
            return this.followerOperation.GetHashCode();
        } 

        #region IActivityEventListener Members 
 
        void IActivityEventListener.OnEvent(object sender, QueueEventArgs args)
        { 
            lock ([....])
            {
                WorkflowQueue queue = (WorkflowQueue)sender;
 
                // create the queue after extracting the correlation values from the message
                EventQueueName staticId = (EventQueueName)queue.QueueName; 
                WorkflowActivityTrace.Activity.TraceEvent(TraceEventType.Information, 0, "FollowerQueueCreator: initialized on operation {0} for follower {1}", staticId.InterfaceType.Name + staticId.MethodName, this.followerOperation); 

                IMethodMessage message = queue.Peek() as IMethodMessage; 

                ICollection corrValues = CorrelationResolver.ResolveCorrelationValues(staticId.InterfaceType, staticId.MethodName, message.Args, false);

                EventQueueName queueName = new EventQueueName(staticId.InterfaceType, this.followerOperation, corrValues); 
                if (!queue.QueuingService.Exists(queueName))
                { 
                    WorkflowActivityTrace.Activity.TraceEvent(TraceEventType.Information, 0, "FollowerQueueCreator::CreateQueue creating q {0}", queueName.GetHashCode()); 
                    queue.QueuingService.CreateWorkflowQueue(queueName, true);
                } 
            }
        }

        #endregion 
    }
} 

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

Link Menu

Network programming in C#, Network Programming in VB.NET, Network Programming in .NET
This book is available now!
Buy at Amazon US or
Buy at Amazon UK