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
- odbcmetadatafactory.cs
- SqlConnectionHelper.cs
- LockedBorderGlyph.cs
- ContextStack.cs
- ScopedKnownTypes.cs
- Matrix.cs
- WsdlInspector.cs
- TextTreeText.cs
- LicenseContext.cs
- ContainerAction.cs
- HMACSHA256.cs
- EventMappingSettings.cs
- NotifyInputEventArgs.cs
- XmlQueryContext.cs
- SQLStringStorage.cs
- FactoryRecord.cs
- ConfigXmlComment.cs
- SByteStorage.cs
- SymbolMethod.cs
- SoapWriter.cs
- HtmlDocument.cs
- HtmlShim.cs
- ConnectionPoolRegistry.cs
- AttachedProperty.cs
- HtmlInputReset.cs
- AppSettingsExpressionBuilder.cs
- UrlAuthFailedErrorFormatter.cs
- CheckoutException.cs
- cache.cs
- LinkLabelLinkClickedEvent.cs
- DataTableTypeConverter.cs
- EventRouteFactory.cs
- BrowserInteropHelper.cs
- smtppermission.cs
- SocketElement.cs
- Cursors.cs
- TargetParameterCountException.cs
- JsonQueryStringConverter.cs
- RuleRefElement.cs
- XmlDataSourceDesigner.cs
- AlgoModule.cs
- ProfileModule.cs
- DbDataSourceEnumerator.cs
- SmiMetaData.cs
- NameTable.cs
- DataGridViewSelectedCellsAccessibleObject.cs
- WinOEToolBoxItem.cs
- PreviousTrackingServiceAttribute.cs
- _SslState.cs
- ControlFilterExpression.cs
- SpoolingTask.cs
- control.ime.cs
- RectangleF.cs
- UIElementCollection.cs
- ReferenceTypeElement.cs
- TrustManager.cs
- XPathDocument.cs
- EncoderReplacementFallback.cs
- PropertyItemInternal.cs
- ISessionStateStore.cs
- Util.cs
- TableLayoutPanelCellPosition.cs
- AutomationPeer.cs
- LockCookie.cs
- Codec.cs
- SerializationTrace.cs
- CompilerErrorCollection.cs
- Bits.cs
- WebPartDescriptionCollection.cs
- XmlWellformedWriter.cs
- TypedTableBaseExtensions.cs
- TreeNodeCollection.cs
- DbConnectionPoolCounters.cs
- CssClassPropertyAttribute.cs
- dbenumerator.cs
- QilValidationVisitor.cs
- DashStyle.cs
- LocalBuilder.cs
- Decorator.cs
- Missing.cs
- TTSEngineProxy.cs
- ShaderRenderModeValidation.cs
- StylusCollection.cs
- EditorPartCollection.cs
- XmlSignatureManifest.cs
- ContentType.cs
- BindingList.cs
- TraceShell.cs
- XpsImageSerializationService.cs
- ForwardPositionQuery.cs
- QuadraticBezierSegment.cs
- DetailsViewUpdatedEventArgs.cs
- ConfigurationPropertyCollection.cs
- EventRouteFactory.cs
- Identifier.cs
- XmlSchemaObjectCollection.cs
- TypeSystem.cs
- ValueUnavailableException.cs
- COM2Properties.cs
- FacetDescriptionElement.cs