Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Services / Messaging / System / Messaging / MessageQueueCriteria.cs / 1305376 / MessageQueueCriteria.cs
//------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //----------------------------------------------------------------------------- namespace System.Messaging { using System.Diagnostics; using System; using System.Messaging.Interop; using Microsoft.Win32; using System.ComponentModel; using System.Security.Permissions; using System.Globalization; //for CultureInfo ////// /// public class MessageQueueCriteria { private DateTime createdAfter; private DateTime createdBefore; private string label; private string machine; private DateTime modifiedAfter; private DateTime modifiedBefore; private Guid category; private CriteriaPropertyFilter filter = new CriteriaPropertyFilter(); private Restrictions restrictions; private Guid machineId; private static DateTime minDate = new DateTime(1970 , 1, 1); private static DateTime maxDate = new DateTime(2038 , 1, 19); ////// This class /// is used to filter MessageQueues when performing a /// query in the network, through MessageQueue.GetPublicQueues method. /// ////// /// Specifies the lower bound of the interval /// that will be used as the queue creation time /// search criteria. /// public DateTime CreatedAfter{ get { if (!this.filter.CreatedAfter) throw new InvalidOperationException(Res.GetString(Res.CriteriaNotDefined)); return this.createdAfter; } set { if (value < MessageQueueCriteria.minDate || value > MessageQueueCriteria.maxDate) throw new ArgumentException(Res.GetString(Res.InvalidDateValue, MessageQueueCriteria.minDate.ToString(CultureInfo.CurrentCulture), MessageQueueCriteria.maxDate.ToString(CultureInfo.CurrentCulture))); this.createdAfter = value; if (this.filter.CreatedBefore && this.createdAfter > this.createdBefore) this.createdBefore = this.createdAfter; this.filter.CreatedAfter = true; } } ////// /// Specifies the upper bound of the interval /// that will be used as the queue creation time /// search criteria. /// public DateTime CreatedBefore{ get { if (!this.filter.CreatedBefore) throw new InvalidOperationException(Res.GetString(Res.CriteriaNotDefined)); return this.createdBefore; } set { if (value < MessageQueueCriteria.minDate || value > MessageQueueCriteria.maxDate) throw new ArgumentException(Res.GetString(Res.InvalidDateValue, MessageQueueCriteria.minDate.ToString(CultureInfo.CurrentCulture), MessageQueueCriteria.maxDate.ToString(CultureInfo.CurrentCulture))); this.createdBefore = value; if (this.filter.CreatedAfter && this.createdAfter > this.createdBefore) this.createdAfter = this.createdBefore; this.filter.CreatedBefore = true; } } internal bool FilterMachine{ get{ return this.filter.MachineName; } } ////// /// Specifies the label that that will be used as /// the criteria to search queues in the network. /// public string Label{ get { if (!this.filter.Label) throw new InvalidOperationException(Res.GetString(Res.CriteriaNotDefined)); return this.label; } set { if (value == null) throw new ArgumentNullException("value"); this.label = value; this.filter.Label = true; } } ////// /// public string MachineName{ get { if (!this.filter.MachineName) throw new InvalidOperationException(Res.GetString(Res.CriteriaNotDefined)); return this.machine; } set { if (!SyntaxCheck.CheckMachineName(value)) throw new ArgumentException(Res.GetString(Res.InvalidProperty, "MachineName", value)); //SECREVIEW: Setting this property shouldn't demmand any permissions, // the machine id will only be used internally. MessageQueuePermission permission = new MessageQueuePermission(PermissionState.Unrestricted); permission.Assert(); try { this.machineId = MessageQueue.GetMachineId(value); } finally { MessageQueuePermission.RevertAssert(); } this.machine = value; this.filter.MachineName = true; } } ////// Specifies the machine name that will be used /// as the criteria to search queues in the network. /// ////// /// Specifies the lower bound of the interval /// that will be used as the queue modified time /// search criteria. /// public DateTime ModifiedAfter{ get { if (!this.filter.ModifiedAfter) throw new InvalidOperationException(Res.GetString(Res.CriteriaNotDefined)); return this.modifiedAfter; } set { if (value < MessageQueueCriteria.minDate || value > MessageQueueCriteria.maxDate) throw new ArgumentException(Res.GetString(Res.InvalidDateValue, MessageQueueCriteria.minDate.ToString(CultureInfo.CurrentCulture), MessageQueueCriteria.maxDate.ToString(CultureInfo.CurrentCulture))); this.modifiedAfter = value; if (this.filter.ModifiedBefore && this.modifiedAfter > this.modifiedBefore) this.modifiedBefore = this.modifiedAfter; this.filter.ModifiedAfter = true; } } ////// /// Specifies the upper bound of the interval /// that will be used as the queue modified time /// search criteria. /// public DateTime ModifiedBefore{ get { if (!this.filter.ModifiedBefore) throw new InvalidOperationException(Res.GetString(Res.CriteriaNotDefined)); return this.modifiedBefore; } set { if (value < MessageQueueCriteria.minDate || value > MessageQueueCriteria.maxDate) throw new ArgumentException(Res.GetString(Res.InvalidDateValue, MessageQueueCriteria.minDate.ToString(CultureInfo.CurrentCulture), MessageQueueCriteria.maxDate.ToString(CultureInfo.CurrentCulture))); this.modifiedBefore = value; if (this.filter.ModifiedAfter && this.modifiedAfter > this.modifiedBefore) this.modifiedAfter = this.modifiedBefore; this.filter.ModifiedBefore = true; } } ////// internal Restrictions.MQRESTRICTION Reference{ get{ int size = 0; if (this.filter.CreatedAfter) ++ size; if (this.filter.CreatedBefore) ++ size; if (this.filter.Label) ++ size; if (this.filter.ModifiedAfter) ++ size; if (this.filter.ModifiedBefore) ++ size; if (this.filter.Category) ++ size; restrictions = new Restrictions(size); if (this.filter.CreatedAfter) restrictions.AddI4(NativeMethods.QUEUE_PROPID_CREATE_TIME, Restrictions.PRGT, ConvertTime(this.createdAfter)); if (this.filter.CreatedBefore) restrictions.AddI4(NativeMethods.QUEUE_PROPID_CREATE_TIME, Restrictions.PRLE, ConvertTime(this.createdBefore)); if (this.filter.Label) restrictions.AddString(NativeMethods.QUEUE_PROPID_LABEL, Restrictions.PREQ, this.label); if (this.filter.ModifiedAfter) restrictions.AddI4(NativeMethods.QUEUE_PROPID_MODIFY_TIME, Restrictions.PRGT, ConvertTime(this.modifiedAfter)); if (this.filter.ModifiedBefore) restrictions.AddI4(NativeMethods.QUEUE_PROPID_MODIFY_TIME, Restrictions.PRLE, ConvertTime(this.modifiedBefore)); if (this.filter.Category) restrictions.AddGuid(NativeMethods.QUEUE_PROPID_TYPE, Restrictions.PREQ, this.category); return this.restrictions.GetRestrictionsRef(); } } /// /// /// Specifies the Category that will be used /// as the criteria to search queues in the network. /// public Guid Category{ get { if (!this.filter.Category) throw new InvalidOperationException(Res.GetString(Res.CriteriaNotDefined)); return this.category; } set { this.category = value; this.filter.Category = true; } } ////// /// Resets all the current instance settings. /// public void ClearAll() { this.filter.ClearAll(); } ////// private int ConvertTime(DateTime time) { time = time.ToUniversalTime(); return (int)(time - MessageQueueCriteria.minDate).TotalSeconds; } /// /// private class CriteriaPropertyFilter{ public bool CreatedAfter; public bool CreatedBefore; public bool Label; public bool MachineName; public bool ModifiedAfter; public bool ModifiedBefore; public bool Category; public void ClearAll() { this.CreatedAfter = false; this.CreatedBefore = false; this.Label = false; this.MachineName = false; this.ModifiedAfter = false; this.ModifiedBefore = false; this.Category = false; } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. //------------------------------------------------------------------------------ // // Copyright (c) Microsoft Corporation. All rights reserved. // //----------------------------------------------------------------------------- namespace System.Messaging { using System.Diagnostics; using System; using System.Messaging.Interop; using Microsoft.Win32; using System.ComponentModel; using System.Security.Permissions; using System.Globalization; //for CultureInfo ////// /// public class MessageQueueCriteria { private DateTime createdAfter; private DateTime createdBefore; private string label; private string machine; private DateTime modifiedAfter; private DateTime modifiedBefore; private Guid category; private CriteriaPropertyFilter filter = new CriteriaPropertyFilter(); private Restrictions restrictions; private Guid machineId; private static DateTime minDate = new DateTime(1970 , 1, 1); private static DateTime maxDate = new DateTime(2038 , 1, 19); ////// This class /// is used to filter MessageQueues when performing a /// query in the network, through MessageQueue.GetPublicQueues method. /// ////// /// Specifies the lower bound of the interval /// that will be used as the queue creation time /// search criteria. /// public DateTime CreatedAfter{ get { if (!this.filter.CreatedAfter) throw new InvalidOperationException(Res.GetString(Res.CriteriaNotDefined)); return this.createdAfter; } set { if (value < MessageQueueCriteria.minDate || value > MessageQueueCriteria.maxDate) throw new ArgumentException(Res.GetString(Res.InvalidDateValue, MessageQueueCriteria.minDate.ToString(CultureInfo.CurrentCulture), MessageQueueCriteria.maxDate.ToString(CultureInfo.CurrentCulture))); this.createdAfter = value; if (this.filter.CreatedBefore && this.createdAfter > this.createdBefore) this.createdBefore = this.createdAfter; this.filter.CreatedAfter = true; } } ////// /// Specifies the upper bound of the interval /// that will be used as the queue creation time /// search criteria. /// public DateTime CreatedBefore{ get { if (!this.filter.CreatedBefore) throw new InvalidOperationException(Res.GetString(Res.CriteriaNotDefined)); return this.createdBefore; } set { if (value < MessageQueueCriteria.minDate || value > MessageQueueCriteria.maxDate) throw new ArgumentException(Res.GetString(Res.InvalidDateValue, MessageQueueCriteria.minDate.ToString(CultureInfo.CurrentCulture), MessageQueueCriteria.maxDate.ToString(CultureInfo.CurrentCulture))); this.createdBefore = value; if (this.filter.CreatedAfter && this.createdAfter > this.createdBefore) this.createdAfter = this.createdBefore; this.filter.CreatedBefore = true; } } internal bool FilterMachine{ get{ return this.filter.MachineName; } } ////// /// Specifies the label that that will be used as /// the criteria to search queues in the network. /// public string Label{ get { if (!this.filter.Label) throw new InvalidOperationException(Res.GetString(Res.CriteriaNotDefined)); return this.label; } set { if (value == null) throw new ArgumentNullException("value"); this.label = value; this.filter.Label = true; } } ////// /// public string MachineName{ get { if (!this.filter.MachineName) throw new InvalidOperationException(Res.GetString(Res.CriteriaNotDefined)); return this.machine; } set { if (!SyntaxCheck.CheckMachineName(value)) throw new ArgumentException(Res.GetString(Res.InvalidProperty, "MachineName", value)); //SECREVIEW: Setting this property shouldn't demmand any permissions, // the machine id will only be used internally. MessageQueuePermission permission = new MessageQueuePermission(PermissionState.Unrestricted); permission.Assert(); try { this.machineId = MessageQueue.GetMachineId(value); } finally { MessageQueuePermission.RevertAssert(); } this.machine = value; this.filter.MachineName = true; } } ////// Specifies the machine name that will be used /// as the criteria to search queues in the network. /// ////// /// Specifies the lower bound of the interval /// that will be used as the queue modified time /// search criteria. /// public DateTime ModifiedAfter{ get { if (!this.filter.ModifiedAfter) throw new InvalidOperationException(Res.GetString(Res.CriteriaNotDefined)); return this.modifiedAfter; } set { if (value < MessageQueueCriteria.minDate || value > MessageQueueCriteria.maxDate) throw new ArgumentException(Res.GetString(Res.InvalidDateValue, MessageQueueCriteria.minDate.ToString(CultureInfo.CurrentCulture), MessageQueueCriteria.maxDate.ToString(CultureInfo.CurrentCulture))); this.modifiedAfter = value; if (this.filter.ModifiedBefore && this.modifiedAfter > this.modifiedBefore) this.modifiedBefore = this.modifiedAfter; this.filter.ModifiedAfter = true; } } ////// /// Specifies the upper bound of the interval /// that will be used as the queue modified time /// search criteria. /// public DateTime ModifiedBefore{ get { if (!this.filter.ModifiedBefore) throw new InvalidOperationException(Res.GetString(Res.CriteriaNotDefined)); return this.modifiedBefore; } set { if (value < MessageQueueCriteria.minDate || value > MessageQueueCriteria.maxDate) throw new ArgumentException(Res.GetString(Res.InvalidDateValue, MessageQueueCriteria.minDate.ToString(CultureInfo.CurrentCulture), MessageQueueCriteria.maxDate.ToString(CultureInfo.CurrentCulture))); this.modifiedBefore = value; if (this.filter.ModifiedAfter && this.modifiedAfter > this.modifiedBefore) this.modifiedAfter = this.modifiedBefore; this.filter.ModifiedBefore = true; } } ////// internal Restrictions.MQRESTRICTION Reference{ get{ int size = 0; if (this.filter.CreatedAfter) ++ size; if (this.filter.CreatedBefore) ++ size; if (this.filter.Label) ++ size; if (this.filter.ModifiedAfter) ++ size; if (this.filter.ModifiedBefore) ++ size; if (this.filter.Category) ++ size; restrictions = new Restrictions(size); if (this.filter.CreatedAfter) restrictions.AddI4(NativeMethods.QUEUE_PROPID_CREATE_TIME, Restrictions.PRGT, ConvertTime(this.createdAfter)); if (this.filter.CreatedBefore) restrictions.AddI4(NativeMethods.QUEUE_PROPID_CREATE_TIME, Restrictions.PRLE, ConvertTime(this.createdBefore)); if (this.filter.Label) restrictions.AddString(NativeMethods.QUEUE_PROPID_LABEL, Restrictions.PREQ, this.label); if (this.filter.ModifiedAfter) restrictions.AddI4(NativeMethods.QUEUE_PROPID_MODIFY_TIME, Restrictions.PRGT, ConvertTime(this.modifiedAfter)); if (this.filter.ModifiedBefore) restrictions.AddI4(NativeMethods.QUEUE_PROPID_MODIFY_TIME, Restrictions.PRLE, ConvertTime(this.modifiedBefore)); if (this.filter.Category) restrictions.AddGuid(NativeMethods.QUEUE_PROPID_TYPE, Restrictions.PREQ, this.category); return this.restrictions.GetRestrictionsRef(); } } /// /// /// Specifies the Category that will be used /// as the criteria to search queues in the network. /// public Guid Category{ get { if (!this.filter.Category) throw new InvalidOperationException(Res.GetString(Res.CriteriaNotDefined)); return this.category; } set { this.category = value; this.filter.Category = true; } } ////// /// Resets all the current instance settings. /// public void ClearAll() { this.filter.ClearAll(); } ////// private int ConvertTime(DateTime time) { time = time.ToUniversalTime(); return (int)(time - MessageQueueCriteria.minDate).TotalSeconds; } /// /// private class CriteriaPropertyFilter{ public bool CreatedAfter; public bool CreatedBefore; public bool Label; public bool MachineName; public bool ModifiedAfter; public bool ModifiedBefore; public bool Category; public void ClearAll() { this.CreatedAfter = false; this.CreatedBefore = false; this.Label = false; this.MachineName = false; this.ModifiedAfter = false; this.ModifiedBefore = false; this.Category = false; } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- DocComment.cs
- JsonEnumDataContract.cs
- SpStreamWrapper.cs
- Parser.cs
- RegexReplacement.cs
- PKCS1MaskGenerationMethod.cs
- MgmtConfigurationRecord.cs
- TimeoutException.cs
- FormatConvertedBitmap.cs
- EndpointAddress10.cs
- FixedSOMGroup.cs
- ResourceReferenceExpression.cs
- Int64.cs
- HtmlTableRowCollection.cs
- RowCache.cs
- PropertyPathConverter.cs
- CodePageUtils.cs
- ImageFormat.cs
- MailSettingsSection.cs
- RC2.cs
- QilTargetType.cs
- IdentityReference.cs
- TreeWalker.cs
- SchemaEntity.cs
- PersonalizableTypeEntry.cs
- ErrorReporting.cs
- WebBrowserHelper.cs
- SoapObjectInfo.cs
- QuotedPrintableStream.cs
- HttpModuleAction.cs
- DataGridViewCellConverter.cs
- ListBox.cs
- Query.cs
- ProtocolsConfigurationEntry.cs
- TreeNodeEventArgs.cs
- ProgressBarAutomationPeer.cs
- TextDocumentView.cs
- RenderDataDrawingContext.cs
- PropertyTab.cs
- GridViewCellAutomationPeer.cs
- CustomAttributeFormatException.cs
- DebugController.cs
- XmlCountingReader.cs
- Parsers.cs
- WinFormsComponentEditor.cs
- IItemContainerGenerator.cs
- XmlILAnnotation.cs
- ExpressionBindingCollection.cs
- CodeDomSerializationProvider.cs
- Vector.cs
- OleDbDataAdapter.cs
- XsdDateTime.cs
- ReadWriteSpinLock.cs
- Delegate.cs
- TextModifier.cs
- SlipBehavior.cs
- _FixedSizeReader.cs
- Quad.cs
- WebServiceFaultDesigner.cs
- CoTaskMemSafeHandle.cs
- SchemaMapping.cs
- JoinElimination.cs
- ResolvedKeyFrameEntry.cs
- HttpRequest.cs
- AspNetPartialTrustHelpers.cs
- SoundPlayer.cs
- RC2.cs
- XpsS0ValidatingLoader.cs
- GridView.cs
- ServiceNameCollection.cs
- ClientReliableChannelBinder.cs
- SQLResource.cs
- DPCustomTypeDescriptor.cs
- FlowPosition.cs
- TraceData.cs
- CursorConverter.cs
- TrustManagerMoreInformation.cs
- EncoderParameter.cs
- XmlSchemaComplexContentExtension.cs
- CategoryGridEntry.cs
- PackWebRequest.cs
- BinaryUtilClasses.cs
- SqlFlattener.cs
- IisTraceWebEventProvider.cs
- ViewGenResults.cs
- CreateUserWizardStep.cs
- MouseButtonEventArgs.cs
- WindowsEditBox.cs
- Condition.cs
- RoleService.cs
- ReflectPropertyDescriptor.cs
- SqlCommand.cs
- Screen.cs
- WorkflowServiceHostFactory.cs
- OciHandle.cs
- PingReply.cs
- HandleCollector.cs
- HttpWebRequestElement.cs
- XmlSchemaObjectCollection.cs
- TransformCryptoHandle.cs