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
- JsonDeserializer.cs
- HierarchicalDataBoundControl.cs
- UmAlQuraCalendar.cs
- StreamWriter.cs
- FocusTracker.cs
- ParseHttpDate.cs
- ClonableStack.cs
- PauseStoryboard.cs
- XmlDataProvider.cs
- ImageFormatConverter.cs
- DefaultValueMapping.cs
- PropertyStore.cs
- XPathSelfQuery.cs
- SettingsSavedEventArgs.cs
- DataGridTablesFactory.cs
- ProgressBarHighlightConverter.cs
- FixedTextContainer.cs
- GC.cs
- ContextMenuService.cs
- PeerCollaborationPermission.cs
- SEHException.cs
- LinkDescriptor.cs
- ManipulationVelocities.cs
- WmlSelectionListAdapter.cs
- RichTextBoxAutomationPeer.cs
- TrueReadOnlyCollection.cs
- DrawingImage.cs
- Constants.cs
- WriteFileContext.cs
- RectValueSerializer.cs
- CodeGeneratorOptions.cs
- MimeFormReflector.cs
- StrokeCollection.cs
- XsltLibrary.cs
- Error.cs
- Substitution.cs
- HostProtectionPermission.cs
- SmtpLoginAuthenticationModule.cs
- EventWaitHandleSecurity.cs
- OracleString.cs
- unitconverter.cs
- DurableInstanceContextProvider.cs
- DataContractAttribute.cs
- AncestorChangedEventArgs.cs
- CodeSnippetExpression.cs
- ObjectQuery_EntitySqlExtensions.cs
- KoreanLunisolarCalendar.cs
- SubclassTypeValidator.cs
- ClientOptions.cs
- SQLGuid.cs
- Material.cs
- InputLanguageProfileNotifySink.cs
- NamedPermissionSet.cs
- SemaphoreFullException.cs
- ClientSession.cs
- BamlResourceDeserializer.cs
- XmlBindingWorker.cs
- DBConnection.cs
- BaseAddressPrefixFilterElement.cs
- NamespaceList.cs
- ObsoleteAttribute.cs
- HealthMonitoringSectionHelper.cs
- LeaseManager.cs
- TargetControlTypeCache.cs
- SapiRecoInterop.cs
- ProviderUtil.cs
- EntityCommandDefinition.cs
- DataGridViewCheckBoxCell.cs
- CodeTypeMemberCollection.cs
- TableDetailsCollection.cs
- DefaultHttpHandler.cs
- UnionQueryOperator.cs
- MessageQueueCriteria.cs
- DbConnectionStringBuilder.cs
- BaseAddressElementCollection.cs
- BulletChrome.cs
- EntityContainerAssociationSetEnd.cs
- WebPartDisplayModeCollection.cs
- XmlCDATASection.cs
- StorageBasedPackageProperties.cs
- ClientBuildManagerCallback.cs
- PriorityQueue.cs
- QuaternionAnimation.cs
- CopyEncoder.cs
- EmptyElement.cs
- CommonDialog.cs
- GeometryHitTestParameters.cs
- PropertyDescriptor.cs
- PrimitiveXmlSerializers.cs
- SwitchElementsCollection.cs
- AnimationTimeline.cs
- _FixedSizeReader.cs
- EntityType.cs
- EmptyStringExpandableObjectConverter.cs
- SimpleType.cs
- EventLogPermissionEntryCollection.cs
- EllipseGeometry.cs
- SubMenuStyle.cs
- AnnotationComponentChooser.cs
- DesignerDataView.cs