From 6b69ba93d110c01e86c8c440d3f186bbbb4fd8e0 Mon Sep 17 00:00:00 2001
From: "william.liangf" <william.liangf@1a56cb94-b969-4eaa-88fa-be21384802f2>
Date: Tue, 1 Nov 2011 13:30:17 +0000
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=97=A5=E5=BF=97=E4=BF=A1?=
 =?UTF-8?q?=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

git-svn-id: http://code.alibabatech.com/svn/dubbo/trunk@167 1a56cb94-b969-4eaa-88fa-be21384802f2
---
 .../registry/multicast/MulticastRegistry.java      | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/dubbo-registry-multicast/src/main/java/com/alibaba/dubbo/registry/multicast/MulticastRegistry.java b/dubbo-registry-multicast/src/main/java/com/alibaba/dubbo/registry/multicast/MulticastRegistry.java
index c477387254..e1748dafdc 100644
--- a/dubbo-registry-multicast/src/main/java/com/alibaba/dubbo/registry/multicast/MulticastRegistry.java
+++ b/dubbo-registry-multicast/src/main/java/com/alibaba/dubbo/registry/multicast/MulticastRegistry.java
@@ -49,9 +49,9 @@ public class MulticastRegistry extends AbstractRegistry {
 
     private static final String UNSUBSCRIBE = "unsubscribe";
     
-    private InetAddress mutilcastAddress;
+    private final InetAddress mutilcastAddress;
     
-    private MulticastSocket mutilcastSocket;
+    private final MulticastSocket mutilcastSocket;
     
     public MulticastRegistry(URL url) {
         super(url);
@@ -85,7 +85,7 @@ public class MulticastRegistry extends AbstractRegistry {
                         }
                     }
                 }
-            }, "MulticastRegistry");
+            }, "MulticastRegistryReceiver");
             thread.setDaemon(true);
             thread.start();
         } catch (IOException e) {
@@ -137,7 +137,7 @@ public class MulticastRegistry extends AbstractRegistry {
             String service = url.getServiceKey();
             if (getRegistered().containsKey(service)) {
                 for (URL u : getRegistered().get(service)) {
-                    unicast(REGISTER + " " + u.toFullString(), url);
+                    unicast(REGISTER + " " + u.toFullString(), url.getHost());
                 }
             }
         } else if (msg.startsWith(UNSUBSCRIBE)) {
@@ -157,13 +157,13 @@ public class MulticastRegistry extends AbstractRegistry {
         }
     }
     
-    private void unicast(String msg, URL url) {
+    private void unicast(String msg, String host) {
         if (logger.isInfoEnabled()) {
-            logger.info("Send unicast message: " + msg + " to " + url.getAddress() + ":" + mutilcastSocket.getLocalPort());
+            logger.info("Send unicast message: " + msg + " to " + host + ":" + mutilcastSocket.getLocalPort());
         }
         try {
             byte[] data = (msg + "\n").getBytes();
-            DatagramPacket hi = new DatagramPacket(data, data.length, InetAddress.getByName(url.getHost()), mutilcastSocket.getLocalPort());
+            DatagramPacket hi = new DatagramPacket(data, data.length, InetAddress.getByName(host), mutilcastSocket.getLocalPort());
             mutilcastSocket.send(hi);
         } catch (Exception e) {
             throw new IllegalStateException(e.getMessage(), e);