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
- XmlSerializerVersionAttribute.cs
- ConditionCollection.cs
- HtmlWindow.cs
- AnimatedTypeHelpers.cs
- RectangleConverter.cs
- Literal.cs
- TextEndOfLine.cs
- ManipulationDevice.cs
- GeneralTransform.cs
- SqlBuilder.cs
- Image.cs
- SubstitutionList.cs
- HttpRequestTraceRecord.cs
- IRCollection.cs
- EnumBuilder.cs
- OleDbCommandBuilder.cs
- BaseCollection.cs
- Sql8ExpressionRewriter.cs
- MonitorWrapper.cs
- versioninfo.cs
- InternalConfigRoot.cs
- CodeGeneratorOptions.cs
- PerspectiveCamera.cs
- PrtTicket_Public_Simple.cs
- WindowsToolbar.cs
- securitymgrsite.cs
- Message.cs
- GlyphsSerializer.cs
- SynchronizationContext.cs
- LexicalChunk.cs
- TranslateTransform.cs
- CaseKeyBox.xaml.cs
- SortExpressionBuilder.cs
- Literal.cs
- ImageListUtils.cs
- MetadataUtilsSmi.cs
- RegexParser.cs
- BuildResult.cs
- CompilerLocalReference.cs
- SectionVisual.cs
- SecureStringHasher.cs
- XmlChoiceIdentifierAttribute.cs
- StateManagedCollection.cs
- LinkedResourceCollection.cs
- PKCS1MaskGenerationMethod.cs
- Mutex.cs
- MimeTypeAttribute.cs
- RootBrowserWindowProxy.cs
- LeftCellWrapper.cs
- LockCookie.cs
- OrderByBuilder.cs
- XPathParser.cs
- Journaling.cs
- ToolStripDropDownItem.cs
- XslTransform.cs
- ToolStripItem.cs
- XmlSchemaSimpleTypeUnion.cs
- COM2ExtendedUITypeEditor.cs
- HitTestParameters3D.cs
- CodeTypeDelegate.cs
- InputProcessorProfiles.cs
- EntityCommandCompilationException.cs
- PrintPreviewDialog.cs
- CollectionChangeEventArgs.cs
- MouseBinding.cs
- RadioButtonBaseAdapter.cs
- DocumentXmlWriter.cs
- XmlDataSource.cs
- MatrixAnimationUsingPath.cs
- FlowDocumentPage.cs
- CodeDirectoryCompiler.cs
- DataGridViewImageCell.cs
- Behavior.cs
- SafeNativeMethodsMilCoreApi.cs
- FullTextState.cs
- StrokeNodeEnumerator.cs
- EdmItemError.cs
- JavaScriptString.cs
- DefaultPropertyAttribute.cs
- HttpHeaderCollection.cs
- RadioButtonPopupAdapter.cs
- BoundingRectTracker.cs
- DataMemberConverter.cs
- RepeatBehaviorConverter.cs
- DetectEofStream.cs
- WebPartTransformerAttribute.cs
- Completion.cs
- RegexTypeEditor.cs
- Domain.cs
- ExpressionBuilder.cs
- PageTheme.cs
- TransformedBitmap.cs
- EntityContainer.cs
- SystemException.cs
- DecimalAnimation.cs
- ItemList.cs
- InvalidStoreProtectionKeyException.cs
- DictionaryGlobals.cs
- ValueTypeFixupInfo.cs
- AmbientProperties.cs