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
- EnvelopedSignatureTransform.cs
- HttpCachePolicy.cs
- FileLoadException.cs
- ServiceOperation.cs
- RegisteredArrayDeclaration.cs
- Peer.cs
- DataSourceCache.cs
- _BasicClient.cs
- EventTrigger.cs
- SimplePropertyEntry.cs
- EditingMode.cs
- WebPageTraceListener.cs
- _RegBlobWebProxyDataBuilder.cs
- PageCanvasSize.cs
- WebCodeGenerator.cs
- UnionExpr.cs
- oledbmetadatacollectionnames.cs
- PenThreadPool.cs
- GcHandle.cs
- ConditionCollection.cs
- WindowsBrush.cs
- EmptyControlCollection.cs
- BaseValidator.cs
- RealProxy.cs
- SystemFonts.cs
- XmlNode.cs
- SQLBinary.cs
- MetadataArtifactLoaderXmlReaderWrapper.cs
- ElementMarkupObject.cs
- ListViewItemSelectionChangedEvent.cs
- ReturnType.cs
- SyntaxCheck.cs
- autovalidator.cs
- ColorTransformHelper.cs
- AttributedMetaModel.cs
- LineUtil.cs
- RectIndependentAnimationStorage.cs
- oledbconnectionstring.cs
- WmiPutTraceRecord.cs
- Operand.cs
- CheckBoxField.cs
- MembershipSection.cs
- NamespaceImport.cs
- StreamingContext.cs
- EventLogPermissionEntry.cs
- PartialList.cs
- WinFormsComponentEditor.cs
- TagMapCollection.cs
- PageCodeDomTreeGenerator.cs
- ItemCollection.cs
- ChainedAsyncResult.cs
- PartialTrustVisibleAssemblyCollection.cs
- WebPartManager.cs
- StyleXamlParser.cs
- ObjectQueryState.cs
- ConsoleKeyInfo.cs
- DesignerHost.cs
- ListControl.cs
- _IPv4Address.cs
- SelectionEditor.cs
- AutomationElementCollection.cs
- PrivateFontCollection.cs
- FileDialogPermission.cs
- RuntimeConfigurationRecord.cs
- PointLightBase.cs
- TimeoutValidationAttribute.cs
- GlobalizationAssembly.cs
- BindingSource.cs
- XsdDateTime.cs
- OrderedDictionary.cs
- TagMapCollection.cs
- SocketCache.cs
- TagMapInfo.cs
- InvalidOleVariantTypeException.cs
- PluggableProtocol.cs
- SoapReflector.cs
- DataBoundLiteralControl.cs
- EntityContainerEmitter.cs
- LinqDataSourceView.cs
- ServiceBehaviorElementCollection.cs
- InvalidStoreProtectionKeyException.cs
- UncommonField.cs
- CachedFontFamily.cs
- FixUp.cs
- Oci.cs
- UnmanagedBitmapWrapper.cs
- _Events.cs
- ValueTypeFixupInfo.cs
- AxisAngleRotation3D.cs
- Stack.cs
- ProgressBarAutomationPeer.cs
- RequestQueryProcessor.cs
- DataGridColumnCollection.cs
- CompileLiteralTextParser.cs
- CommandSet.cs
- EDesignUtil.cs
- _IPv4Address.cs
- QilPatternFactory.cs
- UInt64Converter.cs
- SHA1CryptoServiceProvider.cs