From commits-return-13434-apmail-activemq-commits-archive=activemq.apache.org@activemq.apache.org Thu Apr 01 10:56:54 2010 Return-Path: Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: (qmail 1734 invoked from network); 1 Apr 2010 10:56:54 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 1 Apr 2010 10:56:54 -0000 Received: (qmail 14419 invoked by uid 500); 1 Apr 2010 10:56:54 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 14345 invoked by uid 500); 1 Apr 2010 10:56:51 -0000 Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list commits@activemq.apache.org Received: (qmail 14330 invoked by uid 99); 1 Apr 2010 10:56:50 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 01 Apr 2010 10:56:50 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 01 Apr 2010 10:56:47 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id 879C023888EC; Thu, 1 Apr 2010 10:56:26 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit 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 -0000 To: commits@activemq.apache.org From: dejanb@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20100401105626.879C023888EC@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org 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;