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 8D7BB104ED for ; Wed, 10 Jul 2013 09:28:25 +0000 (UTC) Received: (qmail 91387 invoked by uid 500); 10 Jul 2013 09:28:25 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 91066 invoked by uid 500); 10 Jul 2013 09:28:24 -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 91058 invoked by uid 99); 10 Jul 2013 09:28:23 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 10 Jul 2013 09:28:23 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of praveen.iiith@gmail.com designates 209.85.128.172 as permitted sender) Received: from [209.85.128.172] (HELO mail-ve0-f172.google.com) (209.85.128.172) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 10 Jul 2013 09:28:17 +0000 Received: by mail-ve0-f172.google.com with SMTP id jz10so5517431veb.31 for ; Wed, 10 Jul 2013 02:27:57 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:from:date:message-id:subject:to:content-type; bh=GUyTSewRzoxDQztH2V8jP8/0ZFtzDQCRCY5Ea5+Uobs=; b=pO+xPcNBL8GhN6Kdl0P1KNxg2Y3qcf9UdNnwD62W0xdZMbG/RlESSY3QCPPlCiVzuv LH6BnwV+utcsw15AmhvcLs0agZWwF54hK8Ga2nFuTTW1pZM8wCgXphQFw+uynHaVe5m2 mqmaQfahGv8JlOtXAvtjPPpWfudaBu3g4JqzdTdHzhOOydL3EuPgLn4xS6LQU2NY/vGA 08UMh1kzQtPn1GBj22YQTDTOnWG8/gcU5Am/vqcng7CvmSqjSnR0CGFtNUOYqY2BrDiH xpYDT5oLi6ors7TUpgYy3x09xf8CPvUFwqFRRPiJkp+RiE2te9pZPlOc3ZQbtTpi7fhU mMlA== X-Received: by 10.58.236.70 with SMTP id us6mr18524493vec.89.1373448476845; Wed, 10 Jul 2013 02:27:56 -0700 (PDT) MIME-Version: 1.0 Received: by 10.52.179.199 with HTTP; Wed, 10 Jul 2013 02:27:36 -0700 (PDT) From: Praveen Bysani Date: Wed, 10 Jul 2013 17:27:36 +0800 Message-ID: Subject: Variable volume of messages across consumers To: users@activemq.apache.org Content-Type: multipart/alternative; boundary=047d7bd6a90694b2b304e124e40d X-Virus-Checked: Checked by ClamAV on apache.org --047d7bd6a90694b2b304e124e40d Content-Type: text/plain; charset=ISO-8859-1 Hi, I have the following setup in my project, 1. multiple producers (p1,p2,p3) in Hongkong region sending variable size non-persistent messages to a topic t1 on the broker (b1) in Phillippines region 2. p1,p2 and p3 send messages frequently (~1 second) 3. each message has a time to live of 30 seconds 4. a tcp network bridge from b1 to a new broker b2 in HK region 5. consumers c1 in hongkong and c2 in europe subscribed to b2 through ssl and a consumer c3 subscribed to t1 on b1 through tcp I don't see the same amount of messages received across c1, c2 and c3. The number of messages received is in the following order c3 > c1 > c2. I use the default settings for prefetch values and *vmCursor *for *pendingSubscriberPolicy *and *strictOrderDisptachpolicy*. While i understand there could be delays in passing the message to these consumers as c3 could be slow consumer and c1 is fast, shouldn't the message eventually be received to all consumers of a topic. Why do i see different volumes of messages across different consumers ? Someone please help me understand what is going on !! Another strange thing is after a while, there are no messages received by c2 for a very long period. I suppose it is due to the prefetch size ? Since i am using a non persistent topic, the default value is quite high (according to activemq documentation), which again baffles me if that is really the reason. -- Regards, Praveen Bysani http://www.praveenbysani.com --047d7bd6a90694b2b304e124e40d--