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 75C6B10F2A for ; Tue, 18 Nov 2014 23:02:52 +0000 (UTC) Received: (qmail 15646 invoked by uid 500); 18 Nov 2014 23:02:52 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 15596 invoked by uid 500); 18 Nov 2014 23:02:52 -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 15584 invoked by uid 99); 18 Nov 2014 23:02:51 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 18 Nov 2014 23:02:51 +0000 X-ASF-Spam-Status: No, hits=4.0 required=5.0 tests=FREEMAIL_ENVFROM_END_DIGIT,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS,URI_HEX,URI_TRY_3LD X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of tbain98@gmail.com designates 209.85.192.42 as permitted sender) Received: from [209.85.192.42] (HELO mail-qg0-f42.google.com) (209.85.192.42) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 18 Nov 2014 23:02:25 +0000 Received: by mail-qg0-f42.google.com with SMTP id i50so18267021qgf.1 for ; Tue, 18 Nov 2014 15:02:24 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:sender:in-reply-to:references:from:date:message-id :subject:to:content-type; bh=ydgubLKdO7Vf6WGho7u5qSUDEawNWsM8r+mCVB4e2bk=; b=j/43ZoiuiBj8LIbqdaTBIXRr5FSCutguZiwvTY4z5nmxd3fvIMbjAGDLpqymWpJVqZ AyM6OwZv6y7V2InAIBQVk4soZb1X9RtZmwOPXeBR0tg4brBrW5jM3ikUIWv5jmmcFYLH iIjCAdBUr3IBxVNHmcDNCZ2J83ylj9MmNWZmqQCe9icrmSDR1FisW+7Tqyb6vZVCw4rN YMNvtdPqpSujUfL0eGX6gb/Ix95iXAeey5O60b8P+eZkuQT1MQuYzBS4TF3PpyXqmlrT gwLXU3M4W2TBOecrzdppbMoXqRfAkm2mp4LS3q8DfOLCVSTDYiM7V2dfsMXhh44igk7Y JQ3A== X-Received: by 10.224.29.196 with SMTP id r4mr47733936qac.12.1416351744524; Tue, 18 Nov 2014 15:02:24 -0800 (PST) MIME-Version: 1.0 Sender: tbain98@gmail.com Received: by 10.229.211.199 with HTTP; Tue, 18 Nov 2014 15:02:04 -0800 (PST) In-Reply-To: <1416344288970-4687673.post@n4.nabble.com> References: <1416250806575-4687564.post@n4.nabble.com> <1416344288970-4687673.post@n4.nabble.com> From: Tim Bain Date: Tue, 18 Nov 2014 16:02:04 -0700 X-Google-Sender-Auth: ktWgubE6d3YNRweNO0ys0illBqg Message-ID: Subject: Re: Message Selector or Composite Destinations To: ActiveMQ Users Content-Type: multipart/alternative; boundary=047d7bf0cb469c06ff05082a16cc X-Virus-Checked: Checked by ClamAV on apache.org --047d7bf0cb469c06ff05082a16cc Content-Type: text/plain; charset=UTF-8 It sounds like it could be a bug, though it might not be. Assuming you can reproduce this in a test environment, you should try attaching a debugger to the broker, setting breakpoints, and stepping through the relevant code. AbstractSubscription.matches() and Queue.doAcutalDispatch() seem like good places to start with your breakpoints, though I haven't stepped through this particular code before so I'm just guessing. Also, does this happen when there are only a few messages in the queue? Or does it only happen when there are lots of Version 2 messages mixed in with the Version 1 messages? And does it fix itself when the Version2 consumer comes back online, or are there still unprocessed messages when both consumers are online? I've got a vague memory that in earlier versions of ActiveMQ, there was a limit to how many messages could be in the cursor to be dispatched at any one time and that messages not in the cursor weren't considered for dispatching (so only the first N messages in the queue could be processed, and if all of them were Version 2 messages, they could block any Version 1 messages from being blocked until the Version 1 consumer came online and cleared some of them out). I may be misremembering, and if not there may have been changes in the behavior since those discussions, but if this is still how the broker works, then it could explain messages being blocked while the Version 2 consumer is offline but getting processed once all consumers are back online. On Tue, Nov 18, 2014 at 1:58 PM, juanmanuel.romeraferrio < juanmanuel.romeraferrio@gmail.com> wrote: > I'm using version 5.10.0 > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Message-Selector-or-Composite-Destinations-tp4687564p4687673.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > --047d7bf0cb469c06ff05082a16cc--