Code:
/ 4.0 / 4.0 / 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. //------------------------------------------------------------------------------ //// 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
- ThreadStaticAttribute.cs
- Vector3DConverter.cs
- EmptyStringExpandableObjectConverter.cs
- PenThread.cs
- OracleInternalConnection.cs
- ArgumentOutOfRangeException.cs
- OdbcEnvironmentHandle.cs
- TextMessageEncoder.cs
- AddressAccessDeniedException.cs
- TypeConverterAttribute.cs
- ProtocolsConfigurationEntry.cs
- PairComparer.cs
- AdapterUtil.cs
- CachedBitmap.cs
- LoginDesignerUtil.cs
- InputLangChangeEvent.cs
- UserNameSecurityToken.cs
- OutputScope.cs
- DependencyObject.cs
- TextParagraphProperties.cs
- ServiceModelExtensionCollectionElement.cs
- ExceptionUtil.cs
- Native.cs
- MethodExecutor.cs
- PointCollection.cs
- CompositeFontInfo.cs
- TypedTableBaseExtensions.cs
- AccessibleObject.cs
- LinqDataSourceSelectEventArgs.cs
- FigureParaClient.cs
- EditorPartChrome.cs
- RowBinding.cs
- WindowsFormsHost.cs
- EmbeddedMailObject.cs
- EntityContainerAssociationSetEnd.cs
- FontFamily.cs
- TreeView.cs
- SourceLineInfo.cs
- CompilationSection.cs
- XmlResolver.cs
- RedirectionProxy.cs
- TextBoxBase.cs
- odbcmetadatafactory.cs
- JsonQNameDataContract.cs
- listitem.cs
- BrowserDefinition.cs
- ContractUtils.cs
- WebHeaderCollection.cs
- Sequence.cs
- COM2PictureConverter.cs
- EntityTypeBase.cs
- EmulateRecognizeCompletedEventArgs.cs
- DynamicMethod.cs
- WindowsGraphicsWrapper.cs
- EventLogEntryCollection.cs
- CursorInteropHelper.cs
- EntityDataSourceValidationException.cs
- PropertyStore.cs
- Delegate.cs
- ManifestResourceInfo.cs
- HtmlInputHidden.cs
- AppSecurityManager.cs
- DomainConstraint.cs
- TextFormatterImp.cs
- GenericAuthenticationEventArgs.cs
- Timeline.cs
- UITypeEditor.cs
- SoapAttributes.cs
- SelectedGridItemChangedEvent.cs
- SynchronizedInputHelper.cs
- XmlSchemaImport.cs
- Canvas.cs
- StorageEndPropertyMapping.cs
- XPathSelfQuery.cs
- ImageIndexConverter.cs
- TrustSection.cs
- XmlComplianceUtil.cs
- LoginName.cs
- SafeNativeMethods.cs
- Scheduling.cs
- UniqueIdentifierService.cs
- DataTemplateKey.cs
- SourceChangedEventArgs.cs
- UMPAttributes.cs
- StringReader.cs
- TreeNodeBindingCollection.cs
- MessageDescriptionCollection.cs
- CompositeFontParser.cs
- ClientConfigPaths.cs
- PropertySourceInfo.cs
- _IPv6Address.cs
- sqlmetadatafactory.cs
- BitmapEffect.cs
- COM2IDispatchConverter.cs
- XDeferredAxisSource.cs
- WsdlInspector.cs
- CollectionBase.cs
- WebControlsSection.cs
- VisualTreeHelper.cs
- _emptywebproxy.cs