activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dej...@apache.org
Subject svn commit: r929918 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/Statements.java
Date Thu, 01 Apr 2010 10:56:26 GMT
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;



Mime
View raw message