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 16663866D for ; Fri, 26 Aug 2011 08:28:15 +0000 (UTC) Received: (qmail 50386 invoked by uid 500); 26 Aug 2011 08:28:14 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 49889 invoked by uid 500); 26 Aug 2011 08:28:07 -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 49861 invoked by uid 99); 26 Aug 2011 08:28:04 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 26 Aug 2011 08:28:04 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=FREEMAIL_FROM,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of chubrilo@gmail.com designates 209.85.161.43 as permitted sender) Received: from [209.85.161.43] (HELO mail-fx0-f43.google.com) (209.85.161.43) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 26 Aug 2011 08:27:57 +0000 Received: by fxg17 with SMTP id 17so3001819fxg.2 for ; Fri, 26 Aug 2011 01:27:37 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; 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; bh=J/AKzUDMtuJGcr7rYmtayfn7FuuNf9OGIpx4vWaST3Y=; b=qUPba+1o7b7zuSTctHKPWyzs8jPRB8K7m/HpNSpmPIPdT2tWSbEyVS+TQxxj5Dw7dK pr50JPlOinOh8K2GI1MDKiEHXmFHFg/hijGQxpujTGGE+6BlLsy44CMtX8r7ITjYkdkA tlN0GVCYEISccYrCl7Gm/5sJkqJUDeYWuAg3o= MIME-Version: 1.0 Received: by 10.223.5.76 with SMTP id 12mr1219901fau.103.1314347257546; Fri, 26 Aug 2011 01:27:37 -0700 (PDT) Sender: chubrilo@gmail.com Received: by 10.223.78.196 with HTTP; Fri, 26 Aug 2011 01:27:37 -0700 (PDT) In-Reply-To: References: Date: Fri, 26 Aug 2011 10:27:37 +0200 X-Google-Sender-Auth: y1JIeEPTwncN5J3qZnj4CDTkxZA Message-ID: Subject: Re: amq 5.5.0 and pending queue sizes of durable topic subscribers From: Dejan Bosanac To: users@activemq.apache.org Content-Type: multipart/alternative; boundary=001517478d7e65c87b04ab6451d3 X-Virus-Checked: Checked by ClamAV on apache.org --001517478d7e65c87b04ab6451d3 Content-Type: text/plain; charset=ISO-8859-1 This has been fixed on trunk. You can test it against latest snapshot. Regards -- Dejan Bosanac - http://twitter.com/dejanb ----------------- The experts in open source integration and messaging - http://fusesource.com ActiveMQ in Action - http://www.manning.com/snyder/ Blog - http://www.nighttale.net On Fri, Aug 26, 2011 at 9:58 AM, Aleksandar Ivanisevic < aleksandar@ivanisevic.de> wrote: > > Here I am again with durable topic subscribers ;) > > Is it a bug or a feature that Pending Queue sizes in admin interface > are zero, even if there are messages pending? > > To test this, first I have subscribed to a topic and left using stomp: > > > telnet adminbroker 61613 > Trying 213.198.74.83... > Connected to adminbroker. > Escape character is '^]'. > CONNECT > client-id:test2 > login:system > passcode:manager > > ^@ > CONNECTED > session:test2 > > > SUBSCRIBE > activemq.prefetchSize:1 > activemq.subscriptionName:masterbcast > ack:client-individual > destination:/topic/COMMAND.test > id:masterbcast > > ^@ > > ^] > telnet> q > Connection closed. > > now i see an offline durable subscriber in the admin interface, so I > send a few messages like this > > > telnet adminbroker 61613 > Trying 213.198.74.83... > Connected to adminbroker. > Escape character is '^]'. > CONNECT > client-id:test2 > login:system > passcode:manager > > ^@ > CONNECTED > session:test2 > > > SEND > destination:/topic/COMMAND.test > persistent:true > > asdf > ^@ > SEND > destination:/topic/COMMAND.test > persistent:true > > asdf > ^@ > ^] > telnet> q > Connection closed. > > In the admin interface Pending Queue Count is still zero although the > messages are there and can be fetched > > > telnet adminbroker 61613 > Trying 213.198.74.83... > Connected to adminbroker. > Escape character is '^]'. > CONNECT > client-id:test2 > login:system > passcode:manager > > ^@ > CONNECTED > session:test2 > > > SUBSCRIBE > activemq.prefetchSize:1 > activemq.subscriptionName:masterbcast > ack:client-individual > destination:/topic/COMMAND.test > id:masterbcast > > ^@ > MESSAGE > message-id:ID:STATS2-38410-1314344446931-6:490:-1:1:1 > destination:/topic/COMMAND.test > timestamp:1314345053259 > expires:0 > subscription:masterbcast > priority:4 > > asdf > > ACK > message-id:ID:STATS2-38410-1314344446931-6:490:-1:1:1 > > ^@ > MESSAGE > message-id:ID:STATS2-38410-1314344446931-6:490:-1:1:2 > destination:/topic/COMMAND.test > timestamp:1314345067627 > expires:0 > subscription:masterbcast > priority:4 > > asdf > > ACK > message-id:ID:STATS2-38410-1314344446931-6:490:-1:1:2 > > ^@ > > > --001517478d7e65c87b04ab6451d3--