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
- MediaTimeline.cs
- ACE.cs
- LinkLabel.cs
- RtfNavigator.cs
- TextChangedEventArgs.cs
- DbMetaDataCollectionNames.cs
- BindingSource.cs
- XmlConvert.cs
- QuaternionRotation3D.cs
- PointLight.cs
- XmlSchemaObjectTable.cs
- Wrapper.cs
- ImageInfo.cs
- LinkDescriptor.cs
- InvalidDataContractException.cs
- NullExtension.cs
- ControlCollection.cs
- CodeMethodInvokeExpression.cs
- RoutedCommand.cs
- LogStream.cs
- Bold.cs
- ModifiableIteratorCollection.cs
- UidManager.cs
- CompilerGlobalScopeAttribute.cs
- Point3D.cs
- ComponentResourceKeyConverter.cs
- RoleServiceManager.cs
- BinaryObjectReader.cs
- DesignerAdapterUtil.cs
- FreezableDefaultValueFactory.cs
- Image.cs
- PropertyInfoSet.cs
- _NetRes.cs
- SchemaNamespaceManager.cs
- SynchronousSendBindingElement.cs
- ListMarkerLine.cs
- SystemResourceKey.cs
- ReturnEventArgs.cs
- IIS7WorkerRequest.cs
- TextLineBreak.cs
- XmlObjectSerializerReadContextComplexJson.cs
- DateTimeAutomationPeer.cs
- WebPartUserCapability.cs
- SizeAnimationBase.cs
- SQLMembershipProvider.cs
- HtmlHead.cs
- MD5.cs
- BulletedListEventArgs.cs
- SqlBulkCopyColumnMappingCollection.cs
- GatewayDefinition.cs
- AuthenticationServiceManager.cs
- CodeAssignStatement.cs
- NodeFunctions.cs
- LineGeometry.cs
- HttpApplicationFactory.cs
- QueryContinueDragEventArgs.cs
- TypefaceMetricsCache.cs
- RtfToXamlLexer.cs
- XsltLoader.cs
- versioninfo.cs
- KeyValuePair.cs
- IteratorFilter.cs
- DoubleLinkListEnumerator.cs
- WebDisplayNameAttribute.cs
- TransformDescriptor.cs
- PathSegment.cs
- TextViewBase.cs
- LogicalMethodInfo.cs
- MimeFormatExtensions.cs
- ScriptResourceHandler.cs
- RowToFieldTransformer.cs
- ScriptingProfileServiceSection.cs
- SQLBinary.cs
- DecimalKeyFrameCollection.cs
- EventLogLink.cs
- AnnotationMap.cs
- SafeTimerHandle.cs
- WebPartVerbsEventArgs.cs
- BuildResultCache.cs
- Codec.cs
- CellParagraph.cs
- EditorZone.cs
- EventSinkActivity.cs
- TextEndOfLine.cs
- DbSetClause.cs
- DetailsViewInsertedEventArgs.cs
- SqlRetyper.cs
- InternalCache.cs
- NavigatorOutput.cs
- XmlILConstructAnalyzer.cs
- SecurityElementBase.cs
- Form.cs
- GeometryDrawing.cs
- CurrentChangingEventArgs.cs
- DNS.cs
- DataSourceExpressionCollection.cs
- SymLanguageType.cs
- WebSysDescriptionAttribute.cs
- CodeSnippetExpression.cs
- Documentation.cs