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
- DataTransferEventArgs.cs
- HttpCookieCollection.cs
- TextSchema.cs
- securitycriticaldata.cs
- PropertyInfo.cs
- WinInet.cs
- InputScopeManager.cs
- InfiniteTimeSpanConverter.cs
- CollectionBuilder.cs
- TransformPattern.cs
- EventlogProvider.cs
- MaskedTextBox.cs
- DynamicValidatorEventArgs.cs
- TextFormatterContext.cs
- MessageDesigner.cs
- DataGridViewMethods.cs
- FormViewInsertedEventArgs.cs
- PageThemeParser.cs
- MaskedTextProvider.cs
- ChildTable.cs
- ParserContext.cs
- XPathScanner.cs
- MailSettingsSection.cs
- VideoDrawing.cs
- HtmlInputImage.cs
- EditorPartChrome.cs
- BrowserInteropHelper.cs
- TextElementCollectionHelper.cs
- ComEventsMethod.cs
- GridViewItemAutomationPeer.cs
- Int32RectConverter.cs
- RuntimeWrappedException.cs
- SettingsPropertyNotFoundException.cs
- SettingsPropertyIsReadOnlyException.cs
- StylusDevice.cs
- TraceHandler.cs
- NonSerializedAttribute.cs
- CoreSwitches.cs
- MemberInitExpression.cs
- TraceContextEventArgs.cs
- MergeFailedEvent.cs
- TranslateTransform3D.cs
- Transform.cs
- ScrollableControl.cs
- ToolBarTray.cs
- ParseChildrenAsPropertiesAttribute.cs
- DataMemberAttribute.cs
- Accessible.cs
- ConstraintEnumerator.cs
- SafeHandles.cs
- HttpProfileBase.cs
- SmiContext.cs
- _DisconnectOverlappedAsyncResult.cs
- DataGridViewSelectedColumnCollection.cs
- DataQuery.cs
- CommentEmitter.cs
- FixedSOMLineRanges.cs
- DateTimeOffsetStorage.cs
- HttpWebResponse.cs
- TiffBitmapEncoder.cs
- NativeMethods.cs
- Section.cs
- GridItemProviderWrapper.cs
- GeneratedCodeAttribute.cs
- Grid.cs
- UpDownBase.cs
- BufferedGraphics.cs
- GPPOINTF.cs
- LogRecordSequence.cs
- SmiTypedGetterSetter.cs
- CreateUserWizard.cs
- DataGridViewBand.cs
- StringConverter.cs
- TypeValidationEventArgs.cs
- SQLInt32.cs
- WebUtil.cs
- WindowAutomationPeer.cs
- _FtpControlStream.cs
- DataSourceCache.cs
- Rotation3D.cs
- RuleSettingsCollection.cs
- MailMessageEventArgs.cs
- COM2Properties.cs
- ByteKeyFrameCollection.cs
- XmlDocumentFragment.cs
- XmlSchemaSimpleContent.cs
- RefType.cs
- COM2PropertyDescriptor.cs
- XmlSchemaSimpleContent.cs
- ConfigurationStrings.cs
- DataRowChangeEvent.cs
- XmlQueryContext.cs
- XmlRawWriter.cs
- SettingsPropertyNotFoundException.cs
- SHA384.cs
- Gdiplus.cs
- HttpCacheParams.cs
- GifBitmapDecoder.cs
- EntityDataSourceWrapperCollection.cs
- EventLogPermission.cs