Mailing-List: contact users-help@qpid.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@qpid.apache.org
Received-SPF: pass (nike.apache.org: domain of marnie.mccormack@googlemail.com
 designates 209.85.214.170 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=googlemail.com; s=gamma;
        h=mime-version:in-reply-to:references:date:message-id:subject:from:to
         :content-type;
        b=Gn8+tMew9A/epTw6TIhV0G2VZwrpoptzLrw8StCNiBz2O2oibFmBeG4UgrEwpHzSJu
         KmTeiN9QWO71C9SGXHiLEofZOxHAI5rzI1xnm9Nkzv9h1uG2lnKyJoEcSQtCn82T8t45
         wisnoGeoyYgoGuTc1ELtzGAPjpbANDCBrezyM=
MIME-Version: 1.0
In-Reply-To: <AANLkTikpnq_1MhKQofrtgdVZ3bFwOXAhFoQdwDDisiaH@mail.gmail.com>
References: <1284038446833-5514404.post@n2.nabble.com>
	<AANLkTikpnq_1MhKQofrtgdVZ3bFwOXAhFoQdwDDisiaH@mail.gmail.com>
Date: Fri, 10 Sep 2010 18:16:48 +0100
Message-ID: <AANLkTinsva2kJGW6unMxFnM9GWAj2wir5qir9w-eY2R5@mail.gmail.com>
Subject: Fwd: How can I make the message in queue auto deleted?
From: Marnie McCormack <marnie.mccormack@googlemail.com>
To: users@qpid.apache.org
Content-Type: multipart/alternative; boundary=0022152d679174f816048feae930

--0022152d679174f816048feae930
Content-Type: text/plain; charset=ISO-8859-1

 Hi,

Messages are only removed from the broker once they have been acknowledged
by the consuming client. This is standard JMS behaviour, as opposed to Qpid
specific logic.

This page tells you more about ack modes in Qpid:
https://cwiki.apache.org/qpid/qpid-design-message-acknowledgement.html

What acknowledgement mode are you using - how do you ack the messages once
consumed ?

Regards,
Marnie

  On Thu, Sep 9, 2010 at 2:20 PM, zhaoyi0113@gmail.com <zhaoyi0113@gmail.com
> wrote:

>
> I use Java client and Java-broker. Every time I start a subscriber, it will
> get the messages from the queue. It seems that the messages always exist in
> the queue. How can I make the message removed when it is published to a
> subscriber? I use the default exchange amq.direct and below is the JNDI
> properties:
>
> java.naming.factory.initial =
> org.apache.qpid.jndi.PropertiesFileInitialContextFactory
> connectionfactory.qpidConnectionfactory =
> amqp://guest:guest@clientid/test?brokerlist='tcp://localhost:5672'
> destination.directQueue =
> direct://amq.direct//message_queue?routingkey='routing_key'
>
>

--0022152d679174f816048feae930--