Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

https://issues.apache.org/activemq/browse/AMQ-2681 - findMessageByIdStatement 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@929918 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Bosanac Dejan 2010-04-01 10:56:26 +00:00
parent 9822d58d04
commit fd65b8201a
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
activemq-core/src/main/java/org/apache/activemq/store/jdbc/Statements.java
View File

@ -141,10 +141,10 @@ public class Statements {
} }
public String getFindMessageByIdStatement() { public String getFindMessageByIdStatement() {
if (findMessageStatement == null) { if (findMessageByIdStatement == null) {
findMessageStatement = "SELECT MSG FROM " + getFullMessageTableName() + " WHERE ID=?"; findMessageByIdStatement = "SELECT MSG FROM " + getFullMessageTableName() + " WHERE ID=?";
} }
return findMessageStatement; return findMessageByIdStatement;
} }
public String getFindAllMessagesStatement() { public String getFindAllMessagesStatement() {
@ -572,6 +572,10 @@ public class Statements {
this.findMessageStatement = findMessageStatment; this.findMessageStatement = findMessageStatment;
} }
public void setFindMessageByIdStatement(String findMessageByIdStatement) {
this.findMessageByIdStatement = findMessageByIdStatement;
}
public void setRemoveAllMessagesStatement(String removeAllMessagesStatment) { public void setRemoveAllMessagesStatement(String removeAllMessagesStatment) {
this.removeAllMessagesStatement = removeAllMessagesStatment; this.removeAllMessagesStatement = removeAllMessagesStatment;
} }