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
- URLBuilder.cs
- HtmlDocument.cs
- UnsignedPublishLicense.cs
- ActivityMarkupSerializationProvider.cs
- ReturnEventArgs.cs
- EntityObject.cs
- HandlerWithFactory.cs
- LineSegment.cs
- BindStream.cs
- SystemIPAddressInformation.cs
- HttpInputStream.cs
- ProcessStartInfo.cs
- LocationReferenceValue.cs
- XmlSchemaSubstitutionGroup.cs
- ConfigurationPropertyCollection.cs
- Parser.cs
- FastEncoder.cs
- updatecommandorderer.cs
- DockProviderWrapper.cs
- XmlTextEncoder.cs
- XmlArrayItemAttributes.cs
- XmlDataSource.cs
- LifetimeServices.cs
- HierarchicalDataTemplate.cs
- ObjectItemAssemblyLoader.cs
- CellLabel.cs
- ThaiBuddhistCalendar.cs
- LicenseManager.cs
- TablePatternIdentifiers.cs
- BitStack.cs
- SafeNativeMethods.cs
- ObservableCollection.cs
- RegistrySecurity.cs
- GraphicsPath.cs
- CqlWriter.cs
- CustomActivityDesigner.cs
- BinaryWriter.cs
- XamlTemplateSerializer.cs
- OpenFileDialog.cs
- smtppermission.cs
- PassportAuthenticationModule.cs
- FileLevelControlBuilderAttribute.cs
- SqlRowUpdatingEvent.cs
- TypeGeneratedEventArgs.cs
- DropDownButton.cs
- MetricEntry.cs
- AncestorChangedEventArgs.cs
- X509ChainElement.cs
- Rotation3D.cs
- Matrix.cs
- SimpleTextLine.cs
- ResXResourceSet.cs
- MailFileEditor.cs
- HtmlForm.cs
- ZipIOFileItemStream.cs
- DefinitionUpdate.cs
- PageAsyncTaskManager.cs
- DialogWindow.cs
- SByteStorage.cs
- ExtensibleClassFactory.cs
- ConfigurationValue.cs
- MemoryStream.cs
- FileDialogPermission.cs
- UIPermission.cs
- EnvelopedSignatureTransform.cs
- Avt.cs
- WhitespaceRuleLookup.cs
- XmlMapping.cs
- MouseActionConverter.cs
- IdSpace.cs
- AlternateViewCollection.cs
- TypedTableBase.cs
- PostBackOptions.cs
- Double.cs
- CapabilitiesAssignment.cs
- AppliedDeviceFiltersDialog.cs
- PcmConverter.cs
- StylusShape.cs
- util.cs
- MachineKeyConverter.cs
- InterleavedZipPartStream.cs
- PagedDataSource.cs
- SqlTransaction.cs
- InstancePersistenceCommand.cs
- TableLayoutSettings.cs
- TraceContextEventArgs.cs
- TemplateField.cs
- ExpressionReplacer.cs
- EventArgs.cs
- DataGridTextBox.cs
- DocumentGridContextMenu.cs
- RecognitionResult.cs
- PointLight.cs
- SessionStateItemCollection.cs
- ListenerChannelContext.cs
- CodeExporter.cs
- InvalidDataException.cs
- IndentTextWriter.cs
- ObjectContext.cs
- SudsWriter.cs