Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / NetMsmqBinding.cs / 1 / NetMsmqBinding.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel { using System; using System.Diagnostics; using System.ComponentModel; using System.Text; using System.Collections.Generic; using System.Collections.ObjectModel; using System.Configuration; using System.Globalization; using System.Net; using System.Net.Security; using System.Runtime.Serialization; using System.Security.Principal; using System.ServiceModel.Channels; using System.ServiceModel.Security; using Config = System.ServiceModel.Configuration; using System.Xml; public class NetMsmqBinding : MsmqBindingBase { // private BindingElements BinaryMessageEncodingBindingElement encoding; NetMsmqSecurity security; public NetMsmqBinding() { Initialize(); this.security = new NetMsmqSecurity(); } public NetMsmqBinding(string configurationName) { Initialize(); this.security = new NetMsmqSecurity(); ApplyConfiguration(configurationName); } public NetMsmqBinding(NetMsmqSecurityMode securityMode) { if (! NetMsmqSecurityModeHelper.IsDefined(securityMode)) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidEnumArgumentException("mode", (int)securityMode, typeof(NetMsmqSecurityMode))); Initialize(); this.security = new NetMsmqSecurity(securityMode); } NetMsmqBinding(NetMsmqSecurity security) { Initialize(); DiagnosticUtility.DebugAssert(security != null, "Invalid (null) NetMsmqSecurity value"); this.security = security; } public QueueTransferProtocol QueueTransferProtocol { get { return (this.transport as MsmqTransportBindingElement).QueueTransferProtocol; } set { (this.transport as MsmqTransportBindingElement).QueueTransferProtocol = value; } } public XmlDictionaryReaderQuotas ReaderQuotas { get { return encoding.ReaderQuotas; } set { if (value == null) throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("value"); value.CopyTo(encoding.ReaderQuotas); } } public NetMsmqSecurity Security { get { return this.security; } } public EnvelopeVersion EnvelopeVersion { get { return EnvelopeVersion.Soap12; } } public long MaxBufferPoolSize { get { return transport.MaxBufferPoolSize; } set { transport.MaxBufferPoolSize = value; } } internal int MaxPoolSize { get { return (transport as MsmqTransportBindingElement).MaxPoolSize; } set { (transport as MsmqTransportBindingElement).MaxPoolSize = value; } } public bool UseActiveDirectory { get { return (transport as MsmqTransportBindingElement).UseActiveDirectory; } set { (transport as MsmqTransportBindingElement).UseActiveDirectory = value; } } void Initialize() { transport = new MsmqTransportBindingElement(); encoding = new BinaryMessageEncodingBindingElement(); } void InitializeFrom(MsmqTransportBindingElement transport, BinaryMessageEncodingBindingElement encoding) { // only set properties that have standard binding manifestations: MaxPoolSize *is not* one of them this.CustomDeadLetterQueue = transport.CustomDeadLetterQueue; this.DeadLetterQueue = transport.DeadLetterQueue; this.Durable = transport.Durable; this.ExactlyOnce = transport.ExactlyOnce; this.MaxReceivedMessageSize = transport.MaxReceivedMessageSize; this.ReceiveRetryCount = transport.ReceiveRetryCount; this.MaxRetryCycles = transport.MaxRetryCycles; this.ReceiveErrorHandling = transport.ReceiveErrorHandling; this.RetryCycleDelay = transport.RetryCycleDelay; this.TimeToLive = transport.TimeToLive; this.UseSourceJournal = transport.UseSourceJournal; this.UseMsmqTracing = transport.UseMsmqTracing; this.QueueTransferProtocol = transport.QueueTransferProtocol; this.MaxBufferPoolSize = transport.MaxBufferPoolSize; this.UseActiveDirectory = transport.UseActiveDirectory; this.ReaderQuotas = encoding.ReaderQuotas; } // check that properties of the HttpTransportBindingElement and // MessageEncodingBindingElement not exposed as properties on NetMsmqBinding // match default values of the binding elements bool IsBindingElementsMatch(MsmqTransportBindingElement transport, MessageEncodingBindingElement encoding) { // we do not have to check the transport match here: they always match if (!this.GetTransport().IsMatch(transport)) return false; if (!this.encoding.IsMatch(encoding)) return false; return true; } void ApplyConfiguration(string configurationName) { Config.NetMsmqBindingCollectionElement section = Config.NetMsmqBindingCollectionElement.GetBindingCollectionElement(); Config.NetMsmqBindingElement element = section.Bindings[configurationName]; if (element == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ConfigurationErrorsException( SR.GetString(SR.ConfigInvalidBindingConfigurationName, configurationName, Config.ConfigurationStrings.NetMsmqBindingCollectionElementName))); } else { element.ApplyConfiguration(this); } } public override BindingElementCollection CreateBindingElements() { // return collection of BindingElements BindingElementCollection bindingElements = new BindingElementCollection(); // order of BindingElements is important // add security SecurityBindingElement wsSecurity = CreateMessageSecurity(); if (wsSecurity != null) { bindingElements.Add(wsSecurity); } // add encoding (text or mtom) bindingElements.Add(encoding); // add transport bindingElements.Add(GetTransport()); return bindingElements.Clone(); } internal static bool TryCreate(BindingElementCollection elements, out Binding binding) { binding = null; if (elements.Count > 3) return false; SecurityBindingElement security = null; BinaryMessageEncodingBindingElement encoding = null; MsmqTransportBindingElement transport = null; foreach (BindingElement element in elements) { if (element is SecurityBindingElement) security = element as SecurityBindingElement; else if (element is TransportBindingElement) transport = element as MsmqTransportBindingElement; else if (element is MessageEncodingBindingElement) encoding = element as BinaryMessageEncodingBindingElement; else return false; } UnifiedSecurityMode mode; if (!IsValidTransport(transport, out mode)) return false; if (encoding == null) return false; NetMsmqSecurity netMsmqSecurity; if (!TryCreateSecurity(security, mode, out netMsmqSecurity)) return false; NetMsmqBinding netMsmqBinding = new NetMsmqBinding(netMsmqSecurity); netMsmqBinding.InitializeFrom(transport, encoding); if (!netMsmqBinding.IsBindingElementsMatch(transport, encoding)) return false; binding = netMsmqBinding; return true; } SecurityBindingElement CreateMessageSecurity() { if (this.security.Mode == NetMsmqSecurityMode.Message || this.security.Mode == NetMsmqSecurityMode.Both) { return this.security.CreateMessageSecurity(); } else { return null; } } static bool TryCreateSecurity(SecurityBindingElement sbe, UnifiedSecurityMode mode, out NetMsmqSecurity security) { if (sbe != null) mode &= UnifiedSecurityMode.Message | UnifiedSecurityMode.Both; else mode &= ~(UnifiedSecurityMode.Message | UnifiedSecurityMode.Both); NetMsmqSecurityMode netMsmqSecurityMode = NetMsmqSecurityModeHelper.ToSecurityMode(mode); DiagnosticUtility.DebugAssert(NetMsmqSecurityModeHelper.IsDefined(netMsmqSecurityMode), string.Format("Invalid NetMsmqSecurityMode value: {0}.", netMsmqSecurityMode.ToString())); if (NetMsmqSecurity.TryCreate(sbe, netMsmqSecurityMode, out security)) { return true; } return false; } MsmqBindingElementBase GetTransport() { this.security.ConfigureTransportSecurity(transport); return transport; } static bool IsValidTransport(MsmqTransportBindingElement msmq, out UnifiedSecurityMode mode) { mode = (UnifiedSecurityMode)0; if (msmq == null) return false; return NetMsmqSecurity.IsConfiguredTransportSecurity(msmq, out mode); } } } // 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
- PageCodeDomTreeGenerator.cs
- DataSourceDesigner.cs
- PropertyChangingEventArgs.cs
- QilUnary.cs
- ProcessModule.cs
- TreeNodeCollection.cs
- PolyQuadraticBezierSegment.cs
- PseudoWebRequest.cs
- JoinElimination.cs
- DesignerForm.cs
- DecoderFallback.cs
- CardSpaceShim.cs
- UseManagedPresentationBindingElementImporter.cs
- CodeSnippetTypeMember.cs
- XmlSchemaAttributeGroupRef.cs
- RbTree.cs
- UnsafeNativeMethodsMilCoreApi.cs
- ExpressionConverter.cs
- ConfigXmlCDataSection.cs
- ProvidePropertyAttribute.cs
- XmlMemberMapping.cs
- OutputCache.cs
- BinaryObjectWriter.cs
- XmlSchemaAttributeGroup.cs
- SelectionUIHandler.cs
- FormsAuthenticationConfiguration.cs
- SmtpMail.cs
- AnimationClockResource.cs
- Color.cs
- StateChangeEvent.cs
- TagPrefixInfo.cs
- CommandEventArgs.cs
- Visitors.cs
- EventLogEntry.cs
- TypeInfo.cs
- ItemContainerGenerator.cs
- EventPropertyMap.cs
- oledbmetadatacolumnnames.cs
- EventItfInfo.cs
- DataControlButton.cs
- Literal.cs
- SoapAttributeAttribute.cs
- Authorization.cs
- LinqDataSourceDeleteEventArgs.cs
- ConsumerConnectionPointCollection.cs
- FileDataSourceCache.cs
- TextLineBreak.cs
- VisualProxy.cs
- UpdateCommand.cs
- CompiledRegexRunnerFactory.cs
- CodeTypeReferenceCollection.cs
- DaylightTime.cs
- SkewTransform.cs
- XsdBuildProvider.cs
- RangeValidator.cs
- LabelAutomationPeer.cs
- GlyphRunDrawing.cs
- TableParaClient.cs
- XmlSchemaCollection.cs
- GuidelineSet.cs
- TimerEventSubscriptionCollection.cs
- OptionalRstParameters.cs
- BoundField.cs
- Subset.cs
- DeploymentSectionCache.cs
- ActiveDocumentEvent.cs
- TdsParserStateObject.cs
- SequenceDesignerAccessibleObject.cs
- StringFreezingAttribute.cs
- ISFClipboardData.cs
- EdmItemCollection.cs
- dataSvcMapFileLoader.cs
- PersonalizationEntry.cs
- Visual3D.cs
- ResourceIDHelper.cs
- OleDbErrorCollection.cs
- StateMachineTimers.cs
- ModulesEntry.cs
- CopyNodeSetAction.cs
- SqlInternalConnectionTds.cs
- FunctionImportMapping.ReturnTypeRenameMapping.cs
- ResolveCriteriaCD1.cs
- FormsAuthenticationModule.cs
- HashAlgorithm.cs
- HttpWriter.cs
- TdsValueSetter.cs
- safelinkcollection.cs
- PrintEvent.cs
- ObjectItemCollection.cs
- SQLRoleProvider.cs
- ObservableCollection.cs
- XmlDownloadManager.cs
- TimeSpanSecondsOrInfiniteConverter.cs
- WebHostUnsafeNativeMethods.cs
- PrintEvent.cs
- ReachSerializerAsync.cs
- NotificationContext.cs
- HttpWebRequestElement.cs
- webbrowsersite.cs
- RegexCode.cs