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
- PeerDuplexChannel.cs
- FirewallWrapper.cs
- ProvidersHelper.cs
- CallbackValidator.cs
- ResourceContainer.cs
- SupportingTokenAuthenticatorSpecification.cs
- SafeHandle.cs
- SchemaTableOptionalColumn.cs
- CollectionDataContract.cs
- SupportsEventValidationAttribute.cs
- HttpContextWrapper.cs
- Button.cs
- DigitShape.cs
- Trace.cs
- DeploymentSection.cs
- GZipDecoder.cs
- RangeValuePatternIdentifiers.cs
- Vector3DAnimationUsingKeyFrames.cs
- DictionarySurrogate.cs
- DataGridTemplateColumn.cs
- KoreanLunisolarCalendar.cs
- FontClient.cs
- SID.cs
- IdnElement.cs
- listitem.cs
- MimeBasePart.cs
- TypeUnloadedException.cs
- SmiSettersStream.cs
- FormsAuthenticationCredentials.cs
- HttpClientCertificate.cs
- MatrixStack.cs
- Typography.cs
- ChangeBlockUndoRecord.cs
- OutputBuffer.cs
- ClientConfigurationSystem.cs
- RepeaterItem.cs
- ButtonRenderer.cs
- RegisteredArrayDeclaration.cs
- UIElementAutomationPeer.cs
- HttpWriter.cs
- SwitchExpression.cs
- MarkupObject.cs
- XMLUtil.cs
- JsonReaderWriterFactory.cs
- WebConfigurationManager.cs
- Int32Storage.cs
- Line.cs
- _SingleItemRequestCache.cs
- SearchForVirtualItemEventArgs.cs
- SelectionPatternIdentifiers.cs
- HttpListenerContext.cs
- WindowsSolidBrush.cs
- SafeTimerHandle.cs
- Wizard.cs
- SpecularMaterial.cs
- DragCompletedEventArgs.cs
- HtmlHistory.cs
- InstanceStore.cs
- HttpListenerContext.cs
- Floater.cs
- SymbolEqualComparer.cs
- Model3DGroup.cs
- LinqDataSourceHelper.cs
- CompilerCollection.cs
- ValueTable.cs
- NativeCompoundFileAPIs.cs
- SemanticAnalyzer.cs
- EllipticalNodeOperations.cs
- SimpleBitVector32.cs
- PassportAuthenticationEventArgs.cs
- HtmlElement.cs
- CfgParser.cs
- NamedElement.cs
- StylusPointProperties.cs
- HttpCachePolicyElement.cs
- ProtocolsConfigurationHandler.cs
- WinFormsUtils.cs
- WindowsListViewItemCheckBox.cs
- WindowsRegion.cs
- AutomationPropertyInfo.cs
- unitconverter.cs
- BaseHashHelper.cs
- SqlInfoMessageEvent.cs
- InstanceDescriptor.cs
- WebSysDefaultValueAttribute.cs
- HybridDictionary.cs
- ConditionCollection.cs
- SmiConnection.cs
- __ConsoleStream.cs
- LocalValueEnumerator.cs
- BamlRecordHelper.cs
- NativeMethodsCLR.cs
- FontWeightConverter.cs
- _LoggingObject.cs
- CrossAppDomainChannel.cs
- Substitution.cs
- RedBlackList.cs
- PaperSize.cs
- ToolStripRenderEventArgs.cs
- NeutralResourcesLanguageAttribute.cs