Code:
/ 4.0 / 4.0 / untmp / 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.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- Transform3D.cs
- Process.cs
- EntityStoreSchemaGenerator.cs
- ReadWriteObjectLock.cs
- configsystem.cs
- TextViewElement.cs
- TypeExtensionConverter.cs
- CurrencyManager.cs
- TranslateTransform3D.cs
- AppSettingsReader.cs
- CompModSwitches.cs
- SQLInt32Storage.cs
- SHA1Managed.cs
- CanExpandCollapseAllConverter.cs
- WhileDesigner.xaml.cs
- ExpressionPrefixAttribute.cs
- BitmapDownload.cs
- XmlSerializableWriter.cs
- RemotingSurrogateSelector.cs
- DbConnectionInternal.cs
- StylusPointCollection.cs
- BinaryReader.cs
- TrackingAnnotationCollection.cs
- OutOfMemoryException.cs
- NamedObject.cs
- AnimationLayer.cs
- InstanceData.cs
- WebExceptionStatus.cs
- Size.cs
- PermissionToken.cs
- EntityStoreSchemaGenerator.cs
- HMACSHA256.cs
- Source.cs
- XmlSchemaSubstitutionGroup.cs
- ErrorTableItemStyle.cs
- TextEditorSpelling.cs
- RemoteCryptoRsaServiceProvider.cs
- DesignTableCollection.cs
- VisualProxy.cs
- DocumentViewerAutomationPeer.cs
- mediaeventargs.cs
- ContractAdapter.cs
- SafeProcessHandle.cs
- Fx.cs
- MutexSecurity.cs
- WebPartVerb.cs
- XamlWrappingReader.cs
- TreeViewItemAutomationPeer.cs
- XPathDocumentNavigator.cs
- _LocalDataStoreMgr.cs
- HttpModulesSection.cs
- Hyperlink.cs
- StrokeCollection2.cs
- SqlGatherConsumedAliases.cs
- BamlLocalizationDictionary.cs
- GenericsNotImplementedException.cs
- Predicate.cs
- ListDictionary.cs
- IBuiltInEvidence.cs
- SelectionRangeConverter.cs
- AutomationAttributeInfo.cs
- HttpHandlerActionCollection.cs
- FixedSOMElement.cs
- StructuralObject.cs
- WebBrowserUriTypeConverter.cs
- DefaultProfileManager.cs
- SkipStoryboardToFill.cs
- ObjectDataSourceStatusEventArgs.cs
- LogExtentCollection.cs
- CollectionTraceRecord.cs
- TreeNode.cs
- StrongNamePublicKeyBlob.cs
- BaseParser.cs
- MetadataConversionError.cs
- _Events.cs
- ComponentEvent.cs
- StrokeRenderer.cs
- Baml6Assembly.cs
- TableLayout.cs
- FlowLayoutPanel.cs
- BaseTemplateParser.cs
- RtType.cs
- XmlSortKeyAccumulator.cs
- DictionaryManager.cs
- StdValidatorsAndConverters.cs
- SqlConnectionFactory.cs
- ValidationErrorInfo.cs
- ClientSettingsProvider.cs
- PathFigure.cs
- NavigationService.cs
- WinFormsUtils.cs
- ResourceFallbackManager.cs
- X509Certificate2Collection.cs
- FontSizeConverter.cs
- ErrorFormatter.cs
- AsymmetricKeyExchangeFormatter.cs
- HistoryEventArgs.cs
- HostSecurityManager.cs
- UIPermission.cs
- nulltextnavigator.cs