[hornetq-commits] JBoss hornetq SVN: r9207 - trunk/src/main/org/hornetq/core/cluster/impl.

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2010-05-07 05:03:55 -0400 (Fri, 07 May 2010)
New Revision: 9207

Modified:
   trunk/src/main/org/hornetq/core/cluster/impl/DiscoveryGroupImpl.java
Log:
https://jira.jboss.org/jira/browse/HORNETQ-383: Unreachable network prevents HornetQ server with discovery group to start

* log an error if the discovery group can not be started

Modified: trunk/src/main/org/hornetq/core/cluster/impl/DiscoveryGroupImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/cluster/impl/DiscoveryGroupImpl.java	2010-05-07 05:58:16 UTC (rev 9206)
+++ trunk/src/main/org/hornetq/core/cluster/impl/DiscoveryGroupImpl.java	2010-05-07 09:03:55 UTC (rev 9207)
@@ -13,10 +13,10 @@
 
 package org.hornetq.core.cluster.impl;
 
+import java.io.IOException;
 import java.io.InterruptedIOException;
 import java.net.DatagramPacket;
 import java.net.InetAddress;
-import java.net.InetSocketAddress;
 import java.net.MulticastSocket;
 import java.util.ArrayList;
 import java.util.HashMap;
@@ -114,17 +114,25 @@
          return;
       }
 
-      socket = new MulticastSocket(groupPort);
+      try {
+         socket = new MulticastSocket(groupPort);
 
-      if (localBindAddress != null)
+         if (localBindAddress != null)
+         {
+            socket.setInterface(localBindAddress);
+         }
+
+         socket.joinGroup(groupAddress);
+
+         socket.setSoTimeout(DiscoveryGroupImpl.SOCKET_TIMEOUT);
+      }
+      catch (IOException e)
       {
-         socket.setInterface(localBindAddress);
+         log.error("Failed to create discovery group socket", e);
+         
+         return;
       }
-
-      socket.joinGroup(groupAddress);
-
-      socket.setSoTimeout(DiscoveryGroupImpl.SOCKET_TIMEOUT);
-
+      
       started = true;
 
       thread = new Thread(this, "hornetq-discovery-group-thread-" + name);