[hornetq-commits] JBoss hornetq SVN: r10234 - branches/HORNETQ-316/src/main/org/hornetq/core/server/cluster/impl.

do-not-reply at jboss.org do-not-reply at jboss.org
Mon Feb 21 11:51:47 EST 2011


Author: igarashitm
Date: 2011-02-21 11:51:47 -0500 (Mon, 21 Feb 2011)
New Revision: 10234

Modified:
   branches/HORNETQ-316/src/main/org/hornetq/core/server/cluster/impl/BroadcastGroupImpl.java
Log:
BroadcastGroupImpl was broken when localBindAddress was null in config


Modified: branches/HORNETQ-316/src/main/org/hornetq/core/server/cluster/impl/BroadcastGroupImpl.java
===================================================================
--- branches/HORNETQ-316/src/main/org/hornetq/core/server/cluster/impl/BroadcastGroupImpl.java	2011-02-20 14:34:41 UTC (rev 10233)
+++ branches/HORNETQ-316/src/main/org/hornetq/core/server/cluster/impl/BroadcastGroupImpl.java	2011-02-21 16:51:47 UTC (rev 10234)
@@ -107,8 +107,13 @@
       Map<String,Object> params = this.broadcastGroupConfiguration.getParams();
       int localPort = Integer.parseInt((String)params.get(BroadcastGroupConstants.LOCAL_BIND_PORT_NAME));
       String localAddr = (String)params.get(BroadcastGroupConstants.LOCAL_BIND_ADDRESS_NAME);
-      InetAddress localAddress = InetAddress.getByName(localAddr);
 
+      InetAddress localAddress = null;
+      if(localAddr!=null)
+      {
+         localAddress = InetAddress.getByName(localAddr);
+      }
+
       if (localPort != -1)
       {
          socket = new DatagramSocket(localPort, localAddress);



More information about the hornetq-commits mailing list