Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / TransactionBridge / Microsoft / Transactions / Wsat / Messaging / SupportingTokenDuplexChannel.cs / 1 / SupportingTokenDuplexChannel.cs
//------------------------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------------------------- // Defines the SupportingTokenChannel that implements IDuplexChannel using System; using System.ServiceModel; using System.ServiceModel.Channels; using System.ServiceModel.Security; using Microsoft.Transactions.Wsat.Protocol; namespace Microsoft.Transactions.Wsat.Messaging { class SupportingTokenDuplexChannel : SupportingTokenChannel, IDuplexChannel { public SupportingTokenDuplexChannel(ChannelManagerBase manager, IDuplexChannel innerChannel, SupportingTokenSecurityTokenResolver tokenResolver, ProtocolVersion protocolVersion) : base(manager, innerChannel, tokenResolver, protocolVersion) { } public EndpointAddress LocalAddress { get { return this.innerChannel.LocalAddress; } } public EndpointAddress RemoteAddress { get { return this.innerChannel.RemoteAddress; } } public Uri Via { get { return this.innerChannel.Via; } } public Message Receive() { Message message = this.innerChannel.Receive(); OnReceive(message); return message; } public Message Receive(TimeSpan timeout) { Message message = this.innerChannel.Receive(timeout); OnReceive(message); return message; } public IAsyncResult BeginReceive(AsyncCallback callback, object state) { return this.innerChannel.BeginReceive(callback, state); } public IAsyncResult BeginReceive(TimeSpan timeout, AsyncCallback callback, object state) { return this.innerChannel.BeginReceive(timeout, callback, state); } public Message EndReceive(IAsyncResult result) { Message message = this.innerChannel.EndReceive(result); OnReceive(message); return message; } public bool TryReceive(TimeSpan timeout, out Message message) { if (this.innerChannel.TryReceive(timeout, out message)) { OnReceive(message); return true; } else { return false; } } public IAsyncResult BeginTryReceive(TimeSpan timeout, AsyncCallback callback, object state) { return this.innerChannel.BeginTryReceive(timeout, callback, state); } public bool EndTryReceive(IAsyncResult result, out Message message) { if (this.innerChannel.EndTryReceive(result, out message)) { OnReceive(message); return true; } else { return false; } } public IAsyncResult BeginSend(Message message, AsyncCallback callback, object state) { return this.BeginSend(message, this.DefaultSendTimeout, callback, state); } public IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback asyncCallback, object state) { return this.innerChannel.BeginSend(message, timeout, asyncCallback, state); } public void EndSend(IAsyncResult result) { this.innerChannel.EndSend(result); } public void Send(Message message) { this.innerChannel.Send(message); } public void Send(Message message, TimeSpan timeout) { this.innerChannel.Send(message, timeout); } public bool WaitForMessage(TimeSpan timeout) { return this.innerChannel.WaitForMessage(timeout); } public IAsyncResult BeginWaitForMessage(TimeSpan timeout, AsyncCallback callback, object state) { return this.innerChannel.BeginWaitForMessage(timeout, callback, state); } public bool EndWaitForMessage(IAsyncResult result) { return this.innerChannel.EndWaitForMessage(result); } protected override void TrySendFaultReply(Message faultMessage) { this.innerChannel.Send(faultMessage); } } } // 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
- ClientReliableChannelBinder.cs
- SmtpSpecifiedPickupDirectoryElement.cs
- ProxySimple.cs
- CodeArgumentReferenceExpression.cs
- DocumentViewer.cs
- UnauthorizedWebPart.cs
- SplitterCancelEvent.cs
- LingerOption.cs
- Dictionary.cs
- SmiSettersStream.cs
- ObjectDataSourceFilteringEventArgs.cs
- LocalizationComments.cs
- SystemInfo.cs
- AppSettingsExpressionBuilder.cs
- PostBackTrigger.cs
- HGlobalSafeHandle.cs
- GPRECT.cs
- ZoneButton.cs
- OracleEncoding.cs
- StringToken.cs
- NullableIntMinMaxAggregationOperator.cs
- UrlUtility.cs
- AnnotationComponentManager.cs
- SimpleHandlerBuildProvider.cs
- HttpServerVarsCollection.cs
- _UncName.cs
- RuntimeResourceSet.cs
- XmlDataProvider.cs
- DesigntimeLicenseContextSerializer.cs
- AuthenticationException.cs
- EventHandlersStore.cs
- EventPrivateKey.cs
- OdbcError.cs
- ChtmlTextWriter.cs
- GreenMethods.cs
- TripleDES.cs
- ComboBox.cs
- RadialGradientBrush.cs
- COM2ComponentEditor.cs
- HebrewCalendar.cs
- OLEDB_Enum.cs
- StorageEntityContainerMapping.cs
- StylusPointDescription.cs
- _CacheStreams.cs
- MouseOverProperty.cs
- CodeCatchClauseCollection.cs
- RestClientProxyHandler.cs
- TrackingMemoryStream.cs
- MonthChangedEventArgs.cs
- CaseDesigner.xaml.cs
- Point4DConverter.cs
- CircleEase.cs
- OrderedParallelQuery.cs
- InspectionWorker.cs
- CursorConverter.cs
- MailHeaderInfo.cs
- Viewport2DVisual3D.cs
- adornercollection.cs
- SqlDataSourceCustomCommandEditor.cs
- Attributes.cs
- ProcessModelSection.cs
- HttpMethodAttribute.cs
- GraphicsContext.cs
- ZipIOExtraFieldPaddingElement.cs
- InkCollectionBehavior.cs
- AttributeProviderAttribute.cs
- QueryGeneratorBase.cs
- Error.cs
- StringConcat.cs
- HttpCapabilitiesSectionHandler.cs
- DataGrid.cs
- OleDbException.cs
- MasterPageParser.cs
- DataSourceSelectArguments.cs
- DataGridViewAdvancedBorderStyle.cs
- ProfileGroupSettings.cs
- ImportCatalogPart.cs
- GCHandleCookieTable.cs
- Rect3DConverter.cs
- CardSpacePolicyElement.cs
- PersonalizationAdministration.cs
- GuidelineCollection.cs
- WorkflowTraceTransfer.cs
- QilXmlReader.cs
- QueryCacheEntry.cs
- TableRow.cs
- DivideByZeroException.cs
- AssociatedControlConverter.cs
- SimpleMailWebEventProvider.cs
- FigureHelper.cs
- SchemaTableColumn.cs
- XmlAtomicValue.cs
- UrlMappingsModule.cs
- ReachIDocumentPaginatorSerializer.cs
- RegularExpressionValidator.cs
- Command.cs
- FilteredReadOnlyMetadataCollection.cs
- TailPinnedEventArgs.cs
- CqlParser.cs
- AesCryptoServiceProvider.cs