Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / WF / RunTime / EventQueueState.cs / 1305376 / EventQueueState.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- using System; using System.Collections; using System.Collections.Generic; using System.Text; using System.Diagnostics; using System.Globalization; using System.Workflow.ComponentModel; using System.Runtime.Serialization; namespace System.Workflow.Runtime { [Serializable] internal sealed class EventQueueState { Queue deliveredMessages; List> synchronousListeners; List > asynchronousListeners; bool enabled = true; bool transactional = true; [NonSerialized] internal IComparable queueName; [NonSerialized] bool dirty = false; // dirty flag set to true until a transaction completes internal EventQueueState() { this.deliveredMessages = new Queue(); this.synchronousListeners = new List >(); this.asynchronousListeners = new List >(); } internal Queue Messages { get { return this.deliveredMessages; } } internal List > AsynchronousListeners { get { return this.asynchronousListeners; } } internal List > SynchronousListeners { get { return this.synchronousListeners; } } internal bool Enabled { get { return this.enabled; } set { this.enabled = value; } } internal bool Transactional { get { return this.transactional; } set { this.transactional = value; } } internal bool Dirty { get { return this.dirty; } set { this.dirty = value; } } internal void CopyFrom(EventQueueState copyFromState) { this.deliveredMessages = new Queue(copyFromState.Messages); // don't copy Subscribers since this gets fixed // up at access time based on these tracking context ints this.asynchronousListeners.AddRange(copyFromState.AsynchronousListeners.ToArray()); this.synchronousListeners.AddRange(copyFromState.SynchronousListeners.ToArray()); this.enabled = copyFromState.Enabled; this.transactional = copyFromState.Transactional; this.dirty = false; } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // Copyright (c) Microsoft Corporation. All rights reserved. //------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- using System; using System.Collections; using System.Collections.Generic; using System.Text; using System.Diagnostics; using System.Globalization; using System.Workflow.ComponentModel; using System.Runtime.Serialization; namespace System.Workflow.Runtime { [Serializable] internal sealed class EventQueueState { Queue deliveredMessages; List > synchronousListeners; List > asynchronousListeners; bool enabled = true; bool transactional = true; [NonSerialized] internal IComparable queueName; [NonSerialized] bool dirty = false; // dirty flag set to true until a transaction completes internal EventQueueState() { this.deliveredMessages = new Queue(); this.synchronousListeners = new List >(); this.asynchronousListeners = new List >(); } internal Queue Messages { get { return this.deliveredMessages; } } internal List > AsynchronousListeners { get { return this.asynchronousListeners; } } internal List > SynchronousListeners { get { return this.synchronousListeners; } } internal bool Enabled { get { return this.enabled; } set { this.enabled = value; } } internal bool Transactional { get { return this.transactional; } set { this.transactional = value; } } internal bool Dirty { get { return this.dirty; } set { this.dirty = value; } } internal void CopyFrom(EventQueueState copyFromState) { this.deliveredMessages = new Queue(copyFromState.Messages); // don't copy Subscribers since this gets fixed // up at access time based on these tracking context ints this.asynchronousListeners.AddRange(copyFromState.AsynchronousListeners.ToArray()); this.synchronousListeners.AddRange(copyFromState.SynchronousListeners.ToArray()); this.enabled = copyFromState.Enabled; this.transactional = copyFromState.Transactional; this.dirty = false; } } } // 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
- MetaModel.cs
- UIAgentMonitor.cs
- TemplateControl.cs
- SelectionProviderWrapper.cs
- TransformerTypeCollection.cs
- Model3DGroup.cs
- JournalNavigationScope.cs
- Pair.cs
- TypeElement.cs
- CaseInsensitiveOrdinalStringComparer.cs
- versioninfo.cs
- PersonalizablePropertyEntry.cs
- LinqDataSourceContextEventArgs.cs
- SchemaElementDecl.cs
- DesignerPerfEventProvider.cs
- ManipulationDeltaEventArgs.cs
- ActivityDesignerHelper.cs
- FileEnumerator.cs
- DeleteWorkflowOwnerCommand.cs
- MultiDataTrigger.cs
- CRYPTPROTECT_PROMPTSTRUCT.cs
- ImmComposition.cs
- XmlDataSourceView.cs
- BulletChrome.cs
- HttpCachePolicy.cs
- TypeViewSchema.cs
- OrthographicCamera.cs
- SliderAutomationPeer.cs
- Run.cs
- PcmConverter.cs
- COM2Enum.cs
- ComPlusContractBehavior.cs
- WindowsPrincipal.cs
- ValidationRule.cs
- WebPartEditorOkVerb.cs
- HttpHandlersSection.cs
- HtmlMeta.cs
- ConsoleCancelEventArgs.cs
- PropertyCondition.cs
- DynamicAttribute.cs
- processwaithandle.cs
- CodeGenHelper.cs
- DefaultPropertiesToSend.cs
- EpmCustomContentSerializer.cs
- clipboard.cs
- UpdateExpressionVisitor.cs
- Unit.cs
- RayMeshGeometry3DHitTestResult.cs
- SamlEvidence.cs
- XsltQilFactory.cs
- SessionStateContainer.cs
- AccessorTable.cs
- WebPartConnectVerb.cs
- AutomationPeer.cs
- OdbcParameterCollection.cs
- FragmentQuery.cs
- BaseParaClient.cs
- CompositionCommandSet.cs
- figurelengthconverter.cs
- DataList.cs
- Perspective.cs
- HtmlHead.cs
- SqlStream.cs
- MetadataCollection.cs
- ZoomPercentageConverter.cs
- CacheMemory.cs
- ImageSourceConverter.cs
- RemoteWebConfigurationHostServer.cs
- ManualResetEvent.cs
- CryptoHandle.cs
- SweepDirectionValidation.cs
- DataTrigger.cs
- AddDataControlFieldDialog.cs
- DataGridViewRowCancelEventArgs.cs
- MessageDecoder.cs
- XamlToRtfParser.cs
- DispatcherProcessingDisabled.cs
- AnnotationHighlightLayer.cs
- WebServicesDescriptionAttribute.cs
- IntPtr.cs
- FloaterParaClient.cs
- HttpDebugHandler.cs
- DocumentViewerHelper.cs
- ReadonlyMessageFilter.cs
- __Error.cs
- SignatureHelper.cs
- SQLDoubleStorage.cs
- IntellisenseTextBox.designer.cs
- TrackingRecord.cs
- IpcChannelHelper.cs
- DbDeleteCommandTree.cs
- NumericExpr.cs
- SizeConverter.cs
- DataGridTable.cs
- ProxyHwnd.cs
- OutputScopeManager.cs
- HwndHost.cs
- ListBoxDesigner.cs
- UnknownBitmapEncoder.cs
- CodeNamespaceCollection.cs