Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@activemq.apache.org
Date: Wed, 24 Aug 2011 07:59:29 +0000 (UTC)
From: "Ozan Seymen (JIRA)" <jira@apache.org>
To: dev@activemq.apache.org
Message-ID: 
 <389662301.8603.1314172769062.JavaMail.tomcat@hel.zones.apache.org>
Subject: [jira] [Created] (AMQ-3469) Number of Pending Messages in
 Transactional Send to Composite Destination via Network of Brokers
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit

Number of Pending Messages in Transactional Send to Composite Destination via Network of Brokers
------------------------------------------------------------------------------------------------

                 Key: AMQ-3469
                 URL: https://issues.apache.org/jira/browse/AMQ-3469
             Project: ActiveMQ
          Issue Type: Bug
          Components: Broker, JMX
    Affects Versions: 5.5.0
         Environment: Windows OS using NMS for C#
            Reporter: Ozan Seymen


Please see this arch diagram: http://activemq.2283324.n4.nabble.com/file/n3762364/ActiveMQ_-_Composite_Queues.png

There are two brokers: broker1 & broker2. Messages arriving at Q.Index.Transit.DC2 on broker1 is forwarded to broker2. Configuration files for both brokers are below.

Scenario:
1. Start both brokers in separate consoles
2. Send 3000 messages in AcknowledgementMode.Transactional to broker1 (Q.Index.Replication).
3. While messages are flowing kill (shutdown console) broker2 and then broker1.
4. Start broker1 and then broker2.
5. Repeat 3&4 while messages are still flowing.
6. When all messages are published from producer to broker1, observe message counts in broker1 Transit and broker2 Indexing queues. 

You will see that both admin console and JConsole reporting more messages than there actually are in Q.A.Indexing and Q.B.Indexing queues. 

Take a look at this screenshot: http://activemq.2283324.n4.nabble.com/file/n3762364/ActiveMQ_-_Admin_Console.png

All queues had 3003 messages (instead of 3000). When I consumed all messages in Q.A.Indexing with my consumer, it successfully consumed 3000 messages (as expected) but admin console still reports there are additional 3 messages pending in the queue. When I click on "Browse" to inspect the messages in admin console it reports that there are no messages. When I restart this broker, pending message count corrects itself and reports 0. 

This is a problem for the monitoring and operations: There is no way of knowing whether there are really 3 messages left and consumer is experiencing problems or consumer is alive but there are no messages to consume.

Here are the configuration files for both brokers:
Broker1 configuration: http://activemq.2283324.n4.nabble.com/file/n3762374/activemq_-_broker1.xml
Broker2 configuration: http://activemq.2283324.n4.nabble.com/file/n3762374/activemq_-_broker2.xml

--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira