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
- SkipStoryboardToFill.cs
- StructuralCache.cs
- MessageFilterException.cs
- ObjectViewFactory.cs
- ToolTip.cs
- ProtocolsConfigurationHandler.cs
- MessageAction.cs
- ProtocolsConfigurationEntry.cs
- DataTableReaderListener.cs
- TransactedBatchingBehavior.cs
- CodeCatchClause.cs
- PathSegment.cs
- StrokeCollection.cs
- DesignerDataTableBase.cs
- SetterBaseCollection.cs
- BamlBinaryReader.cs
- XmlUtil.cs
- ValueProviderWrapper.cs
- NumberFormatInfo.cs
- TabItemWrapperAutomationPeer.cs
- ServerReliableChannelBinder.cs
- ProfilePropertySettingsCollection.cs
- WindowsStatusBar.cs
- EditorZone.cs
- ThrowHelper.cs
- PolicyLevel.cs
- RotateTransform.cs
- CurrentChangingEventArgs.cs
- SqlLiftIndependentRowExpressions.cs
- UrlPath.cs
- CodeActivity.cs
- SimpleTextLine.cs
- SqlUtil.cs
- ListBox.cs
- ClientUrlResolverWrapper.cs
- DataControlCommands.cs
- ApplicationActivator.cs
- CngKeyCreationParameters.cs
- CookielessHelper.cs
- AppDomainGrammarProxy.cs
- ExternalFile.cs
- SoapWriter.cs
- CommandID.cs
- DataSourceComponent.cs
- WinEventQueueItem.cs
- ModifierKeysValueSerializer.cs
- TabControl.cs
- PackageController.cs
- XmlSchemaImport.cs
- TextRenderer.cs
- XmlChildEnumerator.cs
- MarkupWriter.cs
- HandlerBase.cs
- SystemIPv6InterfaceProperties.cs
- TypeElement.cs
- DirectoryObjectSecurity.cs
- XsltInput.cs
- InvalidCommandTreeException.cs
- XmlSerializationWriter.cs
- DbConnectionHelper.cs
- SafeBitVector32.cs
- SQLBinary.cs
- MetadataPropertyAttribute.cs
- AudioLevelUpdatedEventArgs.cs
- FormsAuthenticationEventArgs.cs
- BooleanKeyFrameCollection.cs
- SignerInfo.cs
- UTF32Encoding.cs
- PeerNameRecordCollection.cs
- VectorConverter.cs
- WeakReferenceEnumerator.cs
- CrossSiteScriptingValidation.cs
- SpellerStatusTable.cs
- AsymmetricCryptoHandle.cs
- ExpandCollapseProviderWrapper.cs
- QilPatternVisitor.cs
- XmlDataCollection.cs
- EventsTab.cs
- MoveSizeWinEventHandler.cs
- TrackingWorkflowEventArgs.cs
- OperationAbortedException.cs
- AttachedPropertyMethodSelector.cs
- JapaneseCalendar.cs
- XmlSchemaExporter.cs
- TransportConfigurationTypeElementCollection.cs
- DynamicDocumentPaginator.cs
- Pair.cs
- HttpHeaderCollection.cs
- SelectionWordBreaker.cs
- TemplatePartAttribute.cs
- MeasureData.cs
- TypeCodeDomSerializer.cs
- TreeView.cs
- HighlightVisual.cs
- PropertyRecord.cs
- Interop.cs
- ItemsControl.cs
- SystemWebCachingSectionGroup.cs
- DataGridViewSortCompareEventArgs.cs
- LinqDataSourceDeleteEventArgs.cs