[Jboss-svn-commits] JBL Code SVN: r4931 - labs/jbossesb/trunk/ESBCore/listeners/src/org/jboss/soa/esb/listeners

[<jbo...@li...>]

Author: estebanschifman
Date: 2006-07-06 17:24:01 -0400 (Thu, 06 Jul 2006)
New Revision: 4931

Modified:
   labs/jbossesb/trunk/ESBCore/listeners/src/org/jboss/soa/esb/listeners/SqlTablePoller.java
Log:
move getSqlChildProcess() to outermost class (easier override)


Modified: labs/jbossesb/trunk/ESBCore/listeners/src/org/jboss/soa/esb/listeners/SqlTablePoller.java
===================================================================
--- labs/jbossesb/trunk/ESBCore/listeners/src/org/jboss/soa/esb/listeners/SqlTablePoller.java	2006-07-06 21:21:49 UTC (rev 4930)
+++ labs/jbossesb/trunk/ESBCore/listeners/src/org/jboss/soa/esb/listeners/SqlTablePoller.java	2006-07-06 21:24:01 UTC (rev 4931)
@@ -195,18 +195,31 @@
 	runUntilEndRequested();
   } //__________________________________
 
+  /**
+   * Override this method if you wish to extend the SqlChildProcess class
+   * (for example with ad-hoc notifications for OK list or Error list)
+   * @param p_oParms = DomElement containing attributes of trigger
+   * @return  the SqlChildProcess to be started
+   * @throws Exception
+   */
+  	protected SqlChildProcess getSqlChildProcess
+  		(SqlPollerChildGroup pDad, DomElement p_oParms) throws Exception
+  	{
+  		return new SqlChildProcess(pDad, p_oParms);
+  	} //________________________________
+
   @Override
   protected GroupOfChilds newChildGroup(ThreadGroup pThG) throws Exception
   {
   	return new SqlPollerChildGroup(pThG);
   } //__________________________________
   
-  private class SqlPollerChildGroup extends AbstractPoller.GroupOfChilds
+  protected class SqlPollerChildGroup extends AbstractPoller.GroupOfChilds
   {
 	JdbcCleanConn		m_oConn;
 	String[]			m_saKeys;
 	  
-    private SqlPollerChildGroup(ThreadGroup p_oThrGrp) throws Exception
+    protected SqlPollerChildGroup(ThreadGroup p_oThrGrp) throws Exception
     {	super(p_oThrGrp);    	
     } //________________________________
 
@@ -262,19 +275,6 @@
 
     } //________________________________
 	
-/**
- * Override this method if you wish to extend the SqlChildProcess class
- * (for example with ad-hoc notifications for OK list or Error list)
- * @param p_oParms = DomElement containing attributes of trigger
- * @return  the SqlChildProcess to be started
- * @throws Exception
- */
-	protected SqlChildProcess getSqlChildProcess(DomElement p_oParms)
-		throws Exception
-	{
-		return new SqlChildProcess(this, p_oParms);
-	} //________________________________
-
 	@Override
 	protected void doYourJob(DomElement p_oP) throws Exception
 	{
@@ -287,7 +287,7 @@
 	          break;
 	        }
 
-			SqlChildProcess oNew = getSqlChildProcess(oCurr);
+			SqlChildProcess oNew = getSqlChildProcess(this,oCurr);
 	        new Thread(m_oThrGrp,oNew).start();
 	        // Wait a little bit, so thread count will be updated
 	        // at some point in the past, this sleep was indispensable