Changeset 13918 for branches/thasling/DistributedGA/DistributedGA.Core/Implementation/WcfMessageSender.cs

Timestamp:

06/17/16 17:46:40 (8 years ago)

Author:

thasling

Message:

#2615: implemented Dispose()-Method in all classes
also sending a message with the wcf-sender class was rewritten, because of Dispose
added new log entries when server removes peers from its dicionary

File:

• branches/thasling/DistributedGA/DistributedGA.Core/Implementation/WcfMessageSender.cs (modified) (1 diff)

branches/thasling/DistributedGA/DistributedGA.Core/Implementation/WcfMessageSender.cs

@@ -4 +4 @@
 using DistributedGA.Core.Interface;
 
-namespace DistributedGA.Core.Implementation
-{
-    public class WcfMessageSender : IMessageSender
-    {
-        private PeerInfo myself;
+namespace DistributedGA.Core.Implementation {
+  public class WcfMessageSender : IMessageSender {
+    private PeerInfo myself;
 
-        public void Init(PeerInfo source)
-        {
-            myself = source;
+    public void Init(PeerInfo source) {
+      myself = source;
+    }
+
+    public void SendData(PeerInfo destination, byte[][] data) {
+
+      var serviceUrl = "DistributedGA.svc";
+      var baseUri = new Uri(string.Concat("net.tcp://", destination.IpAddress, ":", destination.Port, "/DistributedGA"));
+      var serviceUri = new Uri(baseUri, serviceUrl);
+
+      var binding = new NetTcpBinding();
+      var endpoint = new EndpointAddress(serviceUri);
+      using (var myChannelFactory = new ChannelFactory<IMessageContract>(binding, endpoint)) {
+        using (IClientChannel client = (IClientChannel)myChannelFactory.CreateChannel()) {
+          ((IMessageContract)client).SendData(myself, data); //maybe timout exception...
         }
+      }
+    }
 
-        public void SendData(PeerInfo destination, byte[][] data)
-        {
-            var client = CreateServerClient(destination.IpAddress, destination.Port);
-            client.SendData(myself, data); //maybe timout exception...
-        }
-
-        private IMessageContract CreateServerClient(string ip, int port)
-        {
-            var serviceUrl = "DistributedGA.svc";
-            var baseUri = new Uri(string.Concat("net.tcp://", ip, ":", port, "/DistributedGA"));
-            var serviceUri = new Uri(baseUri, serviceUrl);
-
-            var binding = new NetTcpBinding();
-            var endpoint = new EndpointAddress(serviceUri);
-            var myChannelFactory = new ChannelFactory<IMessageContract>(binding, endpoint);
-
-            IMessageContract client = null;
-            client = myChannelFactory.CreateChannel();
-            return client;
-        }
+    public void Dispose() {
 
     }
+  }
 }