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
- GlyphCollection.cs
- MobileControlsSection.cs
- EmptyControlCollection.cs
- ToolStripProgressBar.cs
- NotifyInputEventArgs.cs
- OdbcTransaction.cs
- Debug.cs
- OracleTransaction.cs
- FlowDocumentScrollViewer.cs
- TreeNodeClickEventArgs.cs
- XmlSchema.cs
- WindowsListViewGroupHelper.cs
- IsolatedStorage.cs
- DataGridHelper.cs
- UnknownBitmapDecoder.cs
- diagnosticsswitches.cs
- WebControlToolBoxItem.cs
- ApplicationDirectory.cs
- SerialPort.cs
- HuffModule.cs
- SqlErrorCollection.cs
- SqlGenericUtil.cs
- CfgArc.cs
- TripleDES.cs
- ComponentManagerBroker.cs
- Int64.cs
- Normalization.cs
- Monitor.cs
- SimpleRecyclingCache.cs
- MetadataArtifactLoader.cs
- TextBoxAutomationPeer.cs
- ContextProperty.cs
- DnsElement.cs
- ProviderMetadataCachedInformation.cs
- Attribute.cs
- FormConverter.cs
- HttpsHostedTransportConfiguration.cs
- BitmapInitialize.cs
- PropertyToken.cs
- ScalarOps.cs
- Addressing.cs
- UndoEngine.cs
- TimeoutStream.cs
- TaskResultSetter.cs
- EventPrivateKey.cs
- MultiBindingExpression.cs
- FormClosingEvent.cs
- DispatchWrapper.cs
- M3DUtil.cs
- SqlDataSourceCache.cs
- EntityProxyTypeInfo.cs
- NamedElement.cs
- AlphabetConverter.cs
- SpecialFolderEnumConverter.cs
- FlowDocumentReaderAutomationPeer.cs
- UserPreferenceChangedEventArgs.cs
- ArcSegment.cs
- MetaChildrenColumn.cs
- TypeBuilderInstantiation.cs
- WindowsFormsHostAutomationPeer.cs
- Errors.cs
- EdgeProfileValidation.cs
- CheckBox.cs
- BufferedOutputStream.cs
- BinaryOperationBinder.cs
- DataObjectMethodAttribute.cs
- EraserBehavior.cs
- ColumnBinding.cs
- WinCategoryAttribute.cs
- CustomDictionarySources.cs
- WebPartAuthorizationEventArgs.cs
- SettingsBase.cs
- RemotingException.cs
- ProfileService.cs
- ServiceOperation.cs
- ConnectionsZone.cs
- CodeTypeReferenceExpression.cs
- UmAlQuraCalendar.cs
- _ProxyRegBlob.cs
- NegotiateStream.cs
- TextUtf8RawTextWriter.cs
- ContentTextAutomationPeer.cs
- HostedAspNetEnvironment.cs
- EntityWithKeyStrategy.cs
- Camera.cs
- SizeAnimationBase.cs
- ArrayElementGridEntry.cs
- ScriptServiceAttribute.cs
- UnsafeNetInfoNativeMethods.cs
- PersistenceException.cs
- ArithmeticException.cs
- Select.cs
- MessageDecoder.cs
- WebBrowserEvent.cs
- HttpGetProtocolImporter.cs
- BooleanProjectedSlot.cs
- ProgressPage.cs
- ValidationEventArgs.cs
- AstTree.cs
- CompressStream.cs