Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Transactions / WsatRegistrationHeader.cs / 1 / WsatRegistrationHeader.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.Transactions { using System; using System.ServiceModel.Channels; using System.Diagnostics; using System.ServiceModel; using System.Xml; using Microsoft.Transactions.Wsat.Messaging; using XD = System.ServiceModel.XD; class WsatRegistrationHeader : AddressHeader { const string HeaderName = DotNetAtomicTransactionExternalStrings.RegisterInfo; const string HeaderNamespace = DotNetAtomicTransactionExternalStrings.Namespace; Guid transactionId; string contextId; string tokenId; public WsatRegistrationHeader(Guid transactionId, string contextId, string tokenId) { this.transactionId = transactionId; this.contextId = contextId; this.tokenId = tokenId; } public override string Name { get { return HeaderName; } } public override string Namespace { get { return HeaderNamespace; } } public Guid TransactionId { get { return this.transactionId; } } public string ContextId { get { return this.contextId; } } public string TokenId { get { return this.tokenId; } } protected override void OnWriteStartAddressHeader (XmlDictionaryWriter writer) { writer.WriteStartElement(DotNetAtomicTransactionExternalStrings.Prefix, XD.DotNetAtomicTransactionExternalDictionary.RegisterInfo, XD.DotNetAtomicTransactionExternalDictionary.Namespace); } protected override void OnWriteAddressHeaderContents (XmlDictionaryWriter writer) { writer.WriteStartElement(XD.DotNetAtomicTransactionExternalDictionary.LocalTransactionId, XD.DotNetAtomicTransactionExternalDictionary.Namespace); writer.WriteValue(this.transactionId); writer.WriteEndElement(); if (this.contextId != null) { writer.WriteStartElement(XD.DotNetAtomicTransactionExternalDictionary.ContextId, XD.DotNetAtomicTransactionExternalDictionary.Namespace); writer.WriteValue(this.contextId); writer.WriteEndElement(); } if (this.tokenId != null) { writer.WriteStartElement(XD.DotNetAtomicTransactionExternalDictionary.TokenId, XD.DotNetAtomicTransactionExternalDictionary.Namespace); writer.WriteValue(this.tokenId); writer.WriteEndElement(); } } public static WsatRegistrationHeader ReadFrom(Message message) { int index; try { index = message.Headers.FindHeader(HeaderName, HeaderNamespace); } catch (MessageHeaderException e) { DiagnosticUtility.ExceptionUtility.TraceHandledException(e, TraceEventType.Warning); return null; } if (index < 0) { return null; } WsatRegistrationHeader header; XmlDictionaryReader reader = message.Headers.GetReaderAtHeader(index); using (reader) { try { header = ReadFrom(reader); } catch (XmlException e) { DiagnosticUtility.ExceptionUtility.TraceHandledException(e, TraceEventType.Error); throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidEnlistmentHeaderException(e.Message, e)); } } MessageHeaderInfo headerInfo = message.Headers[index]; if (!message.Headers.UnderstoodHeaders.Contains(headerInfo)) { message.Headers.UnderstoodHeaders.Add(headerInfo); } return header; } static WsatRegistrationHeader ReadFrom(XmlDictionaryReader reader) { reader.ReadFullStartElement(XD.DotNetAtomicTransactionExternalDictionary.RegisterInfo, XD.DotNetAtomicTransactionExternalDictionary.Namespace); reader.MoveToStartElement(XD.DotNetAtomicTransactionExternalDictionary.LocalTransactionId, XD.DotNetAtomicTransactionExternalDictionary.Namespace); // TransactionId Guid transactionId = reader.ReadElementContentAsGuid(); if (transactionId == Guid.Empty) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new XmlException(SR.GetString(SR.InvalidRegistrationHeaderTransactionId))); } // ContextId string contextId; if (reader.IsStartElement(XD.DotNetAtomicTransactionExternalDictionary.ContextId, XD.DotNetAtomicTransactionExternalDictionary.Namespace)) { Uri uri; contextId = reader.ReadElementContentAsString().Trim(); if (contextId.Length == 0 || contextId.Length > CoordinationContext.MaxIdentifierLength || !Uri.TryCreate(contextId, UriKind.Absolute, out uri)) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new XmlException(SR.GetString(SR.InvalidRegistrationHeaderIdentifier))); } } else { contextId = null; } // TokenId string tokenId; if (reader.IsStartElement(XD.DotNetAtomicTransactionExternalDictionary.TokenId, XD.DotNetAtomicTransactionExternalDictionary.Namespace)) { tokenId = reader.ReadElementContentAsString().Trim(); if (tokenId.Length == 0) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new XmlException(SR.GetString(SR.InvalidRegistrationHeaderTokenId))); } } else { tokenId = null; } // Skip unknown elements while (reader.IsStartElement()) { reader.Skip(); } reader.ReadEndElement(); return new WsatRegistrationHeader(transactionId, contextId, tokenId); } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // Copyright (c) Microsoft Corporation. All rights reserved.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- XpsFontSubsetter.cs
- GACIdentityPermission.cs
- CngKey.cs
- DoubleAnimationUsingPath.cs
- __Error.cs
- SQLConvert.cs
- ArrangedElementCollection.cs
- IisTraceListener.cs
- WorkflowInstance.cs
- OutOfProcStateClientManager.cs
- GregorianCalendar.cs
- Emitter.cs
- DocumentGrid.cs
- _BasicClient.cs
- ImagingCache.cs
- RouteParser.cs
- ChangeConflicts.cs
- XmlDataSourceNodeDescriptor.cs
- XmlQualifiedName.cs
- FormView.cs
- ProviderException.cs
- AddInAttribute.cs
- PageRanges.cs
- GraphicsState.cs
- XmlArrayItemAttribute.cs
- ImageDrawing.cs
- TypeConstant.cs
- OdbcCommand.cs
- FixedSOMFixedBlock.cs
- TypedElement.cs
- SafeFileMappingHandle.cs
- SecurityUtils.cs
- DataBinding.cs
- Vector3DKeyFrameCollection.cs
- TransactionChannelFactory.cs
- Color.cs
- TypeHelpers.cs
- ToolStripManager.cs
- RequestTimeoutManager.cs
- ControlParameter.cs
- _DigestClient.cs
- XmlSchemaSimpleType.cs
- ListViewGroupItemCollection.cs
- FormsAuthenticationModule.cs
- SiteOfOriginContainer.cs
- SystemInformation.cs
- EncryptedKeyHashIdentifierClause.cs
- WindowsSolidBrush.cs
- ManipulationBoundaryFeedbackEventArgs.cs
- SendDesigner.xaml.cs
- ProfilePropertyNameValidator.cs
- HyperLinkField.cs
- FacetChecker.cs
- TagPrefixInfo.cs
- StringAttributeCollection.cs
- DataGridViewImageCell.cs
- WebPartTransformerAttribute.cs
- RestHandlerFactory.cs
- DocumentSequence.cs
- TypedTableHandler.cs
- TraceUtils.cs
- SchemaComplexType.cs
- RemotingConfigParser.cs
- SchemaNames.cs
- WindowsToolbarItemAsMenuItem.cs
- _LoggingObject.cs
- FtpCachePolicyElement.cs
- XPathDescendantIterator.cs
- ListDictionary.cs
- ReferenceService.cs
- PersistChildrenAttribute.cs
- SafePipeHandle.cs
- ListViewItem.cs
- RefreshEventArgs.cs
- LookupBindingPropertiesAttribute.cs
- PrinterResolution.cs
- UnsafeNativeMethods.cs
- Tile.cs
- TouchesCapturedWithinProperty.cs
- SecurityElement.cs
- MetadataProperty.cs
- GridViewColumnCollection.cs
- StylusOverProperty.cs
- BlobPersonalizationState.cs
- ResolveResponse.cs
- TraceFilter.cs
- ToolTip.cs
- KerberosTicketHashIdentifierClause.cs
- Gdiplus.cs
- sqlser.cs
- AttributeCollection.cs
- XpsPackagingException.cs
- IsolatedStoragePermission.cs
- ImageAutomationPeer.cs
- SymbolDocumentGenerator.cs
- SafeNativeMethodsCLR.cs
- LinqDataSourceView.cs
- ConnectionPoint.cs
- WindowsFormsHostAutomationPeer.cs
- RelationalExpressions.cs