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

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

Author: estebanschifman
Date: 2006-07-06 17:27:55 -0400 (Thu, 06 Jul 2006)
New Revision: 4932

Added:
   labs/jbossesb/trunk/ESBCore/listeners/src/org/jboss/soa/esb/listeners/ZZderivedSqlTablePoller.java
Log:
Simple example of how to extend SqlTablePoller class

Added: labs/jbossesb/trunk/ESBCore/listeners/src/org/jboss/soa/esb/listeners/ZZderivedSqlTablePoller.java
===================================================================
--- labs/jbossesb/trunk/ESBCore/listeners/src/org/jboss/soa/esb/listeners/ZZderivedSqlTablePoller.java	2006-07-06 21:24:01 UTC (rev 4931)
+++ labs/jbossesb/trunk/ESBCore/listeners/src/org/jboss/soa/esb/listeners/ZZderivedSqlTablePoller.java	2006-07-06 21:27:55 UTC (rev 4932)
@@ -0,0 +1,54 @@
+package org.jboss.soa.esb.listeners;
+
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+import org.jboss.soa.esb.util.*;
+import org.jboss.soa.esb.helpers.*;
+
+public class ZZderivedSqlTablePoller extends SqlTablePoller
+{
+	  public static void main(String[] args) throws Exception
+	  	{	new ZZderivedSqlTablePoller(args[0]); }
+
+	  public ZZderivedSqlTablePoller(String pParamsUid) throws Exception
+	  {	super(pParamsUid);
+	  } //________________________________
+	  
+	  protected SqlChildProcess getSqlChildProcess
+  			(SqlPollerChildGroup pDad, DomElement p_oParms) throws Exception
+  	  {
+  		return new ZZChildProcess(pDad, p_oParms);
+  	  } //________________________________
+	  
+	  private static final SimpleDateFormat s_oFmt 
+	  		= new SimpleDateFormat("yyyy/MM/dd HH:mm:ss.mmm");
+
+	  protected class ZZChildProcess extends SqlChildProcess
+	  { 
+		  public ZZChildProcess(SqlPollerChildGroup p_oGrp, DomElement p_oP)
+	  		throws Exception
+	  		{	super(p_oGrp,p_oP); }
+		  
+		  protected String getMsgPfx()
+		  {	return EsbUtil.classSuffix(ZZderivedSqlTablePoller.class)
+			  +" "+s_oFmt.format(new Date(System.currentTimeMillis()))+" ";
+		  }
+
+		  // object m_oInstP contains parameters unique to this instance
+		  // object m_oParent.m_oChParms contains parameters common to all child threads
+		  // of the parent child group
+		  protected String getOkNotifContent()
+		  {
+			  return getMsgPfx()+" OK "+m_oInstP.toString();
+		  }
+		  
+		  protected String getErrorNotifContent()
+		  {		
+			  return getMsgPfx()+" eeeeerrrrrrrrr "+m_oInstP.toString();  
+		  }
+
+	  } //__________________________________________________
+
+	  
+} //____________________________________________________________________________