NetMsmqBinding.cs source code in C# .NET

Source code for the .NET framework in C#

                        
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

Network programming in C#, Network Programming in VB.NET, Network Programming in .NET
This book is available now!
Buy at Amazon US or
Buy at Amazon UK