Anuj Khandelwal created AMQ-5089:
------------------------------------
Summary: Inflight Count for topics is not correct
Key: AMQ-5089
URL: https://issues.apache.org/jira/browse/AMQ-5089
Project: ActiveMQ
Issue Type: Bug
Components: Broker
Affects Versions: 5.8.0
Reporter: Anuj Khandelwal
Priority: Minor
Hi,
It is coming from:
http://activemq.2283324.n4.nabble.com/Inflight-Count-for-topics-not-correct-td4678407.html#a4678583
Problem: Inflight count is not going down for topics once consumer is
disconnected or sent acknowledged the message it has received.
Test Scenario:
When a producer and a consumer connected to the broker but consumer is little
bit slow, there will be inflight messages in the broker which are not yet
acknowledged.
Case 1 :Now after some time when consumer acknowledged the messages, than
inflight count should decrease, but that is not happening for topics.
Case 2 :Now If at this point of time, I stop consumer broker should make
inflight count to '0' because those messages are not inflight now. (for queue
these are now held messages and for topic those messages are dropped). But when
I check in Jconsole, I found that: for a queue it is working fine and going
down to 0 but for topics inflight count is not changing.
For topics: once inflight count is increased, it is never going back down. Why
so ?
Test Case: I tested with normal java consumer subscribing to a topic, I put
thread.sleep(5000) while receiving messages. Now consumer will take time to
acknowledge messages which are received. So that we can see inflight messages.
Now after 5 seconds, consumer has received the messages and also sent
acknowledgement to the broker but inflight count is not decreasing. Now if I
disconnects consumer inflight count should go down to '0', again here also it
is not changing for that topic.
Thanks,
Anuj
--
This message was sent by Atlassian JIRA
(v6.2#6252)
