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
- XmlSchemaObjectCollection.cs
- QilVisitor.cs
- OdbcError.cs
- StrongNameKeyPair.cs
- RequestCacheManager.cs
- BitmapPalette.cs
- SmtpMail.cs
- NativeMethods.cs
- DataViewSetting.cs
- __ConsoleStream.cs
- RtfToXamlLexer.cs
- WindowsComboBox.cs
- DataGridViewCellToolTipTextNeededEventArgs.cs
- OracleBinary.cs
- XmlName.cs
- DesignerExtenders.cs
- BufferedGraphicsContext.cs
- DependencyPropertyValueSerializer.cs
- PassportAuthenticationModule.cs
- XPathDocumentIterator.cs
- BasicAsyncResult.cs
- QilFactory.cs
- SQLResource.cs
- Query.cs
- NavigationEventArgs.cs
- CustomAttribute.cs
- TextBreakpoint.cs
- CatalogPartChrome.cs
- DataRowView.cs
- MethodRental.cs
- ConnectionConsumerAttribute.cs
- GenericTextProperties.cs
- SHA384.cs
- RangeValuePattern.cs
- PseudoWebRequest.cs
- ComplexObject.cs
- NumericUpDownAcceleration.cs
- PropertyManager.cs
- EntityConnection.cs
- TrailingSpaceComparer.cs
- ClientRolePrincipal.cs
- ProcessModelInfo.cs
- SignatureConfirmations.cs
- ApplicationManager.cs
- httpapplicationstate.cs
- BitmapEffectGroup.cs
- DesignRelation.cs
- DiagnosticStrings.cs
- ControlBindingsConverter.cs
- OdbcConnectionHandle.cs
- Metafile.cs
- TreeNode.cs
- ByteConverter.cs
- JsonClassDataContract.cs
- GatewayDefinition.cs
- StoryFragments.cs
- Point3D.cs
- KeyGestureConverter.cs
- OpenTypeLayout.cs
- FunctionQuery.cs
- XhtmlTextWriter.cs
- AssemblyUtil.cs
- ConfigsHelper.cs
- HtmlString.cs
- ReflectionUtil.cs
- PresentationAppDomainManager.cs
- ControlAdapter.cs
- WebPartHeaderCloseVerb.cs
- InternalDispatchObject.cs
- COM2ColorConverter.cs
- HttpRawResponse.cs
- MultipleViewProviderWrapper.cs
- ScriptReferenceBase.cs
- TextParaClient.cs
- FillErrorEventArgs.cs
- ListViewCancelEventArgs.cs
- ObjectListFieldsPage.cs
- _Rfc2616CacheValidators.cs
- ObjectItemAssemblyLoader.cs
- ArgumentDirectionHelper.cs
- MetadataPropertyAttribute.cs
- Mapping.cs
- UndoManager.cs
- PopOutPanel.cs
- RawStylusSystemGestureInputReport.cs
- FieldNameLookup.cs
- ColorConverter.cs
- ServicePoint.cs
- XmlChildEnumerator.cs
- AttributeQuery.cs
- AssemblyCache.cs
- ValidatorCompatibilityHelper.cs
- DCSafeHandle.cs
- Rect3D.cs
- WriteTimeStream.cs
- Guid.cs
- FocusTracker.cs
- ViewValidator.cs
- ListViewTableRow.cs
- TableLayoutPanelDesigner.cs