[jboss-svn-commits] JBL Code SVN: r11601 - labs/jbossesb/trunk/product/core/services/src/org/jboss/internal/soa/esb/persistence/format/db.

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

Author: kurt.stam at jboss.com
Date: 2007-05-02 19:57:58 -0400 (Wed, 02 May 2007)
New Revision: 11601

Modified:
   labs/jbossesb/trunk/product/core/services/src/org/jboss/internal/soa/esb/persistence/format/db/DBMessageStoreImpl.java
Log:
JBESB-418 Fixing sql.

Modified: labs/jbossesb/trunk/product/core/services/src/org/jboss/internal/soa/esb/persistence/format/db/DBMessageStoreImpl.java
===================================================================
--- labs/jbossesb/trunk/product/core/services/src/org/jboss/internal/soa/esb/persistence/format/db/DBMessageStoreImpl.java	2007-05-02 23:50:25 UTC (rev 11600)
+++ labs/jbossesb/trunk/product/core/services/src/org/jboss/internal/soa/esb/persistence/format/db/DBMessageStoreImpl.java	2007-05-02 23:57:58 UTC (rev 11601)
@@ -221,7 +221,7 @@
 	 */
 	public Map<URI, Message> getUndeliveredMessages(String classification) throws MessageStoreException {
 		HashMap<URI, Message> messages = new HashMap<URI, Message>();
-		String sql = "select uuid from message where delivered='TRUE'";
+		String sql = "select uuid from message where delivered='FALSE'";
         if (classification!=null) {
             sql += " and classification='" + classification + "'";
         }
@@ -265,7 +265,7 @@
      */
     public Map<URI, Message> getDeliveredMessages(String classification) throws MessageStoreException {
         HashMap<URI, Message> messages = new HashMap<URI, Message>();
-        String sql = "select uuid from message where delivered!='FALSE'";
+        String sql = "select uuid from message where delivered='TRUE'";
         if (classification!=null) {
             sql += " and classification='" + classification + "'";
         }