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'
>
>
|