[jboss-svn-commits] JBL Code SVN: r7496 - labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway

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

Author: estebanschifman
Date: 2006-11-09 10:14:15 -0500 (Thu, 09 Nov 2006)
New Revision: 7496

Modified:
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/SqlTableGatewayListener.java
Log:
Commit ongoing work

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/SqlTableGatewayListener.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/SqlTableGatewayListener.java	2006-11-09 14:41:33 UTC (rev 7495)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/SqlTableGatewayListener.java	2006-11-09 15:14:15 UTC (rev 7496)
@@ -54,7 +54,19 @@
 import org.jboss.soa.esb.util.Util;
 
 /**
+ *
+ * Polls an SQL table for rows that satisfy conditions defined in the xml runtime configuration
  * 
+ * <p/>When a row that matches conditions is retrieved, it's contents are packed into an ESB Message
+ * and
+ *
+ * <p/> The following fields are mandatory (see checkMyParms()):
+ * <br/>
+ * <br/>SQL table name
+ * <br/>list of fields to retrieve
+ * <br/>list of key fields to use in the update statement
+ * <br/>a field that will be used to mark a row as 'pending(p)', 'in process(w)', 'done(d)' or 'in error(e)'
+ * 
  * @author <a href="mailto:schifest at heuristica.com.ar">schifest at heuristica.com.ar</a>
  * @since Version 4.0
  *
@@ -537,15 +549,22 @@
  * @since Version 4.0
  *
  */
-    private static class PackageRowContents
+    private class PackageRowContents
     {
     	public Message process (Object obj) throws Exception
     	{
-    		if (! (obj instanceof List))
-    			throw new Exception ("Object must be instance of List");
+    		if (! (obj instanceof Map))
+    			throw new Exception ("Object must be instance of Map");
 
     		Message message = MessageFactory.getInstance().getMessage();
-    		message.getProperties().setProperty(ListenerTagNames.SQL_ROW_DATA_TAG, obj);    		
+    		org.jboss.soa.esb.message.Properties props = message.getProperties();
+
+    		props.setProperty(ListenerTagNames.SQL_ROW_DATA_TAG, obj);
+    		props.setProperty(JDBCEpr.DRIVER_TAG	,_driver);
+    		props.setProperty(JDBCEpr.URL_TAG		,_url);
+    		props.setProperty(JDBCEpr.USERNAME_TAG	,_user);
+    		props.setProperty(JDBCEpr.PASSWORD_TAG	, _password);
+    		
     		return message;
     	}    	
     } //____________________________________________________