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
- ListViewGroup.cs
- RotateTransform.cs
- WsdlParser.cs
- ForceCopyBuildProvider.cs
- UIElement.cs
- SQLDoubleStorage.cs
- HtmlSelect.cs
- NonClientArea.cs
- MimeTextImporter.cs
- DataGridHyperlinkColumn.cs
- TraversalRequest.cs
- MobileDeviceCapabilitiesSectionHandler.cs
- ValidatingPropertiesEventArgs.cs
- CaseStatementProjectedSlot.cs
- CalculatedColumn.cs
- ClientTargetSection.cs
- RuntimeEnvironment.cs
- PackWebResponse.cs
- UnsafeNativeMethods.cs
- MouseOverProperty.cs
- TraceHandler.cs
- DataPagerFieldItem.cs
- GenericEnumConverter.cs
- DataColumn.cs
- ProxyHelper.cs
- BinaryMethodMessage.cs
- ValueHandle.cs
- SettingsPropertyWrongTypeException.cs
- CategoryAttribute.cs
- StringStorage.cs
- WindowsScrollBar.cs
- DesignerVerbCollection.cs
- MessageQueueInstaller.cs
- _CacheStreams.cs
- MatchAllMessageFilter.cs
- XmlNodeChangedEventArgs.cs
- DoubleLink.cs
- DeliveryStrategy.cs
- SchemaImporterExtensionElement.cs
- LocationSectionRecord.cs
- PageThemeBuildProvider.cs
- RtfToXamlReader.cs
- DataTemplate.cs
- TextParentUndoUnit.cs
- TextBoxDesigner.cs
- CodeArgumentReferenceExpression.cs
- TextParagraph.cs
- LassoSelectionBehavior.cs
- Page.cs
- WebPartVerbCollection.cs
- DecimalConverter.cs
- DocumentSignatureManager.cs
- EntityDataSourceColumn.cs
- TraceSection.cs
- TextTreeTextNode.cs
- BitmapEffectGroup.cs
- DebugView.cs
- SmtpSection.cs
- Facet.cs
- GPStream.cs
- WmfPlaceableFileHeader.cs
- UnknownWrapper.cs
- InkPresenterAutomationPeer.cs
- WmiInstallComponent.cs
- WindowsStatic.cs
- ClientOptions.cs
- RoleManagerModule.cs
- RequestCachingSection.cs
- SystemPens.cs
- WorkItem.cs
- LineServicesRun.cs
- BaseDataBoundControl.cs
- HtmlContainerControl.cs
- HtmlButton.cs
- CombinedGeometry.cs
- ResourceWriter.cs
- AppSettingsReader.cs
- ColumnMapProcessor.cs
- RequestStatusBarUpdateEventArgs.cs
- UnicodeEncoding.cs
- x509utils.cs
- versioninfo.cs
- PromptBuilder.cs
- TreeNodeSelectionProcessor.cs
- SerializerProvider.cs
- ValidationErrorCollection.cs
- ProfessionalColors.cs
- LineServicesRun.cs
- ReachPrintTicketSerializer.cs
- ColumnResult.cs
- CancelEventArgs.cs
- CompositeDataBoundControl.cs
- GridViewColumnHeaderAutomationPeer.cs
- URI.cs
- TokenDescriptor.cs
- PointAnimationUsingKeyFrames.cs
- SqlUnionizer.cs
- WebPartConnectionCollection.cs
- Perspective.cs
- CompositeFontParser.cs