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
- SocketException.cs
- DesignerHelpers.cs
- ServiceReflector.cs
- DecimalMinMaxAggregationOperator.cs
- WebRequest.cs
- PageBuildProvider.cs
- OutputCacheModule.cs
- _OverlappedAsyncResult.cs
- ListViewInsertionMark.cs
- EventLogPermission.cs
- DependencyPropertyKind.cs
- MsmqBindingElementBase.cs
- SqlCachedBuffer.cs
- SqlCacheDependency.cs
- TreeViewEvent.cs
- SQLInt16.cs
- DrawingGroupDrawingContext.cs
- Classification.cs
- CanExecuteRoutedEventArgs.cs
- FilteredAttributeCollection.cs
- InheritanceRules.cs
- TypeGeneratedEventArgs.cs
- ZoomingMessageFilter.cs
- ListViewInsertionMark.cs
- NativeMethods.cs
- MessageSmuggler.cs
- XslException.cs
- SqlParameterizer.cs
- ProcessStartInfo.cs
- EdmTypeAttribute.cs
- CompilationUtil.cs
- CalendarDesigner.cs
- ConnectionManagementElement.cs
- StorageScalarPropertyMapping.cs
- AnonymousIdentificationSection.cs
- RestHandler.cs
- RegexGroupCollection.cs
- FormViewDeletedEventArgs.cs
- PropertyRecord.cs
- MissingManifestResourceException.cs
- UrlPath.cs
- DataGridViewCheckBoxColumn.cs
- MergablePropertyAttribute.cs
- EmptyEnumerator.cs
- ArglessEventHandlerProxy.cs
- TypeConverterHelper.cs
- RoleBoolean.cs
- XmlQualifiedName.cs
- WindowsScrollBarBits.cs
- EnvelopedPkcs7.cs
- WebPartMenuStyle.cs
- IDispatchConstantAttribute.cs
- NonBatchDirectoryCompiler.cs
- BlobPersonalizationState.cs
- followingquery.cs
- Automation.cs
- AppearanceEditorPart.cs
- ContentType.cs
- AuthorizationRule.cs
- InstalledFontCollection.cs
- WindowsRebar.cs
- TextUtf8RawTextWriter.cs
- PartialList.cs
- ServicePointManager.cs
- MetadataPropertyAttribute.cs
- MatrixKeyFrameCollection.cs
- UnsupportedPolicyOptionsException.cs
- Misc.cs
- ping.cs
- _NegotiateClient.cs
- PageAsyncTask.cs
- Expr.cs
- TableLayoutSettings.cs
- RecordsAffectedEventArgs.cs
- DayRenderEvent.cs
- LogicalExpr.cs
- PropertyDescriptorCollection.cs
- BamlRecordHelper.cs
- GridEntry.cs
- OutputCacheProviderCollection.cs
- HebrewNumber.cs
- BamlRecords.cs
- WebInvokeAttribute.cs
- PluralizationService.cs
- StructuredTypeEmitter.cs
- QueueSurrogate.cs
- RenderDataDrawingContext.cs
- DecodeHelper.cs
- EmbeddedObject.cs
- InvalidOleVariantTypeException.cs
- OutputCacheEntry.cs
- SecureUICommand.cs
- _NestedMultipleAsyncResult.cs
- TypeSystem.cs
- HttpPostClientProtocol.cs
- ToolStripContentPanel.cs
- WebPartVerbCollection.cs
- RemoteWebConfigurationHostStream.cs
- ResourcePermissionBase.cs
- WebReferencesBuildProvider.cs