2009-05-22 Atsushi Enomoto <atsushi@ximian.com>

	* TcpDuplexSessionChannel.cs : add ReplyTo header.

svn path=/trunk/mcs/; revision=134583

diff --git a/mcs/class/System.ServiceModel/System.ServiceModel.Channels/ChangeLog b/mcs/class/System.ServiceModel/System.ServiceModel.Channels/ChangeLog
index 15ad7d7c4257842c529e76aae2660f1d6bee4315..efef05f5d735799495722165f79bb1e2ebdc691a 100755 (executable)
--- a/mcs/class/System.ServiceModel/System.ServiceModel.Channels/ChangeLog
+++ b/mcs/class/System.ServiceModel/System.ServiceModel.Channels/ChangeLog
@@ -1,3 +1,7 @@
+2009-05-22  Atsushi Enomoto  <atsushi@ximian.com>
+
+       * TcpDuplexSessionChannel.cs : add ReplyTo header.
+
 2009-05-21  Atsushi Enomoto  <atsushi@ximian.com>
 
        * DuplexSessionBase.cs : new file, for session implementation.

diff --git a/mcs/class/System.ServiceModel/System.ServiceModel.Channels/TcpDuplexSessionChannel.cs b/mcs/class/System.ServiceModel/System.ServiceModel.Channels/TcpDuplexSessionChannel.cs
index cf46395157113f41df31a64f64e5e3376476cfd4..8ce9f0a42f49272af3d9bae58b9e3b760b2c8401 100644 (file)
--- a/mcs/class/System.ServiceModel/System.ServiceModel.Channels/TcpDuplexSessionChannel.cs
+++ b/mcs/class/System.ServiceModel/System.ServiceModel.Channels/TcpDuplexSessionChannel.cs
@@ -110,10 +110,11 @@ namespace System.ServiceModel.Channels
                
                public override void Send (Message message, TimeSpan timeout)
                {
-                       // FIXME: add MessageID and ReplyTo (might not be here; it's likely in session channel in common)
-
                        if (!is_service_side && message.Headers.To == null)
                                message.Headers.To = RemoteAddress.Uri;
+                       if (!is_service_side && message.Headers.ReplyTo == null)
+                               message.Headers.ReplyTo = new EndpointAddress (Constants.WsaAnonymousUri);
+
                        client.SendTimeout = (int) timeout.TotalMilliseconds;
                        frame.WriteSizedMessage (message);
                        // FIXME: should EndRecord be sent here?