[hornetq-commits] JBoss hornetq SVN: r9250 - trunk/src/main/org/hornetq/ra/inflow.

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2010-05-21 08:52:44 -0400 (Fri, 21 May 2010)
New Revision: 9250

Modified:
   trunk/src/main/org/hornetq/ra/inflow/HornetQActivation.java
Log:
Resource Adapter Activation setup

* try to setup the HornetQActivation multiple times in case the JMS resources have not been deployed
  by the AS before the MDB is activated

Modified: trunk/src/main/org/hornetq/ra/inflow/HornetQActivation.java
===================================================================
--- trunk/src/main/org/hornetq/ra/inflow/HornetQActivation.java	2010-05-20 12:48:35 UTC (rev 9249)
+++ trunk/src/main/org/hornetq/ra/inflow/HornetQActivation.java	2010-05-21 12:52:44 UTC (rev 9250)
@@ -102,6 +102,13 @@
 
    private HornetQConnectionFactory factory;
 
+   // Whether we are in the failure recovery loop
+   private AtomicBoolean inFailure = new AtomicBoolean(false);
+
+   private final int setupAttempts = 5;
+   
+   private final long setupInterval = 10 * 1000;
+   
    static
    {
       try
@@ -492,6 +499,56 @@
    }
 
    /**
+    * Handles any failure by trying to reconnect
+    * 
+    * @param failure the reason for the failure
+    */
+   public void handleFailure(Throwable failure)
+   {
+      log.warn("Failure in HornetQ activation " + spec, failure);
+      int reconnectCount = 0;
+      
+      // Only enter the failure loop once
+      if (inFailure.getAndSet(true))
+         return;
+      try
+      {
+         while (deliveryActive.get() && reconnectCount < setupAttempts)
+         {
+            teardown();
+
+            try
+            {
+               Thread.sleep(setupInterval);
+            }
+            catch (InterruptedException e)
+            {
+               log.debug("Interrupted trying to reconnect " + spec, e);
+               break;
+            }
+
+            log.info("Attempting to reconnect " + spec);
+            try
+            {
+               setup();
+               log.info("Reconnected with HornetQ");            
+               break;
+            }
+            catch (Throwable t)
+            {
+               log.error("Unable to reconnect " + spec, t);
+            }
+            ++reconnectCount;
+         }
+      }
+      finally
+      {
+         // Leaving failure recovery loop
+         inFailure.set(false);
+      }
+   }
+   
+   /**
     * Handles the setup
     */
    private class SetupActivation implements Work
@@ -504,7 +561,7 @@
          }
          catch (Throwable t)
          {
-            HornetQActivation.log.error("Unable to start activation ", t);
+            handleFailure(t);
          }
       }