Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (athena.apache.org: domain of chubrilo@gmail.com designates
 209.85.219.164 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:sender:in-reply-to:references:date
         :x-google-sender-auth:message-id:subject:from:to:content-type;
        b=PqK4UFZIbqDEwGmL2w8gQyqxJEW/Wh7YpFbi0hfDKGKvb4KyHsC9tYJFsZ2uYOBdNH
         HHztAaiQIhv5pkC+fLUfXj6v7MH73taCRkd8xf3HrBR5B727/DcHrseBKE87IwwH4OzA
         e6N/1qCyz7FGU8DyTym0b1rnAc/5SJriU0opw=
MIME-Version: 1.0
Sender: chubrilo@gmail.com
In-Reply-To: <23074533.post@talk.nabble.com>
References: <23074533.post@talk.nabble.com>
Date: Thu, 16 Apr 2009 11:47:30 +0200
Message-ID: <36e91d9d0904160247i78089318s163887c8dca954@mail.gmail.com>
Subject: Re: Stomp ack:auto clears all remaining messages in the queue
From: Dejan Bosanac <dejan@nighttale.net>
To: users@activemq.apache.org
Content-Type: multipart/alternative; boundary=0015174bdfd8dd63390467a8f315

--0015174bdfd8dd63390467a8f315
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: 7bit

Hi Michael,

can you consume other ten messages afterwards? can you try to disconnect
your current consumer, subscribe again and try to consume remaining
messages?


Cheers
--
Dejan Bosanac

Open Source Integration - http://fusesource.com/
ActiveMQ in Action - http://www.manning.com/snyder/
Blog - http://www.nighttale.net


On Thu, Apr 16, 2009 at 11:37 AM, mjustin <michael.justin@gmx.net> wrote:

>
> Hello,
>
> I compared the behaviour of the JMS client (using the ProducerTool and
> ConsumerTool) and the behaviour of the Stomp client in Java.
>
> In both tests I start with 20 messages which I send to the queue
> TOOL.DEFAULT:
>
>
> call java -cp .;activemq-all-5.3-SNAPSHOT.jar ProducerTool
> --MessageCount=20
>
> Then I verify that the queue contains 20 messages:
>
> start http://localhost:8161/admin/browse.jsp?JMSDestination=TOOL.DEFAULT
>
> First I run the test of the JMS Client, consuming 10 messages using
> AUTO_ACKNOWLEDGE:
>
> java -cp .;activemq-all-5.3-SNAPSHOT.jar ConsumerTool
> --AckMode=AUTO_ACKNOWLEDGE --MaxiumMessages=10 --verbose
>
> Then I verify that there are 10 messages remaining in the queue, with the
> 'Redelivered' fag set.
>
> Finally I read the remaining queue entries using the same command as
> before.
>
> Now I start again, sending 20 messages to the queue.
>
> With the Stomp Java client, I read ten messages:
>
>    public void testSubscribeWithAutoAck() throws Exception {
>
>        String frame = "CONNECT\n" + "login: system\n" + "passcode:
> manager\n\n" + Stomp.NULL;
>        stompConnection.sendFrame(frame);
>
>        frame = stompConnection.receiveFrame();
>        System.out.println(frame);
>
>        frame = "SUBSCRIBE\n" + "destination:/queue/TOOL.DEFAULT" + "\n" +
> "ack:auto\n\n" + Stomp.NULL;
>        stompConnection.sendFrame(frame);
>
>        for (int i=0; i < 10; i++) {
>          frame = stompConnection.receiveFrame();
>            System.out.println(frame);
>        }
>
>        frame = "DISCONNECT\n" + "\n\n" + Stomp.NULL;
>        stompConnection.sendFrame(frame);
>
>        System.out.println("Disconnect frame sent");
>    }
>
>
> Now I check the queue in the admin console: there should be ten remaining
> messages in the queue, but the queue is empty.
>
> All 20 messages have been sent to the client over the Stomp adapter (as I
> can see in the broker log), but the broker does not realize that the client
> has received only 10.
>
> So the difference between the JMS and the Stomp interface is that the JMS
> interface allows to fetch some messages using automatic acknowledge, while
> the Stomp client (using ack:auto) would require to read all remaining
> messages - if it stops receiving, all remaining messages are lost.
>
> I am not sure if this is 'as designed', however it seems to make automatic
> acknowledgement in the Stomp interface very fragile.
>
> Best Regards
> Michael Justin
> --
> View this message in context:
> http://www.nabble.com/Stomp-ack%3Aauto-clears-all-remaining-messages-in-the-queue-tp23074533p23074533.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>

--0015174bdfd8dd63390467a8f315--