Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Services / Messaging / System / Messaging / BinaryMessageFormatter.cs / 1305376 / BinaryMessageFormatter.cs
//------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //----------------------------------------------------------------------------- namespace System.Messaging { using System; using System.Runtime.Serialization; using System.Runtime.Serialization.Formatters; using System.Runtime.Serialization.Formatters.Binary; using System.Diagnostics; using System.IO; using System.ComponentModel; ////// /// Formatter class that serializes and deserializes objects into /// and from MessageQueue messages using binary format. /// public class BinaryMessageFormatter : IMessageFormatter { private BinaryFormatter formatter; internal const short VT_BINARY_OBJECT = 0x300; ////// /// Creates a new Binary message formatter object. /// public BinaryMessageFormatter() { this.formatter = new BinaryFormatter(); } ////// /// Creates a new Binary message formatter object /// with the given properties. /// public BinaryMessageFormatter(FormatterAssemblyStyle topObjectFormat, FormatterTypeStyle typeFormat) { this.formatter = new BinaryFormatter(); this.formatter.AssemblyFormat = topObjectFormat; this.formatter.TypeFormat = typeFormat; } ////// /// Determines how the top (root) object of a graph /// is laid out in the serialized stream. /// [MessagingDescription(Res.MsgTopObjectFormat), DefaultValueAttribute(FormatterAssemblyStyle.Simple)] public FormatterAssemblyStyle TopObjectFormat { get { return this.formatter.AssemblyFormat; } set { this.formatter.AssemblyFormat = value; } } ////// /// Determines how type descriptions are laid out in the /// serialized stream. /// [MessagingDescription(Res.MsgTypeFormat), DefaultValueAttribute(FormatterTypeStyle.TypesWhenNeeded)] public FormatterTypeStyle TypeFormat { get { return this.formatter.TypeFormat; } set { this.formatter.TypeFormat = value; } } ////// /// public bool CanRead(Message message) { if (message == null) throw new ArgumentNullException("message"); int variantType = message.BodyType; if (variantType != VT_BINARY_OBJECT) return false; return true; } ///When this method is called, the formatter will attempt to determine /// if the contents of the message are something the formatter can deal with. ////// /// This method is needed to improve scalability on Receive and ReceiveAsync scenarios. Not requiring /// thread safety on read and write. /// public object Clone() { return new BinaryMessageFormatter(TopObjectFormat, TypeFormat); } ////// /// This method is used to read the contents from the given message /// and create an object. /// public object Read(Message message) { if (message == null) throw new ArgumentNullException("message"); int variantType = message.BodyType; if (variantType == VT_BINARY_OBJECT) { Stream stream = message.BodyStream; return formatter.Deserialize(stream); } throw new InvalidOperationException(Res.GetString(Res.InvalidTypeDeserialization)); } ////// /// This method is used to write the given object into the given message. /// If the formatter cannot understand the given object, an exception is thrown. /// public void Write(Message message, object obj) { if (message == null) throw new ArgumentNullException("message"); Stream stream = new MemoryStream(); formatter.Serialize(stream, obj); message.BodyType = VT_BINARY_OBJECT; message.BodyStream = stream; } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu

This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- ServiceObjectContainer.cs
- SoapCommonClasses.cs
- DesignerCommandSet.cs
- DataGridCellEditEndingEventArgs.cs
- VirtualPathProvider.cs
- While.cs
- XmlFormatWriterGenerator.cs
- Executor.cs
- BufferModesCollection.cs
- DataErrorValidationRule.cs
- httpserverutility.cs
- _WinHttpWebProxyDataBuilder.cs
- AxImporter.cs
- DataSvcMapFileSerializer.cs
- InputBindingCollection.cs
- ColumnBinding.cs
- FrugalList.cs
- StringComparer.cs
- SerializerProvider.cs
- Variable.cs
- prompt.cs
- StringResourceManager.cs
- StackOverflowException.cs
- TypeResolvingOptions.cs
- TriggerCollection.cs
- TransactionContextValidator.cs
- CannotUnloadAppDomainException.cs
- ContextTokenTypeConverter.cs
- IntegrationExceptionEventArgs.cs
- PowerModeChangedEventArgs.cs
- CommandConverter.cs
- CompressedStack.cs
- XamlWrappingReader.cs
- DataSourceControl.cs
- ClientUrlResolverWrapper.cs
- CopyAttributesAction.cs
- EmptyWithCancelationCheckWorkItem.cs
- DataViewSettingCollection.cs
- TextSpanModifier.cs
- XmlParserContext.cs
- RuntimeArgument.cs
- ProgressBarAutomationPeer.cs
- X509UI.cs
- HMACSHA1.cs
- Baml6Assembly.cs
- TextDataBindingHandler.cs
- SequentialUshortCollection.cs
- TrackingRecord.cs
- LinkTarget.cs
- mediaeventargs.cs
- FontNameConverter.cs
- HashAlgorithm.cs
- WebPartTransformer.cs
- TokenBasedSet.cs
- DoubleConverter.cs
- ClientConfigPaths.cs
- Win32SafeHandles.cs
- AgileSafeNativeMemoryHandle.cs
- TraceHandler.cs
- relpropertyhelper.cs
- ProtocolsSection.cs
- X509ServiceCertificateAuthenticationElement.cs
- TextTreeUndoUnit.cs
- XmlDataCollection.cs
- DataBindingCollection.cs
- RenamedEventArgs.cs
- InternalConfigRoot.cs
- OdbcDataAdapter.cs
- FontSizeConverter.cs
- PiiTraceSource.cs
- StyleCollection.cs
- XpsFilter.cs
- ControlValuePropertyAttribute.cs
- SHA256.cs
- BufferedGraphicsManager.cs
- httpapplicationstate.cs
- WebPartAddingEventArgs.cs
- RewritingProcessor.cs
- WebCategoryAttribute.cs
- AsmxEndpointPickerExtension.cs
- SoapIncludeAttribute.cs
- DataContractJsonSerializerOperationFormatter.cs
- InputEventArgs.cs
- OraclePermission.cs
- AttachmentCollection.cs
- DesignOnlyAttribute.cs
- SoapElementAttribute.cs
- ModelPerspective.cs
- WindowsEditBox.cs
- HttpStreams.cs
- XmlSignificantWhitespace.cs
- ZipIOLocalFileDataDescriptor.cs
- RegisteredDisposeScript.cs
- DotNetATv1WindowsLogEntryDeserializer.cs
- QilList.cs
- CalendarBlackoutDatesCollection.cs
- ExcludeFromCodeCoverageAttribute.cs
- DefaultPropertyAttribute.cs
- ListenerServiceInstallComponent.cs
- PipeStream.cs