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

Rob Davies reassigned AMQ-2009:
-------------------------------

    Assignee: Rob Davies

> Problem with message dispatch after a while
> -------------------------------------------
>
>                 Key: AMQ-2009
>                 URL: https://issues.apache.org/activemq/browse/AMQ-2009
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.1.0, 5.2.0
>            Reporter: Rajani Chennamaneni
>            Assignee: Rob Davies
>            Priority: Blocker
>         Attachments: consumertest.zip, DispatchMultipleConsumersTest.java, 
> JConsole-screenshot.jpg
>
>
> Messages are not getting dispatched after a while (although it accepts new 
> incoming messages) until restart of the broker. This problem is described in 
> several posts.
> http://www.nabble.com/Pending-Messages-are-shown-in-ActiveMQ-td20241332.html
> http://www.nabble.com/Consumer-Listener-stop-receving-message-until-ActiveMQ-restart-td20355247.html
> http://www.nabble.com/Stuck-messages---Dispatch-issues-td20467949.html
> There was also an issue opened in Spring project for this thinking it was 
> Spring problem.
> http://jira.springframework.org/browse/SPR-5110
> I am not able to reproduce with Junit test case having BrokerService started 
> with in the test case. I guess I am not hitting the right stress conditions 
> this way. But when I run the test case against an externally running ActiveMQ 
> instance backed with oracle database persistence, it is reproducible most of 
> the times. This is not a every time failure situation, it takes more time 
> once than the other.
> I was able to hit this situation of stuck messages on queue using following 
> scenario most of the times:
> 1) Start 2 concurrent consumers for the queue using Spring's 
> DefaultMessageListenerContainer using cacheLevelName as CACHE_CONSUMER
> 2) Send messages using JMETER 2.3.2 to the queue on ActiveMQ stand alone 
> broker instance with 50 threads looping 20 times.
> 3) After a while, you will notice that Spring logs that no messages are being 
> received but the messages are shown jconsole of ActiveMQ and the database 
> backing it for persistence.
> But in 5.2 RC3, the problem is that it dispatches duplicate messages and does 
> not remove them from broker's database after acknowledge properly.
> Attached test case might help to reproduce when run against externally 
> running stand alone ActiveMQ broker. Another way to see the problem is that 
> try to load test using JMETER by sending messages to a queue with a camel 
> route that moves messages from this queue to another and you will notice that 
> it stops moving after while or copied duplicates in case of 5.2 RC3.
> Sorry about such a huge description but it is a real problem! A different 
> team at our company are having this issue in production with 5.1. They are 
> using it as an embedded broker with derby for persistence.

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.

Reply via email to