[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