Only use the source address to join a multicast group if it was speci…

…fied. See netty#216
shijinkui · Apr 2, 2012 · 221a774 · 221a774
1 parent 7f84080
commit 221a774
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/transport/src/main/java/io/netty/channel/socket/nio/NioDatagramChannel.java b/transport/src/main/java/io/netty/channel/socket/nio/NioDatagramChannel.java
@@ -136,7 +136,13 @@ public ChannelFuture joinGroup(InetAddress multicastAddress, NetworkInterface ne
             }
 
             try {
-                MembershipKey key = getJdkChannel().getChannel().join(multicastAddress, networkInterface);
+                MembershipKey key;
+                if (source == null) {
+                    key = getJdkChannel().getChannel().join(multicastAddress, networkInterface);
+                } else {
+                    key = getJdkChannel().getChannel().join(multicastAddress, networkInterface, source);
+                }
+
                 synchronized (this) {
                     if (memberships == null) {
                         memberships = new HashMap<InetAddress, List<MembershipKey>>();
@@ -147,7 +153,7 @@ public ChannelFuture joinGroup(InetAddress multicastAddress, NetworkInterface ne
                         keys = new ArrayList<MembershipKey>();
                         memberships.put(multicastAddress, keys);
                     }
-
+                    System.out.println(key);
                     keys.add(key);
                 }
             } catch (Throwable e) {