Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Channels / MsmqVerifier.cs / 1 / MsmqVerifier.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.Channels { using System; using System.Runtime.CompilerServices; using System.Net.Security; using System.ServiceModel; internal static class MsmqVerifier { internal static void VerifySender(MsmqChannelFactoryBase factory) { // no assurances if messages are volatile if (!factory.Durable && factory.ExactlyOnce) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqNoAssurancesForVolatile))); MsmqChannelFactory transportFactory = factory as MsmqChannelFactory ; if (null != transportFactory && transportFactory.UseActiveDirectory && QueueTransferProtocol.Native != transportFactory.QueueTransferProtocol) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqActiveDirectoryRequiresNativeTransfer))); bool? useActiveDirectory = null; if (null != transportFactory) useActiveDirectory = transportFactory.UseActiveDirectory; VerifySecurity(factory.MsmqTransportSecurity, useActiveDirectory); if (null != factory.CustomDeadLetterQueue) { if (DeadLetterQueue.Custom != factory.DeadLetterQueue) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqPerAppDLQRequiresCustom))); } if (! Msmq.IsPerAppDeadLetterQueueSupported) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqPerAppDLQRequiresMsmq4))); } if (! factory.ExactlyOnce) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqPerAppDLQRequiresExactlyOnce))); } string dlqFormatName = MsmqUri.NetMsmqAddressTranslator.UriToFormatName(factory.CustomDeadLetterQueue); if (! MsmqQueue.IsWriteable(dlqFormatName)) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqDLQNotWriteable))); bool isQueueTx; if (! MsmqQueue.TryGetIsTransactional(dlqFormatName, out isQueueTx) || ! isQueueTx) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqTransactedDLQExpected))); } if (null == factory.CustomDeadLetterQueue && DeadLetterQueue.Custom == factory.DeadLetterQueue) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqCustomRequiresPerAppDLQ))); } // token provider needed if Certificate mode requested if (MsmqAuthenticationMode.Certificate == factory.MsmqTransportSecurity.MsmqAuthenticationMode) EnsureSecurityTokenManagerPresent (factory); } internal static void VerifyReceiver(MsmqReceiveParameters receiveParameters, Uri listenUri) { if (!receiveParameters.Durable && receiveParameters.ExactlyOnce) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqNoAssurancesForVolatile))); } VerifySecurity(receiveParameters.TransportSecurity, null); string formatName = receiveParameters.AddressTranslator.UriToFormatName(listenUri); // check if can open the queue for read MsmqException msmqException; if (! MsmqQueue.IsReadable(formatName, out msmqException)) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqQueueNotReadable), msmqException)); } // check if the queue is transactional bool knownTxStatus = false; bool isQueueTx; knownTxStatus = MsmqQueue.TryGetIsTransactional(formatName, out isQueueTx); try { if (!knownTxStatus && (receiveParameters is MsmqTransportReceiveParameters)) knownTxStatus = MsmqQueue.TryGetIsTransactional(MsmqUri.ActiveDirectoryAddressTranslator.UriToFormatName(listenUri), out isQueueTx); } catch (MsmqException ex) // active directory lookup may cause exceptions for certain scenarios { MsmqDiagnostics.ExpectedException(ex); } if (knownTxStatus) { if (!receiveParameters.ExactlyOnce && isQueueTx) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqNonTransactionalQueueNeeded))); if (receiveParameters.ExactlyOnce && !isQueueTx) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqTransactionalQueueNeeded))); } // check poison handling settings if (receiveParameters.ExactlyOnce) { if (Msmq.IsAdvancedPoisonHandlingSupported) // msmq 4 { if (formatName.Contains(";")) { // no retry queues for subqueues if (ReceiveErrorHandling.Move == receiveParameters.ReceiveErrorHandling) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqNoMoveForSubqueues))); } else { // should be able to open the retry queue for move if (! MsmqQueue.IsMoveable(formatName + ";retry")) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqDirectFormatNameRequiredForPoison))); } } else { if (ReceiveErrorHandling.Reject == receiveParameters.ReceiveErrorHandling || ReceiveErrorHandling.Move == receiveParameters.ReceiveErrorHandling) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqAdvancedPoisonHandlingRequired))); } } } } static void VerifySecurity(MsmqTransportSecurity security, bool? useActiveDirectory) { if (security.MsmqAuthenticationMode == MsmqAuthenticationMode.WindowsDomain && ! Msmq.ActiveDirectoryEnabled) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqWindowsAuthnRequiresAD))); // MsmqAuthenticationMode.None implies MsmqProtectionLevel.None if (security.MsmqAuthenticationMode == MsmqAuthenticationMode.None && security.MsmqProtectionLevel != ProtectionLevel.None) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqAuthNoneRequiresProtectionNone))); // MsmqAuthenticationMode.Certificate implies MsmqProtectionLevel.Sign or MsmqProtectionLevel.SignAndEncrypt if (security.MsmqAuthenticationMode == MsmqAuthenticationMode.Certificate && security.MsmqProtectionLevel == ProtectionLevel.None) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqAuthCertificateRequiresProtectionSign))); // MsmqAuthenticationMode.WindowsDomain doesn't allow MsmqProtectionLevel.None if (security.MsmqAuthenticationMode == MsmqAuthenticationMode.WindowsDomain) { if (security.MsmqProtectionLevel == ProtectionLevel.None) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqAuthWindowsRequiresProtectionNotNone))); } // public queues (thus: AD) needed for encryption if (security.MsmqProtectionLevel == ProtectionLevel.EncryptAndSign && useActiveDirectory.HasValue && !useActiveDirectory.Value) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqEncryptRequiresUseAD))); } [MethodImpl(MethodImplOptions.NoInlining)] static void EnsureSecurityTokenManagerPresent (MsmqChannelFactoryBase factory) { if (null == factory.SecurityTokenManager) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqTokenProviderNeededForCertificates))); } } } // 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
- RegexWorker.cs
- ThumbAutomationPeer.cs
- LayoutInformation.cs
- ResourceProperty.cs
- StreamGeometry.cs
- WebBrowserDocumentCompletedEventHandler.cs
- MailAddress.cs
- NominalTypeEliminator.cs
- GAC.cs
- SoapServerMethod.cs
- X509CertificateStore.cs
- Empty.cs
- DocumentReferenceCollection.cs
- JavascriptXmlWriterWrapper.cs
- StylusPointPropertyId.cs
- DbLambda.cs
- DoubleAnimationClockResource.cs
- AdapterDictionary.cs
- ChtmlTextWriter.cs
- ServiceModelTimeSpanValidator.cs
- WebBrowserNavigatingEventHandler.cs
- MethodCallTranslator.cs
- ConfigurationManagerHelperFactory.cs
- precedingsibling.cs
- ProxySimple.cs
- PassportAuthentication.cs
- HWStack.cs
- XmlTextAttribute.cs
- GroupBoxAutomationPeer.cs
- RectKeyFrameCollection.cs
- Panel.cs
- ApplicationDirectory.cs
- WindowsListView.cs
- Grant.cs
- DeviceContext2.cs
- CRYPTPROTECT_PROMPTSTRUCT.cs
- ContractMapping.cs
- File.cs
- DynamicPropertyHolder.cs
- ReturnType.cs
- SqlUdtInfo.cs
- StyleModeStack.cs
- ToolStripItemEventArgs.cs
- HealthMonitoringSection.cs
- SignedXml.cs
- BasicHttpSecurity.cs
- Scanner.cs
- TextSelectionHighlightLayer.cs
- EventProviderWriter.cs
- LayoutEditorPart.cs
- Schema.cs
- BaseCodeDomTreeGenerator.cs
- ImageBrush.cs
- DataTransferEventArgs.cs
- ISO2022Encoding.cs
- CreatingCookieEventArgs.cs
- ObjectDesignerDataSourceView.cs
- DoubleAnimation.cs
- CngProvider.cs
- XsdBuilder.cs
- WebPartConnectionsConfigureVerb.cs
- ExtractedStateEntry.cs
- _SSPIWrapper.cs
- ErrorRuntimeConfig.cs
- TextRangeAdaptor.cs
- HMACMD5.cs
- NativeMethods.cs
- StateBag.cs
- JournalEntryStack.cs
- RijndaelManagedTransform.cs
- UnsafeNativeMethodsCLR.cs
- SatelliteContractVersionAttribute.cs
- WindowsTooltip.cs
- RegexInterpreter.cs
- ObjectCloneHelper.cs
- ConfigurationSettings.cs
- ContentType.cs
- DLinqAssociationProvider.cs
- Parser.cs
- TickBar.cs
- SessionStateSection.cs
- EntityDataSourceStatementEditor.cs
- ElementsClipboardData.cs
- EventManager.cs
- ProxyGenerationError.cs
- BindingExpressionUncommonField.cs
- EnumValidator.cs
- WindowsRichEditRange.cs
- VirtualPath.cs
- Stack.cs
- FontEmbeddingManager.cs
- PixelFormatConverter.cs
- cryptoapiTransform.cs
- NavigatingCancelEventArgs.cs
- NegatedConstant.cs
- loginstatus.cs
- DataComponentMethodGenerator.cs
- ThreadStartException.cs
- RepeaterItem.cs
- Evidence.cs