Code:
/ 4.0 / 4.0 / untmp / 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.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- HMACSHA512.cs
- IdentitySection.cs
- DynamicMethod.cs
- ZipIOCentralDirectoryDigitalSignature.cs
- InputBindingCollection.cs
- DocumentScope.cs
- ByteStorage.cs
- FormViewPagerRow.cs
- GeneralTransform3DTo2D.cs
- UrlMapping.cs
- ProcessModelSection.cs
- Lasso.cs
- FaultContext.cs
- DbModificationCommandTree.cs
- Helper.cs
- XmlException.cs
- WeakHashtable.cs
- TimelineCollection.cs
- TypeGeneratedEventArgs.cs
- NumberFormatInfo.cs
- StronglyTypedResourceBuilder.cs
- MenuItemBinding.cs
- BooleanToVisibilityConverter.cs
- Stylesheet.cs
- _AutoWebProxyScriptWrapper.cs
- Label.cs
- CodeConstructor.cs
- PolicyValidationException.cs
- LinkLabel.cs
- FileSecurity.cs
- COM2ExtendedTypeConverter.cs
- WmlControlAdapter.cs
- MultiByteCodec.cs
- ImageSourceValueSerializer.cs
- ValidatingReaderNodeData.cs
- WebPartVerbCollection.cs
- QueuePathEditor.cs
- GradientSpreadMethodValidation.cs
- SettingsAttributes.cs
- DataExpression.cs
- BitmapCodecInfo.cs
- Semaphore.cs
- ArrayTypeMismatchException.cs
- ExpressionBuilder.cs
- StateDesigner.cs
- TextElementEnumerator.cs
- Random.cs
- RadioButtonFlatAdapter.cs
- ByteArrayHelperWithString.cs
- ToolStripSystemRenderer.cs
- ColorAnimationUsingKeyFrames.cs
- ScalarOps.cs
- CollectionViewGroupRoot.cs
- Separator.cs
- TypeName.cs
- BufferedGraphicsContext.cs
- AnimationClock.cs
- HandlerFactoryCache.cs
- TraceProvider.cs
- ConsumerConnectionPointCollection.cs
- ConnectionPointConverter.cs
- CodeSnippetExpression.cs
- ButtonColumn.cs
- MaskedTextBox.cs
- CookieProtection.cs
- SamlNameIdentifierClaimResource.cs
- DbConvert.cs
- ArgumentsParser.cs
- UndoManager.cs
- ListDataHelper.cs
- OutOfProcStateClientManager.cs
- PathGeometry.cs
- RequiredAttributeAttribute.cs
- TrackBarRenderer.cs
- ScriptManagerProxy.cs
- DSACryptoServiceProvider.cs
- SourceLineInfo.cs
- GlobalizationSection.cs
- Stream.cs
- WSSecurityPolicy11.cs
- SweepDirectionValidation.cs
- RightsManagementPermission.cs
- ActiveDesignSurfaceEvent.cs
- InstallerTypeAttribute.cs
- DeviceFilterDictionary.cs
- HtmlCommandAdapter.cs
- TextPointerBase.cs
- BridgeDataRecord.cs
- ReaderOutput.cs
- PersistenceProviderElement.cs
- DataGridAddNewRow.cs
- FolderNameEditor.cs
- HideDisabledControlAdapter.cs
- TaiwanLunisolarCalendar.cs
- TreeBuilderXamlTranslator.cs
- ExpressionParser.cs
- RoutedUICommand.cs
- MaskDescriptors.cs
- HyperLink.cs
- InfocardClientCredentials.cs