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, [email protected] <[email protected] > 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:gu...@clientid/test?brokerlist='tcp://localhost:5672' > destination.directQueue = > direct://amq.direct//message_queue?routingkey='routing_key' > >
