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
- SafeLocalMemHandle.cs
- CacheSection.cs
- ModifierKeysConverter.cs
- Point3DKeyFrameCollection.cs
- XmlSchemaNotation.cs
- TranslateTransform.cs
- SoapClientMessage.cs
- ExpandSegmentCollection.cs
- MsmqProcessProtocolHandler.cs
- DataView.cs
- WsdlEndpointConversionContext.cs
- FileDialog_Vista.cs
- WCFModelStrings.Designer.cs
- SplineKeyFrames.cs
- BCryptNative.cs
- HtmlInputSubmit.cs
- ExpressionBuilder.cs
- _HTTPDateParse.cs
- SecurityManager.cs
- Accessors.cs
- CodeAttributeArgumentCollection.cs
- ThreadPool.cs
- PolyBezierSegmentFigureLogic.cs
- coordinator.cs
- ProfileInfo.cs
- Validator.cs
- ResourceReferenceExpression.cs
- CommandSet.cs
- ILGenerator.cs
- CommunicationObjectManager.cs
- Vector3DKeyFrameCollection.cs
- Dynamic.cs
- AdobeCFFWrapper.cs
- UInt64Converter.cs
- DataTable.cs
- ImageIndexConverter.cs
- TagMapCollection.cs
- ReferenceTypeElement.cs
- Dump.cs
- LocatorPart.cs
- PlanCompilerUtil.cs
- LongValidatorAttribute.cs
- COMException.cs
- Error.cs
- InitializerFacet.cs
- RoleGroupCollection.cs
- EventSourceCreationData.cs
- MonikerProxyAttribute.cs
- PropertyRef.cs
- QueryParameter.cs
- UInt16.cs
- _AutoWebProxyScriptEngine.cs
- TraceSwitch.cs
- COAUTHINFO.cs
- RightsManagementEncryptedStream.cs
- RefType.cs
- RuleProcessor.cs
- BypassElementCollection.cs
- CharKeyFrameCollection.cs
- RowUpdatedEventArgs.cs
- DataGridViewAutoSizeColumnsModeEventArgs.cs
- FormsAuthentication.cs
- Panel.cs
- PerformanceCountersBase.cs
- XmlTextReaderImplHelpers.cs
- ColumnMapProcessor.cs
- ValidatorUtils.cs
- CacheDependency.cs
- DataGridHelper.cs
- Vector3dCollection.cs
- SqlDataSourceStatusEventArgs.cs
- WorkflowExecutor.cs
- SharedDp.cs
- TraceInternal.cs
- PackWebRequest.cs
- PanelStyle.cs
- TableCell.cs
- HyperLinkColumn.cs
- DataKeyCollection.cs
- BulletedListEventArgs.cs
- UIElementPropertyUndoUnit.cs
- VideoDrawing.cs
- AmbiguousMatchException.cs
- UrlPath.cs
- HttpAsyncResult.cs
- login.cs
- VisualStyleRenderer.cs
- XmlSchemaSimpleContentExtension.cs
- MD5CryptoServiceProvider.cs
- assertwrapper.cs
- ScopeCollection.cs
- AssertUtility.cs
- ControlCachePolicy.cs
- StringWriter.cs
- CalendarData.cs
- DataGridViewComboBoxColumn.cs
- EditorAttribute.cs
- InternalDispatchObject.cs
- ModelService.cs
- SerializableAttribute.cs