Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id AEE1E200CCC for ; Fri, 21 Jul 2017 15:42:35 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id AD93516D309; Fri, 21 Jul 2017 13:42:35 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id F314216D306 for ; Fri, 21 Jul 2017 15:42:34 +0200 (CEST) Received: (qmail 24972 invoked by uid 500); 21 Jul 2017 13:42:29 -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 24960 invoked by uid 99); 21 Jul 2017 13:42:28 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 21 Jul 2017 13:42:28 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id 6104418062C for ; Fri, 21 Jul 2017 13:42:28 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 4.044 X-Spam-Level: **** X-Spam-Status: No, score=4.044 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, FREEMAIL_ENVFROM_END_DIGIT=0.25, HEADER_FROM_DIFFERENT_DOMAINS=0.001, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RCVD_IN_SORBS_SPAM=0.5, SPF_PASS=-0.001, URI_HEX=1.313, URI_TRY_3LD=0.001] autolearn=disabled Authentication-Results: spamd3-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id GZ3zmSTxzWI3 for ; Fri, 21 Jul 2017 13:42:26 +0000 (UTC) Received: from mail-ua0-f180.google.com (mail-ua0-f180.google.com [209.85.217.180]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 93F805F3BF for ; Fri, 21 Jul 2017 13:42:26 +0000 (UTC) Received: by mail-ua0-f180.google.com with SMTP id q25so26933790uah.1 for ; Fri, 21 Jul 2017 06:42:26 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:sender:in-reply-to:references:from:date:message-id :subject:to; bh=UlKdbEgrW6OjPzLvW/rOuXtxEEcgR/1WsPps+lN/iDI=; b=bo++Gbn0VJsh2aaWLleprtnlXQVGMRWSvdvPxVGDeMNHJiHrfO/Xk0xjP/B1HDVy5i 26nZvPbuYkX0u5gcQ9f5SRMVwoeLOdK0AU7QDitg2NEe24l4Sah9gOWeGnWHYdVwbRCt 7dIHNecWNT2/n7sc3qEC3F2OIeRYb5uMRUzh7dbFMEyid/fd0KoS3hSxJH+KMhtp4FKV ZFoS9wJZpJgG9zhJ2VtIUkLBBG90IhAQKpCHGQlxgAR63BYW4yd3Rnsxorl2THInmb5f iJY8d2uXcRLYvMMPcyDh87fWd/oNThKjO3zv01C53TGkrU0LkV/9D9hL3l0iiRzEBTW+ 8UCg== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:sender:in-reply-to:references:from :date:message-id:subject:to; bh=UlKdbEgrW6OjPzLvW/rOuXtxEEcgR/1WsPps+lN/iDI=; b=NJbE9Q+1KSAL1d9kbtppvkDHh+hu5B3mAvnwgjJ2FuAiQiGSh2MlOvW+L3diumIm/o ubwGJiYUjMColQ9/pc3QiCVPcYWaRiw9E31OawTK9msWl7rNnzhYbzgkKNMCWIoD+zPv Z1nKsRQlv3B5ohGfK2TxYQByvrnKfHo0l7uIa1Z9f1hT4AqepkYPf2jKaXddjh885CaI wcrqX8R9Pv2YhYbvqqgY3FHayc4TvTSA57GTkImU5ARD7zZ+eIp/QqoxpzJwVFfMRUWu Iy5ODWar8vtER0XIIp7hEd0yOVRUWt8Y1cvvACaN9MwUgFgUi+roWrpTZjl0legwK/3D NTVA== X-Gm-Message-State: AIVw1124hIVRrrWCQLJIcBoL+KFG+m0CHo63aKGVxcsbHg0SsUch7xAa 1b4z0phSobunlPypNjMdO9lducjGeQ== X-Received: by 10.159.34.85 with SMTP id 79mr4516529uad.86.1500644545912; Fri, 21 Jul 2017 06:42:25 -0700 (PDT) MIME-Version: 1.0 Sender: tbain98@gmail.com Received: by 10.103.77.3 with HTTP; Fri, 21 Jul 2017 06:42:05 -0700 (PDT) In-Reply-To: <1500628245241-4728760.post@n4.nabble.com> References: <1500552218131-4728731.post@n4.nabble.com> <1500628245241-4728760.post@n4.nabble.com> From: Tim Bain Date: Fri, 21 Jul 2017 07:42:05 -0600 X-Google-Sender-Auth: Ktfot9Sq4sBezd1WydkBEYUKG-k Message-ID: Subject: Re: Messages are not discarded from queue when they're expired. To: ActiveMQ Users Content-Type: multipart/alternative; boundary="001a1135418017e8320554d409ed" archived-at: Fri, 21 Jul 2017 13:42:35 -0000 --001a1135418017e8320554d409ed Content-Type: text/plain; charset="UTF-8" When you say the messages "are indeed purged," do you mean to say (in more words, to make sure we're clear) "When I reconnect my consumer that has been offline for longer than the TTL I set, all messages older than the TTL are expired (as confirmed by an increase in the ExpiredCount JMX attribute on the queue in question or by some similar mechanism)"? For your second test scenario (10000 messages, consumer connected all the time), what about your test procedure causes them to be clearly pending for more than half a second? Are you saying you're publishing messages far faster than your consumer can process them and therefore there's a large backlog? How are you determining that message expiration isn't happening? With this scenario, message expiration could be taking place on either the broker or the consumer, so to get a count of expired messages you have to sum together the count from JMX for the broker plus the number of expired messages listed in the consumer logs (which is only written every 1000 expired messages, if I remember correctly). But I would expect that 1/2 second after your last message is produced, your consumer would receive no further messages to process. One other question: are the clocks synchronized on whatever machines are running your producers, consumers, and brokers? If not, that could explain the behavior you're seeing. Tim On Fri, Jul 21, 2017 at 3:10 AM, jbar wrote: > Thank you for your response. > > The messages are indeed purged when I reconnect my customer, however I > observed the same behaviour testing one that doesn't set any TTL. When > trying the mechanism "in action" with 10 000 messages and their TTL = 500 > ms > (and consumer connected all the time), all of them get dequeued and > delivered to the consumer, despite clearly being pending for more than only > 0,5 s. > Am I missing something? Maybe there're some files other than activemq.xml > that I should take a look at? > > > > -- > View this message in context: http://activemq.2283324.n4. > nabble.com/ActiveMQ-Messages-are-not-discarded-from-queue- > when-they-re-expired-tp4728731p4728760.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > --001a1135418017e8320554d409ed--