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
- ChildrenQuery.cs
- StreamFormatter.cs
- ObjectStateFormatter.cs
- HtmlAnchor.cs
- ObjectFactoryCodeDomTreeGenerator.cs
- DataPagerFieldCommandEventArgs.cs
- ToolStripDropDownMenu.cs
- Int64AnimationUsingKeyFrames.cs
- ValidationErrorCollection.cs
- TextViewDesigner.cs
- QuestionEventArgs.cs
- HasCopySemanticsAttribute.cs
- AnnotationResource.cs
- AppDomainManager.cs
- TcpPortSharing.cs
- XmlSchemaComplexType.cs
- ZoomPercentageConverter.cs
- DataGridViewComboBoxCell.cs
- CannotUnloadAppDomainException.cs
- DictionaryEntry.cs
- remotingproxy.cs
- LocalBuilder.cs
- FontSizeConverter.cs
- LicFileLicenseProvider.cs
- ScriptManager.cs
- NamedPipeAppDomainProtocolHandler.cs
- _NestedMultipleAsyncResult.cs
- BufferedResponseStream.cs
- PrincipalPermission.cs
- TrailingSpaceComparer.cs
- ProviderBase.cs
- GridViewEditEventArgs.cs
- Viewport2DVisual3D.cs
- DPCustomTypeDescriptor.cs
- TreeNode.cs
- SerializerProvider.cs
- PrintDialog.cs
- ListBox.cs
- HierarchicalDataBoundControl.cs
- Int32CollectionConverter.cs
- UrlAuthFailureHandler.cs
- PipelineModuleStepContainer.cs
- PropertyTabChangedEvent.cs
- SigningCredentials.cs
- WebReferenceCollection.cs
- CompositionAdorner.cs
- X509CertificateValidator.cs
- RenderingEventArgs.cs
- EnumValidator.cs
- SQLInt32Storage.cs
- AlternateViewCollection.cs
- StandardTransformFactory.cs
- ResourcePool.cs
- SelectionEditingBehavior.cs
- LongValidator.cs
- Point.cs
- StrongNameUtility.cs
- MouseEvent.cs
- XmlSerializableServices.cs
- serverconfig.cs
- GeneralTransform3DTo2DTo3D.cs
- QilFunction.cs
- ConnectivityStatus.cs
- TargetParameterCountException.cs
- HostSecurityManager.cs
- HScrollBar.cs
- Encoder.cs
- MsmqBindingBase.cs
- WindowsToolbarItemAsMenuItem.cs
- SaveFileDialog.cs
- SchemaEntity.cs
- CryptoProvider.cs
- MethodBody.cs
- RotateTransform3D.cs
- CodeAccessPermission.cs
- ObjectToken.cs
- VScrollProperties.cs
- CreateUserWizard.cs
- Timeline.cs
- ShaperBuffers.cs
- InfoCardBinaryReader.cs
- IpcManager.cs
- sqlcontext.cs
- Dynamic.cs
- HttpPostServerProtocol.cs
- QuadTree.cs
- StyleTypedPropertyAttribute.cs
- OuterGlowBitmapEffect.cs
- AsymmetricKeyExchangeDeformatter.cs
- WindowsSlider.cs
- LinearGradientBrush.cs
- DataGridCommandEventArgs.cs
- IndexedGlyphRun.cs
- NavigatorInvalidBodyAccessException.cs
- ExpandableObjectConverter.cs
- MsmqReceiveHelper.cs
- _SslStream.cs
- ObjectSelectorEditor.cs
- SpellCheck.cs
- HybridDictionary.cs