Return-Path: X-Original-To: apmail-activemq-users-archive@www.apache.org Delivered-To: apmail-activemq-users-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id E32EC9AFB for ; Fri, 15 Jun 2012 22:23:21 +0000 (UTC) Received: (qmail 49026 invoked by uid 500); 15 Jun 2012 22:23:21 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 48967 invoked by uid 500); 15 Jun 2012 22:23:21 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 48959 invoked by uid 99); 15 Jun 2012 22:23:21 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 15 Jun 2012 22:23:21 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of ichikoo@gmail.com designates 209.85.210.43 as permitted sender) Received: from [209.85.210.43] (HELO mail-pz0-f43.google.com) (209.85.210.43) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 15 Jun 2012 22:23:13 +0000 Received: by dajz8 with SMTP id z8so4674017daj.2 for ; Fri, 15 Jun 2012 15:22:51 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:date:message-id:subject:from:to:content-type; bh=hVuo8c6okmjaCKYRYSpVF3q/+iIDoeK66NxnpiAZGAE=; b=c0f3sH+XxItqLX2d6Nz1WcyA9tmPO2U2JnID8XQlPSWukgip9iBZ0RWm9p88RV2Rzn JSWsfLRP6E9IYpLMgjQzQEQ/VApntWN7Y8b4n2yVAeDFR8nQFIsdyQAMpn9/N6qPzGKC ogQHexr/2AukfqF/iyXMZ9zzfe06sdqkCQaCnRTiXv2/qaoEe9cdFwqYPPYx4xhB2yn+ FnPHc0ubF2cIdOEwpjxN6S6FTJ53I9EcGXEiYVxKXW1PG4RBcbC4Q6Z1Nyw4EzBWZjpZ P8NWM8w13cc4dyuQU/nwmi6PA5DwSG0SxmHUhRWvfzio6Woz2UC88mw4Xct1rTo2SnX4 e9tw== MIME-Version: 1.0 Received: by 10.68.231.8 with SMTP id tc8mr24326802pbc.140.1339798971825; Fri, 15 Jun 2012 15:22:51 -0700 (PDT) Received: by 10.142.165.13 with HTTP; Fri, 15 Jun 2012 15:22:51 -0700 (PDT) Date: Fri, 15 Jun 2012 15:22:51 -0700 Message-ID: Subject: Weird cast From: Koichi Tsunoda To: users@activemq.apache.org Content-Type: multipart/alternative; boundary=047d7b33d8dcc93ebc04c28a4196 --047d7b33d8dcc93ebc04c28a4196 Content-Type: text/plain; charset=ISO-8859-1 ActiveMQ 5.5.0 JDK 6 For some reason, I hit a problem that results in the below callstacks occasionally. The problem is worked around by restarting the broker. However, when this happens, I can see that the message count is going up from the Admin queue, but when I go to the queue, nothing actually shows up. I Googled for a bit but have not been able find anything like it yet. Thanks! Koichi ---------- 2012-06-14 05:11:32,949 | ERROR | QueueStorePrefetch631099980 - Failed to fill batch | org.apache.activemq.broker.region.cursors.AbstractStoreCursor | Queue:XXX java.lang.ClassCastException: org.apache.activemq.store.kahadb.data.KahaTraceCommand cannot be cast to org.apache.activemq.store.kahadb.data.KahaAddMessageCommand at org.apache.activemq.store.kahadb.KahaDBStore.loadMessage(KahaDBStore.java:955) at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore$5.execute(KahaDBStore.java:493) at org.apache.kahadb.page.Transaction.execute(Transaction.java:728) at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore.recoverNextMessages(KahaDBStore.java:485) at org.apache.activemq.store.ProxyMessageStore.recoverNextMessages(ProxyMessageStore.java:88) at org.apache.activemq.broker.region.cursors.QueueStorePrefetch.doFillBatch(QueueStorePrefetch.java:97) at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:260) at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.hasNext(AbstractStoreCursor.java:145) at org.apache.activemq.broker.region.cursors.StoreQueueCursor.hasNext(StoreQueueCursor.java:131) at org.apache.activemq.broker.region.Queue.doPageInForDispatch(Queue.java:1713) at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:1932) at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1440) at org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:104) at org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:42) 2012-06-14 05:11:32,955 | ERROR | QueueStorePrefetch631099980 - Failed to fill batch | org.apache.activemq.broker.region.cursors.AbstractStoreCursor | Queue:XXX java.lang.RuntimeException: java.lang.ClassCastException: org.apache.activemq.store.kahadb.data.KahaTraceCommand cannot be cast to org.apache.activemq.store.kahadb.data.KahaAddMessageCommand at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:263) at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.hasNext(AbstractStoreCursor.java:145) at org.apache.activemq.broker.region.cursors.StoreQueueCursor.hasNext(StoreQueueCursor.java:131) at org.apache.activemq.broker.region.Queue.doPageInForDispatch(Queue.java:1713) at org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:1932) at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1440) at org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:104) at org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:42) Caused by: java.lang.ClassCastException: org.apache.activemq.store.kahadb.data.KahaTraceCommand cannot be cast to org.apache.activemq.store.kahadb.data.KahaAddMessageCommand at org.apache.activemq.store.kahadb.KahaDBStore.loadMessage(KahaDBStore.java:955) at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore$5.execute(KahaDBStore.java:493) at org.apache.kahadb.page.Transaction.execute(Transaction.java:728) at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore.recoverNextMessages(KahaDBStore.java:485) at org.apache.activemq.store.ProxyMessageStore.recoverNextMessages(ProxyMessageStore.java:88) at org.apache.activemq.broker.region.cursors.QueueStorePrefetch.doFillBatch(QueueStorePrefetch.java:97) at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:260) ... 7 more --047d7b33d8dcc93ebc04c28a4196--