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 9B31918E8F for ; Thu, 23 Apr 2015 12:51:18 +0000 (UTC) Received: (qmail 42934 invoked by uid 500); 23 Apr 2015 12:43:23 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 39173 invoked by uid 500); 23 Apr 2015 12:43:21 -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 35274 invoked by uid 99); 23 Apr 2015 12:35:52 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 23 Apr 2015 12:35:52 +0000 X-ASF-Spam-Status: No, hits=3.8 required=5.0 tests=FREEMAIL_ENVFROM_END_DIGIT,HTML_MESSAGE,SPF_PASS,URI_HEX,URI_TRY_3LD X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: message received from 54.164.171.186 which is an MX secondary for users@activemq.apache.org) Received: from [54.164.171.186] (HELO mx1-us-east.apache.org) (54.164.171.186) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 23 Apr 2015 12:35:46 +0000 Received: from mail-ie0-f171.google.com (mail-ie0-f171.google.com [209.85.223.171]) by mx1-us-east.apache.org (ASF Mail Server at mx1-us-east.apache.org) with ESMTPS id 103BF42AB6 for ; Thu, 23 Apr 2015 12:35:26 +0000 (UTC) Received: by iedfl3 with SMTP id fl3so66730210ied.1 for ; Thu, 23 Apr 2015 05:35:25 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:sender:in-reply-to:references:date:message-id:subject :from:to:content-type; bh=Hjc8ZYVOJQHYEav4TzcrdiqS1SThOACDJKXRFQcPsFQ=; b=OtqBZ+D6EqPXYFUw4xx27y8MOUJXrrsus+vGYF9fffrHsl6i2zteRHAAT1wKRj4Azd v7B69GgcwOo2c4oqRlbq3OClLRq0BO86Vl4qoJPjnsSxzSAaqq16L6tK30W7WR4Ju+LS ACgVNNvsUILguyn58yNxToDEHT21M77B3u7WLa83Q3+DCn+xaBReijOsIsUoLg1cIMKl s2hz/dztFshKI/NUv4gcEmzu3wT3/DdZuAQ/9IblCiHmHj+PXF9g4gy0IlsU+rEu3JJS iHfABtBhihnv4taVPVjBS9NIBxRE6sU0GOsvt8cWnPBuQVCYsQLjLzALwEnHbBtNFuZt bc1w== MIME-Version: 1.0 X-Received: by 10.50.64.244 with SMTP id r20mr11646621igs.48.1429792525726; Thu, 23 Apr 2015 05:35:25 -0700 (PDT) Sender: tbain98@gmail.com Received: by 10.50.131.233 with HTTP; Thu, 23 Apr 2015 05:35:25 -0700 (PDT) Received: by 10.50.131.233 with HTTP; Thu, 23 Apr 2015 05:35:25 -0700 (PDT) In-Reply-To: <1429283558015-4695147.post@n4.nabble.com> References: <1429283558015-4695147.post@n4.nabble.com> Date: Thu, 23 Apr 2015 06:35:25 -0600 X-Google-Sender-Auth: 79PWYpcYjz7caF12y06ockvscaQ Message-ID: Subject: Re: AMQ stops sending messages with 36 messages to go consistently on large volume of messages From: Tim Bain To: ActiveMQ Users Content-Type: multipart/alternative; boundary=047d7bea3d229938ab05146383d1 X-Virus-Checked: Checked by ClamAV on apache.org --047d7bea3d229938ab05146383d1 Content-Type: text/plain; charset=UTF-8 Is it always the same 36 messages that aren't consumed? Also, do your 60 consumers use any selectors? On Apr 17, 2015 9:26 AM, "mattmadhavan" wrote: > Hello, > I have been stuck in the problem for a while. I have large volumes of > request messages that are produced by a 'server' app. The requests are > nothing but start Oracle DB rownum and end rownum depending on the > 'request > page size' can be 500 or 1000. So a massage is an ImmutablePair<1, 499> or > ImmutablePair<1, 999> depending on the 'request page size'. > > If the 'request page size' is 500 I have 65182 request messages to be > consumed and if my 'request page size' is 1000 then I have 32592 'request' > messages to be consumed. > > It does not matter how many large volume of messages I have. The broker > stops sending messages with exactly 36 messages to go > (failover:(tcp://127.0.0.1:60000)?*jms.prefetchPolicy.all=1*) or the > consumers stop polling with 36 messages more to poll for > failover:(tcp://127.0.0.1:60000)?*jms.prefetchPolicy.all=0* > > I have been stuck on this issue for three weeks now. Any ideas please? > please refer to the attached screen shots. > > I appreciate in advance! > > Thanks > Matt'M queues-1.png > > > queues2.png > > > > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/AMQ-stops-sending-messages-with-36-messages-to-go-consistently-on-large-volume-of-messages-tp4695147.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > --047d7bea3d229938ab05146383d1--