From users-return-31237-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org Sat Jul 7 08:11:23 2012 Return-Path: X-Original-To: apmail-activemq-users-archive@www.apache.org Delivered-To: apmail-activemq-users-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 3A2209F9A for ; Sat, 7 Jul 2012 08:11:23 +0000 (UTC) Received: (qmail 29174 invoked by uid 500); 7 Jul 2012 08:11:23 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 28704 invoked by uid 500); 7 Jul 2012 08:11:22 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 28678 invoked by uid 99); 7 Jul 2012 08:11:21 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 07 Jul 2012 08:11:21 +0000 X-ASF-Spam-Status: No, hits=-0.0 required=5.0 tests=RCVD_IN_DNSWL_NONE,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of michael.justin@gmx.net designates 213.165.64.22 as permitted sender) Received: from [213.165.64.22] (HELO mailout-de.gmx.net) (213.165.64.22) by apache.org (qpsmtpd/0.29) with SMTP; Sat, 07 Jul 2012 08:11:09 +0000 Received: (qmail invoked by alias); 07 Jul 2012 08:10:48 -0000 Received: from p50898CCD.dip0.t-ipconnect.de (EHLO [192.168.178.24]) [80.137.140.205] by mail.gmx.net (mp020) with SMTP; 07 Jul 2012 10:10:48 +0200 X-Authenticated: #924633 X-Provags-ID: V01U2FsdGVkX1/Cn1V5hwjC+5iqzoHOb+Y1F3dLfyCe/1kDujDg4s Q4KV9TJIOUO3V1 Message-ID: <4FF7EF05.6090902@gmx.net> Date: Sat, 07 Jul 2012 10:10:45 +0200 From: Michael Justin User-Agent: Mozilla/5.0 (Windows NT 6.0; rv:13.0) Gecko/20120614 Thunderbird/13.0.1 MIME-Version: 1.0 To: users@activemq.apache.org Subject: STOMP 1.1 NACK test and activemq.prefetchSize question Content-Type: text/plain; charset=UTF-8; format=flowed Content-Transfer-Encoding: 7bit X-Y-GMX-Trusted: 0 X-Virus-Checked: Checked by ClamAV on apache.org Hello, I am trying to set up a STOMP 1.1 NACK test for ActiveMQ 5.6.0 and Apollo 1.3. The tests first sends three messages to a queue. Then it subscribes the destination queue with a prefetch size of 3, like SUBSCRIBE destination:/queue/ExampleQueue ack:client-individual id:{A06FD6DB-6487-49DB-9396-258F5230306E} activemq.prefetchSize:3 and for two messages it sends ACK, for one message NACK. The connection then is closed and a new connection tries to receive the NACKed message. * I can see in the Admin web interface that all messages disappeared from "Pending Messages", and "Messages Enqueued" equals "Messages Dequeued". So I can not see any pending message while I would expect one, either in the same queue or in some dead letter queue * also there is a message count of 1 in the Topic ActiveMQ.Advisory.MessageDLQd.Queue.ExampleQueue (but can not read the messages with the STOMP client) Is activemq.prefetchSize the correct header to set the prefetch size on a subscribe frame if the ActiveMQ connection uses STOMP 1.1? Can this header also be used with Apache Apollo, or is there a different header? Many thanks in advance -- Michael Justin habarisoft - Enterprise Messaging Software for Delphi http://www.habarisoft.com/