[jboss-svn-commits] JBL Code SVN: r35252 - labs/jbossrules/trunk/drools-grid/drools-grid-task/src/main/java/org/drools/grid/task.

[jboss-svn-commits at lists.jboss.org]

Author: salaboy21
Date: 2010-09-23 15:23:39 -0400 (Thu, 23 Sep 2010)
New Revision: 35252

Modified:
   labs/jbossrules/trunk/drools-grid/drools-grid-task/src/main/java/org/drools/grid/task/RemoteMinaHumanTaskConnector.java
Log:
JBRULES-2618:  Drools Grid Services - Improve and clean tests
	- reconnection for disconnected task nodes

Modified: labs/jbossrules/trunk/drools-grid/drools-grid-task/src/main/java/org/drools/grid/task/RemoteMinaHumanTaskConnector.java
===================================================================
--- labs/jbossrules/trunk/drools-grid/drools-grid-task/src/main/java/org/drools/grid/task/RemoteMinaHumanTaskConnector.java	2010-09-23 16:15:31 UTC (rev 35251)
+++ labs/jbossrules/trunk/drools-grid/drools-grid-task/src/main/java/org/drools/grid/task/RemoteMinaHumanTaskConnector.java	2010-09-23 19:23:39 UTC (rev 35252)
@@ -112,6 +112,13 @@
 
     private void addResponseHandler(int id,
                                     MessageResponseHandler responseHandler) {
+        if(this.connector == null){
+            try {
+                connect();
+            } catch (ConnectorException ex) {
+                Logger.getLogger(RemoteMinaHumanTaskConnector.class.getName()).log(Level.SEVERE, null, ex);
+            }
+        }
         ((MinaIoHandler) this.connector.getHandler()).addResponseHandler( id,
                                                                           responseHandler );
     }