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;