[jboss-svn-commits] JBL Code SVN: r23127 - in labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb: notification and 1 other directory.

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

Author: mark.little at jboss.com
Date: 2008-09-27 17:33:54 -0400 (Sat, 27 Sep 2008)
New Revision: 23127

Modified:
   labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/listeners/gateway/SqlTableGatewayListener.java
   labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/notification/NotifySqlTable.java
Log:
https://jira.jboss.org/jira/browse/JBESB-1887

Modified: labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/listeners/gateway/SqlTableGatewayListener.java
===================================================================
--- labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/listeners/gateway/SqlTableGatewayListener.java	2008-09-27 21:12:44 UTC (rev 23126)
+++ labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/listeners/gateway/SqlTableGatewayListener.java	2008-09-27 21:33:54 UTC (rev 23127)
@@ -755,6 +755,16 @@
                     _logger.warn("Cannot change row state from " + fromState
                             + " to " + toState + ".  Number of rows in state "
                             + fromState + " = " + count);
+                    
+                    if (count == 0)  // the execute affected zero rows!
+                    {
+                        // https://jira.jboss.org/jira/browse/SOA-642
+                        
+                        _logger.warn("No rows affected by update statement. Check listener/gateway/notifier table definitions are correct.");
+                    }
+                    else
+                        _logger.warn("Curent implementation expected only one row to be applicable to update request.");
+                    
                     return false;
                 }
             }

Modified: labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/notification/NotifySqlTable.java
===================================================================
--- labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/notification/NotifySqlTable.java	2008-09-27 21:12:44 UTC (rev 23126)
+++ labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/notification/NotifySqlTable.java	2008-09-27 21:33:54 UTC (rev 23127)
@@ -166,7 +166,7 @@
 		{
 			oConn = createJdbcCleanConnection();
 			ps = oConn.prepareStatement(getInsertStmt());
-			oConn.execUpdWait(ps, 3);
+			oConn.execUpdWait(ps, 3); // TODO the executeUpdate routine doesn't check return code, which could mask a problem https://jira.jboss.org/jira/browse/SOA-642                  
 			oConn.commit();
 		} 
 		catch( SQLException e)