[jboss-cvs] JBoss Messaging SVN: r8206 - branches/port1842/src/main/org/jboss/messaging/core/impl.

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

Author: jbertram at redhat.com
Date: 2011-02-05 15:19:55 -0500 (Sat, 05 Feb 2011)
New Revision: 8206

Modified:
   branches/port1842/src/main/org/jboss/messaging/core/impl/JDBCPersistenceManager.java
Log:
update default CLAIM_MESSAGE_IN_SUCK (used with hsqldb)

Modified: branches/port1842/src/main/org/jboss/messaging/core/impl/JDBCPersistenceManager.java
===================================================================
--- branches/port1842/src/main/org/jboss/messaging/core/impl/JDBCPersistenceManager.java	2011-02-02 00:56:47 UTC (rev 8205)
+++ branches/port1842/src/main/org/jboss/messaging/core/impl/JDBCPersistenceManager.java	2011-02-05 20:19:55 UTC (rev 8206)
@@ -3006,7 +3006,7 @@
 
       // sucker use
       map.put("UPDATE_MESSAGE_STATE", "UPDATE JBM_MSG_REF SET STATE = ? WHERE MESSAGE_ID = ? AND CHANNEL_ID = ?");
-      map.put("CLAIM_MESSAGE_IN_SUCK", "UPDATE JBM_MSG_REF SET STATE='C' WHERE CHANNEL_ID = ? AND STATE='S'");
+      map.put("CLAIM_MESSAGE_IN_SUCK", "UPDATE JBM_MSG_REF SET STATE='C' WHERE CHANNEL_ID = ? AND MESSAGE_ID = ? AND STATE='S'");
       map.put("LOAD_REFS_IN_SUCK",
               "SELECT MESSAGE_ID, DELIVERY_COUNT, SCHED_DELIVERY FROM JBM_MSG_REF WHERE STATE = 'S' AND CHANNEL_ID = ? ORDER BY ORD");