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
- DataSetMappper.cs
- UnsafeNativeMethodsPenimc.cs
- ValidatorCollection.cs
- OdbcStatementHandle.cs
- TextServicesDisplayAttribute.cs
- Path.cs
- PrimitiveSchema.cs
- SafeRightsManagementHandle.cs
- HijriCalendar.cs
- UpdatePanelTriggerCollection.cs
- OpenTypeLayout.cs
- SpAudioStreamWrapper.cs
- AccessDataSourceView.cs
- DefaultBindingPropertyAttribute.cs
- ColumnProvider.cs
- CapabilitiesUse.cs
- EmulateRecognizeCompletedEventArgs.cs
- MatrixIndependentAnimationStorage.cs
- LayeredChannelListener.cs
- ObjectHandle.cs
- SqlDataReader.cs
- SqlConnectionHelper.cs
- Graphics.cs
- Deserializer.cs
- InstallerTypeAttribute.cs
- StringUtil.cs
- Char.cs
- SoapExtensionTypeElementCollection.cs
- ToolStripItemImageRenderEventArgs.cs
- ValueType.cs
- TableCell.cs
- ConfigXmlSignificantWhitespace.cs
- FieldDescriptor.cs
- SpecialNameAttribute.cs
- UrlAuthorizationModule.cs
- FileResponseElement.cs
- ResetableIterator.cs
- FixedSOMPageElement.cs
- ClassicBorderDecorator.cs
- FontCollection.cs
- TextElementCollectionHelper.cs
- RtfFormatStack.cs
- Rect3DValueSerializer.cs
- EntityConnectionStringBuilder.cs
- LongValidator.cs
- TagPrefixCollection.cs
- PieceNameHelper.cs
- ListMarkerLine.cs
- WebPartTransformer.cs
- RefreshPropertiesAttribute.cs
- EditingCommands.cs
- AssemblyNameProxy.cs
- NumericUpDown.cs
- Border.cs
- SessionState.cs
- TimeoutValidationAttribute.cs
- SamlAttribute.cs
- ColumnBinding.cs
- StsCommunicationException.cs
- GridViewCellAutomationPeer.cs
- KeyValueSerializer.cs
- CurrencyWrapper.cs
- ImageMetadata.cs
- AdornerHitTestResult.cs
- UmAlQuraCalendar.cs
- DataGridViewRowDividerDoubleClickEventArgs.cs
- WsiProfilesElement.cs
- CheckableControlBaseAdapter.cs
- Menu.cs
- CroppedBitmap.cs
- NoneExcludedImageIndexConverter.cs
- DoubleLinkList.cs
- CuspData.cs
- XmlReflectionImporter.cs
- XNodeNavigator.cs
- UseLicense.cs
- StructuralObject.cs
- XPathNodeList.cs
- MeshGeometry3D.cs
- CoreSwitches.cs
- X509ChainElement.cs
- DispatchChannelSink.cs
- Int32CollectionConverter.cs
- SpotLight.cs
- CodeConditionStatement.cs
- MonthCalendar.cs
- FastPropertyAccessor.cs
- _BasicClient.cs
- NavigationExpr.cs
- InfoCardRSACryptoProvider.cs
- FixedPageStructure.cs
- ContainerActivationHelper.cs
- InkCanvasAutomationPeer.cs
- SchemaTypeEmitter.cs
- BrushConverter.cs
- TextParaClient.cs
- ChangeProcessor.cs
- WindowShowOrOpenTracker.cs
- DelegatingTypeDescriptionProvider.cs
- CodeFieldReferenceExpression.cs