From dev-return-8179-apmail-activemq-dev-archive=activemq.apache.org@activemq.apache.org Thu Sep 20 20:19:47 2007 Return-Path: Delivered-To: apmail-activemq-dev-archive@www.apache.org Received: (qmail 17238 invoked from network); 20 Sep 2007 20:19:46 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 20 Sep 2007 20:19:46 -0000 Received: (qmail 44938 invoked by uid 500); 20 Sep 2007 20:19:37 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 44900 invoked by uid 500); 20 Sep 2007 20:19:37 -0000 Mailing-List: contact dev-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 dev@activemq.apache.org Received: (qmail 44891 invoked by uid 99); 20 Sep 2007 20:19:37 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 20 Sep 2007 13:19:37 -0700 X-ASF-Spam-Status: No, hits=-100.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO brutus.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 20 Sep 2007 20:21:45 +0000 Received: from brutus (localhost [127.0.0.1]) by brutus.apache.org (Postfix) with ESMTP id BD59B714168 for ; Thu, 20 Sep 2007 13:19:22 -0700 (PDT) Message-ID: <12219734.1190319562771.JavaMail.jira@brutus> Date: Thu, 20 Sep 2007 13:19:22 -0700 (PDT) From: "David Dossot (JIRA)" To: dev@activemq.apache.org Subject: [jira] Created: (AMQ-1430) Composite Queue causes duplicate keys in JDBC store MIME-Version: 1.0 Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: 7bit X-Virus-Checked: Checked by ClamAV on apache.org Composite Queue causes duplicate keys in JDBC store --------------------------------------------------- Key: AMQ-1430 URL: https://issues.apache.org/activemq/browse/AMQ-1430 Project: ActiveMQ Issue Type: Bug Components: Broker Environment: apache-activemq-5.0-20070920.154726-5, JVM 1.5.0_07, Mac OS X Reporter: David Dossot Fix For: 5.0.0 Using this CQ config: and this JDBC config: I create a subscriber to queue B and one to queue C. I start a publisher that sends 20 messages. The subscriber to queue B receives 20 messages ; the one on queue C receives 0. The server prints this error for each message: Sep 20, 2007 1:11:04 PM org.apache.activemq.util.TransactionTemplate run SEVERE: Having to Rollback - caught an exception: java.io.IOException: The statement was aborted because it would have caused a duplicate key value in a unique or primary key constraint or unique index identified by 'SQL070920011040920' defined on 'ACTIVEMQ_MSGS'. Sep 20, 2007 1:11:04 PM org.apache.activemq.store.journal.JournalPersistenceAdapter doCheckpoint SEVERE: Failed to checkpoint a message store: java.util.concurrent.ExecutionException: java.io.IOException: Not started. java.util.concurrent.ExecutionException: java.io.IOException: Not started. at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:205) at java.util.concurrent.FutureTask.get(FutureTask.java:80) at org.apache.activemq.store.journal.JournalPersistenceAdapter.doCheckpoint(JournalPersistenceAdapter.java:397) at org.apache.activemq.store.journal.JournalPersistenceAdapter$1.iterate(JournalPersistenceAdapter.java:118) at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:118) at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:42) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675) at java.lang.Thread.run(Thread.java:613) Caused by: java.io.IOException: Not started. at org.apache.activemq.store.jdbc.TransactionContext.rollback(TransactionContext.java:174) at org.apache.activemq.store.jdbc.JDBCPersistenceAdapter.rollbackTransaction(JDBCPersistenceAdapter.java:366) at org.apache.activemq.store.journal.JournalPersistenceAdapter.rollbackTransaction(JournalPersistenceAdapter.java:200) at org.apache.activemq.util.TransactionTemplate.run(TransactionTemplate.java:59) at org.apache.activemq.store.journal.JournalMessageStore.checkpoint(JournalMessageStore.java:257) at org.apache.activemq.store.journal.JournalMessageStore.checkpoint(JournalMessageStore.java:232) at org.apache.activemq.store.journal.JournalPersistenceAdapter$4.call(JournalPersistenceAdapter.java:367) at org.apache.activemq.store.journal.JournalPersistenceAdapter$4.call(JournalPersistenceAdapter.java:366) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:269) at java.util.concurrent.FutureTask.run(FutureTask.java:123) ... 3 more -- This message is automatically generated by JIRA. - You can reply to this email to add a comment to the issue online.