Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / NetFx40 / System.ServiceModel.Discovery / System / ServiceModel / Discovery / DiscoveryClientDuplexChannel.cs / 1305376 / DiscoveryClientDuplexChannel.cs
//---------------------------------------------------------------- // Copyright (c) Microsoft Corporation. All rights reserved. //--------------------------------------------------------------- namespace System.ServiceModel.Discovery { using System; using System.ServiceModel; using System.ServiceModel.Channels; class DiscoveryClientDuplexChannel: DiscoveryClientOutputChannel , IDuplexChannel where TChannel : class, IDuplexChannel { public DiscoveryClientDuplexChannel( ChannelManagerBase channelManagerBase, IChannelFactory innerChannelFactory, FindCriteria findCriteria, DiscoveryEndpointProvider discoveryEndpointProvider) : base(channelManagerBase, innerChannelFactory, findCriteria, discoveryEndpointProvider) { } public EndpointAddress LocalAddress { get { if (this.InnerChannel == null) { return DiscoveryClientBindingElement.DiscoveryEndpointAddress; } return this.InnerChannel.LocalAddress; } } public override IAsyncResult BeginSend(Message message, TimeSpan timeout, AsyncCallback callback, object state) { this.EnsureReplyTo(message); return base.BeginSend(message, timeout, callback, state); } public override void Send(Message message, TimeSpan timeout) { this.EnsureReplyTo(message); base.Send(message, timeout); } public IAsyncResult BeginReceive(TimeSpan timeout, AsyncCallback callback, object state) { return this.InnerChannel.BeginReceive(timeout, callback, state); } public IAsyncResult BeginReceive(AsyncCallback callback, object state) { return this.InnerChannel.BeginReceive(callback, state); } public IAsyncResult BeginTryReceive(TimeSpan timeout, AsyncCallback callback, object state) { return this.InnerChannel.BeginTryReceive(timeout, callback, state); } public IAsyncResult BeginWaitForMessage(TimeSpan timeout, AsyncCallback callback, object state) { return this.InnerChannel.BeginWaitForMessage(timeout, callback, state); } public Message EndReceive(IAsyncResult result) { return this.InnerChannel.EndReceive(result); } public bool EndTryReceive(IAsyncResult result, out Message message) { return this.InnerChannel.EndTryReceive(result, out message); } public bool EndWaitForMessage(IAsyncResult result) { return this.InnerChannel.EndWaitForMessage(result); } public Message Receive(TimeSpan timeout) { return this.InnerChannel.Receive(timeout); } public Message Receive() { return this.InnerChannel.Receive(); } public bool TryReceive(TimeSpan timeout, out Message message) { return this.InnerChannel.TryReceive(timeout, out message); } public bool WaitForMessage(TimeSpan timeout) { return this.InnerChannel.WaitForMessage(timeout); } void EnsureReplyTo(Message message) { if (message != null && message.Headers != null) { if (message.Headers.ReplyTo == DiscoveryClientBindingElement.DiscoveryEndpointAddress) { message.Headers.ReplyTo = this.LocalAddress; } } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- AnnotationComponentChooser.cs
- AppSettingsSection.cs
- FixedPage.cs
- StickyNoteAnnotations.cs
- DataGridViewCellStateChangedEventArgs.cs
- ProxyWebPartManager.cs
- Policy.cs
- FuncCompletionCallbackWrapper.cs
- Socket.cs
- DescendentsWalker.cs
- UserNamePasswordValidator.cs
- SapiGrammar.cs
- RenderingBiasValidation.cs
- AppDomain.cs
- Menu.cs
- AnyAllSearchOperator.cs
- DataObjectFieldAttribute.cs
- XmlElementAttribute.cs
- UnitControl.cs
- DataServiceQueryProvider.cs
- EnumUnknown.cs
- EntityDataSourceChangingEventArgs.cs
- PeerCollaborationPermission.cs
- WarningException.cs
- VectorConverter.cs
- TemplatePagerField.cs
- CultureSpecificCharacterBufferRange.cs
- InkCanvasAutomationPeer.cs
- SoapDocumentMethodAttribute.cs
- UIElementParaClient.cs
- FormsAuthenticationEventArgs.cs
- Int64Animation.cs
- TextEffect.cs
- SortQuery.cs
- MethodBody.cs
- LocalizableResourceBuilder.cs
- ToolStripContainer.cs
- WebBrowserContainer.cs
- OnOperation.cs
- Utils.cs
- TableLayoutStyleCollection.cs
- AuthenticationService.cs
- DetailsViewDeleteEventArgs.cs
- TextTreeRootNode.cs
- SessionIDManager.cs
- OperandQuery.cs
- RuleSettingsCollection.cs
- LoginName.cs
- embossbitmapeffect.cs
- WindowsScrollBarBits.cs
- StyleTypedPropertyAttribute.cs
- ConfigurationSettings.cs
- OLEDB_Util.cs
- Int16AnimationBase.cs
- RectangleGeometry.cs
- TreeWalker.cs
- UrlMappingsSection.cs
- Context.cs
- IdentityNotMappedException.cs
- SafeBitVector32.cs
- DataGridViewCheckBoxColumn.cs
- LogExtent.cs
- Identifier.cs
- PreviewKeyDownEventArgs.cs
- WindowsStartMenu.cs
- CompositeControl.cs
- TdsEnums.cs
- DynamicILGenerator.cs
- ObjectDataSourceMethodEventArgs.cs
- BoundColumn.cs
- MediaSystem.cs
- ImmutablePropertyDescriptorGridEntry.cs
- MachineKeyConverter.cs
- SystemNetworkInterface.cs
- RealizationDrawingContextWalker.cs
- SqlConnectionPoolGroupProviderInfo.cs
- Form.cs
- XmlHierarchyData.cs
- OleDbPropertySetGuid.cs
- DerivedKeySecurityTokenStub.cs
- MembershipPasswordException.cs
- WorkflowOperationBehavior.cs
- WebEvents.cs
- SectionVisual.cs
- TreeViewHitTestInfo.cs
- DriveInfo.cs
- StringAnimationUsingKeyFrames.cs
- Line.cs
- BehaviorEditorPart.cs
- UnsafeNativeMethods.cs
- BrowserCapabilitiesCodeGenerator.cs
- StreamGeometryContext.cs
- DataRow.cs
- MarkupWriter.cs
- invalidudtexception.cs
- BinaryParser.cs
- DataGridViewRowHeightInfoPushedEventArgs.cs
- ArraySortHelper.cs
- SimpleWebHandlerParser.cs
- TableRowCollection.cs