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
- DummyDataSource.cs
- MenuItem.cs
- LinkDesigner.cs
- _WebProxyDataBuilder.cs
- PersonalizablePropertyEntry.cs
- NavigatorInput.cs
- EntitySqlQueryBuilder.cs
- ListBindingHelper.cs
- DefaultEvaluationContext.cs
- StylusTouchDevice.cs
- TrackingMemoryStreamFactory.cs
- AttributeQuery.cs
- TripleDES.cs
- StateManagedCollection.cs
- ListSurrogate.cs
- OracleCommandSet.cs
- RequestTimeoutManager.cs
- TypeUtil.cs
- ExpressionReplacer.cs
- DispatcherHookEventArgs.cs
- GradientStop.cs
- _IPv6Address.cs
- PaginationProgressEventArgs.cs
- WebPartDeleteVerb.cs
- UrlAuthFailedErrorFormatter.cs
- DynamicPropertyHolder.cs
- ClusterRegistryConfigurationProvider.cs
- XmlAttributeCollection.cs
- DataGridRowsPresenter.cs
- RotateTransform3D.cs
- SymbolTable.cs
- SqlConnectionManager.cs
- CalendarDay.cs
- Scripts.cs
- CodeTypeParameterCollection.cs
- DataViewManager.cs
- EventMap.cs
- SqlWebEventProvider.cs
- ToolboxItem.cs
- WindowsTokenRoleProvider.cs
- CodeStatementCollection.cs
- FacetValueContainer.cs
- GroupStyle.cs
- PropertyCollection.cs
- VerificationException.cs
- BlurBitmapEffect.cs
- BuildResult.cs
- EventToken.cs
- DataGridPageChangedEventArgs.cs
- DataBinder.cs
- LeaseManager.cs
- ConnectAlgorithms.cs
- WindowsRichEditRange.cs
- RowToParametersTransformer.cs
- TableCellCollection.cs
- Debug.cs
- MiniMapControl.xaml.cs
- Region.cs
- Rijndael.cs
- SectionUpdates.cs
- SafeNativeMethods.cs
- SystemColors.cs
- DbConnectionPoolIdentity.cs
- KnownTypesHelper.cs
- HtmlControlAdapter.cs
- ExtentKey.cs
- Point3DCollectionConverter.cs
- ServiceNameElement.cs
- XmlObjectSerializerWriteContextComplex.cs
- DragEventArgs.cs
- ToolStripProfessionalLowResolutionRenderer.cs
- MaterialGroup.cs
- PolyBezierSegment.cs
- EdmToObjectNamespaceMap.cs
- CellLabel.cs
- _ScatterGatherBuffers.cs
- PipeStream.cs
- EncodingNLS.cs
- MetadataPropertyAttribute.cs
- recordstatefactory.cs
- Int32Storage.cs
- ReadOnlyDictionary.cs
- HtmlInputPassword.cs
- XmlSerializer.cs
- Inflater.cs
- SqlDataSourceStatusEventArgs.cs
- SmiEventStream.cs
- DesignerActionService.cs
- Model3DGroup.cs
- CustomGrammar.cs
- FlowDocumentPage.cs
- ExecutionEngineException.cs
- XPathNavigator.cs
- ObjectStateFormatter.cs
- StringUtil.cs
- SuppressMessageAttribute.cs
- ColorAnimation.cs
- DataControlCommands.cs
- HttpWebResponse.cs
- StructuralCache.cs