From fd65b8201a7729e4c20fb16fcc53a1cee74777f0 Mon Sep 17 00:00:00 2001 From: Bosanac Dejan Date: Thu, 1 Apr 2010 10:56:26 +0000 Subject: [PATCH] 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 --- .../org/apache/activemq/store/jdbc/Statements.java | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/store/jdbc/Statements.java b/activemq-core/src/main/java/org/apache/activemq/store/jdbc/Statements.java index 7581b0a14c..b39a540f7e 100755 --- a/activemq-core/src/main/java/org/apache/activemq/store/jdbc/Statements.java +++ b/activemq-core/src/main/java/org/apache/activemq/store/jdbc/Statements.java @@ -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;