activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Anuj Khandelwal (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (AMQ-5089) Inflight Count for topics is not correct
Date Fri, 07 Mar 2014 08:59:42 GMT

     [ https://issues.apache.org/jira/browse/AMQ-5089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Anuj Khandelwal updated AMQ-5089:
---------------------------------

    Description: 
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
acknowledgements for the messages it has received.
For topics once inflight count is increased, it is never going back down. 


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.



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 

  was:
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 


> 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 acknowledgements for the messages it has received.
> For topics once inflight count is increased, it is never going back down. 
> 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.
> 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)

Mime
View raw message