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
- TreeNode.cs
- PrefixHandle.cs
- ScriptResourceAttribute.cs
- ItemContainerGenerator.cs
- GridViewAutoFormat.cs
- XmlSchemaAppInfo.cs
- BuildResultCache.cs
- TextUtf8RawTextWriter.cs
- WebRequestModuleElement.cs
- SessionIDManager.cs
- LocalIdCollection.cs
- DrawingDrawingContext.cs
- CompatibleIComparer.cs
- SchemaCollectionPreprocessor.cs
- TextWriter.cs
- EntityClientCacheEntry.cs
- EntityDataSourceDataSelection.cs
- ReadOnlyDataSourceView.cs
- SmiMetaData.cs
- BindingNavigator.cs
- TextTreeRootNode.cs
- filewebrequest.cs
- ClientBuildManager.cs
- CursorConverter.cs
- WebPartDisplayMode.cs
- XmlWrappingWriter.cs
- RijndaelManagedTransform.cs
- XmlArrayItemAttribute.cs
- GeneratedView.cs
- WebPageTraceListener.cs
- DataGridCell.cs
- MouseEventArgs.cs
- ParamArrayAttribute.cs
- WrapperSecurityCommunicationObject.cs
- TypeConverter.cs
- UnicodeEncoding.cs
- Event.cs
- JsonServiceDocumentSerializer.cs
- Compilation.cs
- MultipartIdentifier.cs
- WebPartTracker.cs
- StyleXamlParser.cs
- ClientUtils.cs
- MonikerProxyAttribute.cs
- EndOfStreamException.cs
- ToolStripPanelCell.cs
- EventManager.cs
- DataControlLinkButton.cs
- GenericRootAutomationPeer.cs
- SmiGettersStream.cs
- DesignerAutoFormatCollection.cs
- PassportAuthentication.cs
- RouteItem.cs
- XPathNodeInfoAtom.cs
- OleDbRowUpdatingEvent.cs
- HierarchicalDataSourceConverter.cs
- SynchronizingStream.cs
- SortDescriptionCollection.cs
- ValueTypeFixupInfo.cs
- MultipleViewPattern.cs
- ViewStateAttachedPropertyFeature.cs
- EndGetFileNameFromUserRequest.cs
- DiagnosticTraceSource.cs
- SqlConnectionString.cs
- SecuritySessionSecurityTokenProvider.cs
- TextServicesContext.cs
- DataControlFieldsEditor.cs
- ExceptionUtil.cs
- MessageSecurityException.cs
- PageAsyncTaskManager.cs
- RightsManagementEncryptedStream.cs
- InternalEnumValidator.cs
- DLinqAssociationProvider.cs
- WebPartDisplayModeEventArgs.cs
- DataGridTable.cs
- VirtualPathUtility.cs
- Rss20FeedFormatter.cs
- _DomainName.cs
- SearchForVirtualItemEventArgs.cs
- OutputCacheProfile.cs
- EntityContainerEntitySet.cs
- WebPartUserCapability.cs
- ClientApiGenerator.cs
- DataControlReference.cs
- ConfigXmlCDataSection.cs
- DesignTimeResourceProviderFactoryAttribute.cs
- RawStylusInputCustomData.cs
- SrgsRuleRef.cs
- GridViewCommandEventArgs.cs
- PathFigureCollection.cs
- CorrelationService.cs
- CompoundFileIOPermission.cs
- DecimalConverter.cs
- WebHttpDispatchOperationSelector.cs
- FrameworkElementAutomationPeer.cs
- CommandEventArgs.cs
- SqlAliasesReferenced.cs
- HttpModulesSection.cs
- IisTraceListener.cs
- ServiceManagerHandle.cs