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
- BitSet.cs
- DocumentApplicationJournalEntry.cs
- FreezableOperations.cs
- RoleGroupCollection.cs
- StringKeyFrameCollection.cs
- PatternMatcher.cs
- WindowsPen.cs
- OdbcConnectionString.cs
- AttributeData.cs
- DesignerLoader.cs
- ExpressionBuilder.cs
- HttpHandler.cs
- OLEDB_Util.cs
- SafeRightsManagementPubHandle.cs
- EdmMember.cs
- ButtonBase.cs
- RolePrincipal.cs
- Queue.cs
- ExcCanonicalXml.cs
- OneOfConst.cs
- XhtmlBasicCalendarAdapter.cs
- SetStateEventArgs.cs
- ProfileSettings.cs
- DiscardableAttribute.cs
- TextPointerBase.cs
- ActivityInstanceReference.cs
- SqlProcedureAttribute.cs
- URLBuilder.cs
- FormViewDeleteEventArgs.cs
- XmlChoiceIdentifierAttribute.cs
- TemplateInstanceAttribute.cs
- PenLineJoinValidation.cs
- SafePEFileHandle.cs
- XmlException.cs
- ManagementEventArgs.cs
- ClockController.cs
- hresults.cs
- XNameTypeConverter.cs
- RuntimeResourceSet.cs
- Exceptions.cs
- InputLangChangeRequestEvent.cs
- SimpleApplicationHost.cs
- ExpandedWrapper.cs
- ManagementOperationWatcher.cs
- BamlMapTable.cs
- UrlRoutingModule.cs
- ImpersonateTokenRef.cs
- GridItemPattern.cs
- ReferenceEqualityComparer.cs
- OleDbDataAdapter.cs
- BitmapVisualManager.cs
- SmtpNetworkElement.cs
- Encoder.cs
- FontConverter.cs
- SettingsPropertyValueCollection.cs
- SchemaAttDef.cs
- DropDownButton.cs
- EntitySet.cs
- CodeAttributeArgument.cs
- _TLSstream.cs
- GatewayIPAddressInformationCollection.cs
- EntityTypeEmitter.cs
- shaper.cs
- ObjectAnimationBase.cs
- TableCellCollection.cs
- FontConverter.cs
- PowerEase.cs
- SchemaInfo.cs
- DataColumnChangeEvent.cs
- EditorZone.cs
- NotifyIcon.cs
- CorrelationManager.cs
- RequiredFieldValidator.cs
- ElapsedEventArgs.cs
- GlyphRunDrawing.cs
- SqlBulkCopy.cs
- ASCIIEncoding.cs
- DeflateStream.cs
- ResourceKey.cs
- dbdatarecord.cs
- FilteredReadOnlyMetadataCollection.cs
- ColumnMap.cs
- VectorConverter.cs
- SystemResourceHost.cs
- ListViewGroupConverter.cs
- UserControl.cs
- ElementAction.cs
- RTLAwareMessageBox.cs
- ProcessModelSection.cs
- InternalBase.cs
- BindStream.cs
- HtmlTableRowCollection.cs
- KeyManager.cs
- PropertyStore.cs
- ExecutionEngineException.cs
- HtmlInputButton.cs
- TargetControlTypeCache.cs
- ColorInterpolationModeValidation.cs
- Nullable.cs
- DefaultAssemblyResolver.cs