You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by de...@apache.org on 2010/04/01 12:56:26 UTC

svn commit: r929918 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/Statements.java

Author: dejanb
Date: Thu Apr  1 10:56:26 2010
New Revision: 929918

URL: http://svn.apache.org/viewvc?rev=929918&view=rev
Log:
https://issues.apache.org/activemq/browse/AMQ-2681 - findMessageByIdStatement

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/Statements.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/Statements.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/Statements.java?rev=929918&r1=929917&r2=929918&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/Statements.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/Statements.java Thu Apr  1 10:56:26 2010
@@ -141,10 +141,10 @@ public class Statements {
     }
 
     public String getFindMessageByIdStatement() {
-        if (findMessageStatement == null) {
-            findMessageStatement = "SELECT MSG FROM " + getFullMessageTableName() + " WHERE ID=?";
+        if (findMessageByIdStatement == null) {
+        	findMessageByIdStatement = "SELECT MSG FROM " + getFullMessageTableName() + " WHERE ID=?";
         }
-        return findMessageStatement;
+        return findMessageByIdStatement;
     }
     
     public String getFindAllMessagesStatement() {
@@ -571,6 +571,10 @@ public class Statements {
     public void setFindMessageStatement(String findMessageStatment) {
         this.findMessageStatement = findMessageStatment;
     }
+    
+    public void setFindMessageByIdStatement(String findMessageByIdStatement) {
+        this.findMessageByIdStatement = findMessageByIdStatement;
+    }
 
     public void setRemoveAllMessagesStatement(String removeAllMessagesStatment) {
         this.removeAllMessagesStatement = removeAllMessagesStatment;