Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / MsmqIntegration / MsmqIntegrationChannelFactory.cs / 1 / MsmqIntegrationChannelFactory.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.MsmqIntegration { using System.Runtime.Serialization; using System.ServiceModel; using System.Runtime.Serialization.Formatters.Binary; // for BinaryFormatter using System.Xml.Serialization; // for XmlSerializer using System.IO; // for Stream using System.Collections.Specialized; //For HybridDictionary using System.ServiceModel.Channels; sealed class MsmqIntegrationChannelFactory : MsmqChannelFactoryBase{ ActiveXSerializer activeXSerializer; BinaryFormatter binaryFormatter; MsmqMessageSerializationFormat serializationFormat; HybridDictionary xmlSerializerTable; const int maxSerializerTableSize = 1024; internal MsmqIntegrationChannelFactory(MsmqIntegrationBindingElement bindingElement, BindingContext context) : base(bindingElement, context, null) { this.serializationFormat = bindingElement.SerializationFormat; } BinaryFormatter BinaryFormatter { get { if (this.binaryFormatter == null) { lock(ThisLock) { if (this.binaryFormatter == null) this.binaryFormatter = new BinaryFormatter(); } } return this.binaryFormatter; } } ActiveXSerializer ActiveXSerializer { get { if (this.activeXSerializer == null) { lock(ThisLock) { if (this.activeXSerializer == null) this.activeXSerializer = new ActiveXSerializer(); } } return this.activeXSerializer; } } XmlSerializer GetXmlSerializerForType(Type serializedType) { if (this.xmlSerializerTable == null) { lock(ThisLock) { if (this.xmlSerializerTable == null) this.xmlSerializerTable = new HybridDictionary(); } } XmlSerializer serializer = (XmlSerializer)this.xmlSerializerTable[serializedType]; if (serializer != null) { return serializer; } lock(ThisLock) { if (this.xmlSerializerTable.Count >= maxSerializerTableSize) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new CommunicationException(SR.GetString(SR.MsmqSerializationTableFull, maxSerializerTableSize))); // double-locking serializer = (XmlSerializer)this.xmlSerializerTable[serializedType]; if (serializer != null) { return serializer; } serializer = new XmlSerializer(serializedType); this.xmlSerializerTable[serializedType] = serializer; return serializer; } } public MsmqMessageSerializationFormat SerializationFormat { get { ThrowIfDisposed(); return this.serializationFormat; } } protected override IOutputChannel OnCreateChannel(EndpointAddress to, Uri via) { base.ValidateScheme(via); return new MsmqIntegrationOutputChannel(this, to, via, ManualAddressing); } // // Returns stream containing serialized body // In case of MsmqMessageSerializationFormat.Stream, // returns body as Stream, and throws exception if body is not a Stream // internal Stream Serialize(MsmqIntegrationMessageProperty property) { Stream stream; switch (this.SerializationFormat) { case MsmqMessageSerializationFormat.Xml: stream = new MemoryStream(); XmlSerializer serializer = GetXmlSerializerForType(property.Body.GetType()); serializer.Serialize(stream, property.Body); return stream; case MsmqMessageSerializationFormat.Binary: stream = new MemoryStream(); BinaryFormatter.Serialize(stream, property.Body); // need to set BodyType to a magic number used by System.Messaging property.BodyType = 0x300; return stream; case MsmqMessageSerializationFormat.ActiveX: if (property.BodyType.HasValue) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentException(SR.GetString(SR.MsmqCannotUseBodyTypeWithActiveXSerialization))); } stream = new MemoryStream(); int bodyType = 0; ActiveXSerializer.Serialize(stream as MemoryStream, property.Body, ref bodyType); property.BodyType = bodyType; return stream; case MsmqMessageSerializationFormat.ByteArray: // body MUST be byte array byte[] byteArray = property.Body as byte[]; if (byteArray == null) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new SerializationException(SR.GetString(SR.MsmqByteArrayBodyExpected))); stream = new MemoryStream(); stream.Write(byteArray, 0, byteArray.Length); return stream; case MsmqMessageSerializationFormat.Stream: // body MUST be a stream Stream bodyStream = property.Body as Stream; if (bodyStream == null) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new SerializationException(SR.GetString(SR.MsmqStreamBodyExpected))); // NOTE: we don't copy here as a perf optimization, but this might be dangerous return bodyStream; default: throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new SerializationException(SR.GetString(SR.MsmqUnsupportedSerializationFormat, this.SerializationFormat))); } } } } // 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
- _NestedSingleAsyncResult.cs
- RuntimeWrappedException.cs
- ValidationError.cs
- ADMembershipProvider.cs
- IisTraceWebEventProvider.cs
- ScriptingScriptResourceHandlerSection.cs
- SvcMapFile.cs
- Attributes.cs
- TrustLevelCollection.cs
- ServerReliableChannelBinder.cs
- HtmlTextArea.cs
- TableLayoutRowStyleCollection.cs
- GenerateScriptTypeAttribute.cs
- WFItemsToSpacerVisibility.cs
- LicenseException.cs
- ColorPalette.cs
- ConsumerConnectionPointCollection.cs
- SqlInternalConnection.cs
- GridViewSortEventArgs.cs
- PKCS1MaskGenerationMethod.cs
- ManualResetEvent.cs
- RemoteCryptoDecryptRequest.cs
- CodePrimitiveExpression.cs
- ServiceDescriptionReflector.cs
- LinqDataSource.cs
- RawStylusInputReport.cs
- ConfigurationStrings.cs
- PluralizationServiceUtil.cs
- HttpPostedFile.cs
- CompositeActivityCodeGenerator.cs
- ManagementOperationWatcher.cs
- DbRetry.cs
- Int32RectConverter.cs
- PlacementWorkspace.cs
- ExclusiveTcpListener.cs
- Command.cs
- RotateTransform3D.cs
- RuntimeConfig.cs
- RequestContext.cs
- CodeNamespace.cs
- TimeIntervalCollection.cs
- DataGridViewColumnDividerDoubleClickEventArgs.cs
- ModifierKeysConverter.cs
- keycontainerpermission.cs
- BinHexDecoder.cs
- QueryOperator.cs
- securitycriticaldataClass.cs
- AsnEncodedData.cs
- LinqDataView.cs
- RecordManager.cs
- EdmRelationshipRoleAttribute.cs
- AppDomainProtocolHandler.cs
- ControlBindingsCollection.cs
- DebugInfoExpression.cs
- TemplateParser.cs
- DbParameterCollectionHelper.cs
- LinkedResourceCollection.cs
- AutomationAttributeInfo.cs
- ContextMenu.cs
- TempEnvironment.cs
- ObservableCollectionDefaultValueFactory.cs
- ProxyElement.cs
- EventHandlerList.cs
- CaseStatement.cs
- EntityContainerEmitter.cs
- WCFServiceClientProxyGenerator.cs
- MethodBuilder.cs
- SimpleHandlerFactory.cs
- CommonDialog.cs
- BehaviorEditorPart.cs
- ReflectionTypeLoadException.cs
- InternalConfigSettingsFactory.cs
- FieldNameLookup.cs
- TextPatternIdentifiers.cs
- HMAC.cs
- SplitterCancelEvent.cs
- LateBoundBitmapDecoder.cs
- basenumberconverter.cs
- XmlReaderSettings.cs
- AsymmetricKeyExchangeFormatter.cs
- CompilerLocalReference.cs
- RequestQueue.cs
- CaseKeyBox.xaml.cs
- PtsPage.cs
- RadioButtonPopupAdapter.cs
- _Events.cs
- TextBox.cs
- SqlPersistenceProviderFactory.cs
- ButtonField.cs
- StreamAsIStream.cs
- COSERVERINFO.cs
- ProxyWebPartManager.cs
- LocalClientSecuritySettingsElement.cs
- WebBrowser.cs
- UriExt.cs
- Main.cs
- odbcmetadatafactory.cs
- ComPlusContractBehavior.cs
- XmlCharType.cs
- RichTextBoxContextMenu.cs