Return-Path: Delivered-To: apmail-activemq-dev-archive@www.apache.org Received: (qmail 63406 invoked from network); 17 May 2010 08:37:12 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 17 May 2010 08:37:12 -0000 Received: (qmail 36814 invoked by uid 500); 17 May 2010 08:37:12 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 36657 invoked by uid 500); 17 May 2010 08:37:12 -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 36644 invoked by uid 99); 17 May 2010 08:37:11 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 17 May 2010 08:37:11 +0000 X-ASF-Spam-Status: No, hits=2.2 required=10.0 tests=FREEMAIL_FROM,HTML_MESSAGE,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of gary.tully@gmail.com designates 209.85.160.171 as permitted sender) Received: from [209.85.160.171] (HELO mail-gy0-f171.google.com) (209.85.160.171) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 17 May 2010 08:37:04 +0000 Received: by gyf3 with SMTP id 3so3992570gyf.2 for ; Mon, 17 May 2010 01:36:44 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:mime-version:received:received:in-reply-to :references:date:message-id:subject:from:to:content-type; bh=YVLFq1IXgkHC/2eYsN8piAwQQKfj+7ZC9AfuLUUaNac=; b=qusASgpWZpyo88Zy5LzozBzFk4EgLegqCfkwKhXlJDpmHFoZUoA1bRkilz11DD0pgF 9ECgMrSb1o9Xdr77aahquN07+g8cF6k/a9WKMDUfvf8RebcExFI+hxQX5Rs/dAVEHem5 u1/In+N5bHkMP6AxhPkdMMI+wk/L3JNLrRAhk= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; b=swiq0PHrptrOpIr2ejnDOvP+5XzUYEGnaSihuMfzZnWr8xpLq2ZbocgkEtJazrl+/D 8QcRdTKH8BvBe83a7PTsQPzzzdlrppByKLgLLBb5/7h45rJVtPu4sBiz7kF9h9I9Lolw scG0kcjbWbOyeg0AfEpV4Wq8GCcRfmZPaM1yQ= MIME-Version: 1.0 Received: by 10.150.247.3 with SMTP id u3mr5812869ybh.41.1274085403745; Mon, 17 May 2010 01:36:43 -0700 (PDT) Received: by 10.151.82.2 with HTTP; Mon, 17 May 2010 01:36:43 -0700 (PDT) In-Reply-To: References: Date: Mon, 17 May 2010 09:36:43 +0100 Message-ID: Subject: Re: Persistence Adapter question From: Gary Tully To: dev@activemq.apache.org Content-Type: multipart/alternative; boundary=000e0cd688c0e75f000486c61f62 X-Virus-Checked: Checked by ClamAV on apache.org --000e0cd688c0e75f000486c61f62 Content-Type: text/plain; charset=ISO-8859-1 Is the example camel route enabled in your configuration? It configures a route from example.A to example.B which would explain the creation of those two destinations. On 17 May 2010 00:28, Mark Greene wrote: > I'm writing a cassandra persistence adapter but have a question about the > behavior when it comes to recovering messages. > > The steps I'm taking are as follows: > > 1. Send message to myQueue1 > 2. Observe successful persistence of message to data store > 3. Confirm myQueue1 has 1 pending message in it > 4. Shutdown AMQ broker > 5. Start AMQ broker > > At this point, I see AMQ invoke the MessageStore.recoverNextMessages() > method which finds the message I orginally sent to myQueue1. However, I'm > seeing a request to remove the message but for the example.A queue. It then > looks like from the logs that example.B is created, and a message persisted > under that queue as well. > > Any hints as to why this is happening? > > Thanks in advance! > Best, > Mark Greene > -- http://blog.garytully.com Open Source Integration http://fusesource.com --000e0cd688c0e75f000486c61f62--