Effective October 27, 2012, online and email support for FuseSource products will move to Red Hat support channels. For more information, please see the JIRA Migration to Red Hat FAQ.
As of October 27th, please open all new issues in the Red Hat Customer Portal .
Issue Details (XML | Word | Printable)

Key: MB-377
Type: Bug Bug
Status: Resolved Resolved
Resolution: Fixed
Priority: Major Major
Assignee: Hiram Chirino
Reporter: Martin Murphy
Votes: 0
Watchers: 3
Operations

If you were logged in you would be able to see more operations.
FUSE Message Broker

Using small queue prefetch sizes cause all consumers to run as fast as the slowest consumer.

Created: 17/Jul/08 11:43 AM   Updated: 20/Aug/08 09:03 AM
Component/s: broker
Affects Version/s: 5.0.0.17-fuse, 5.1.0.0-fuse
Fix Version/s: 5.0.0.19-fuse

File Attachments: 1. Text File AMQ-1866.patch (8 kB)
2. Java Source File AMQ1866.java (8 kB)
3. Zip Archive ESB-343.zip (35 kB)

Environment: Servicemix 3.3.1.3 on Windows, probably on all platforms.

External Issue URL: https://issues.apache.org/activemq/browse/AMQ-1866


 Description  « Hide
If you have a JMS producer sending messages to multiple consumers and you have the cacheLevel set to 3 or higher, eventually all consumers will run as slow as the slowest consumer.
In the attached projects the SA sends messages to a MockOptimizer (JMS consumer) that has two threads. One sleeps for one second and the other sleeps for ten. Initially the thread sleeping for 1 second will consume most of the messages, but towards the end it will start to consume messages every ten seconds as well.

 All   Comments   Change History      Sort Order: Ascending order - Click to sort in descending order
Martin Murphy made changes - 17/Jul/08 11:49 AM
Field Original Value New Value
Attachment ESB-343.zip [ 11909 ]
Martin Murphy made changes - 17/Jul/08 11:50 AM
Link This issue fixes DEV-1026 [ DEV-1026 ]
Hiram Chirino made changes - 22/Jul/08 12:24 PM
Assignee Rob Davies [ rajdavies ] Hiram Chirino [ chirino ]
Hiram Chirino made changes - 22/Jul/08 12:24 PM
Status Open [ 1 ] In Progress [ 3 ]
Hiram Chirino made changes - 22/Jul/08 01:25 PM
Project FUSE ESB [ 10000 ] FUSE Message Broker [ 10001 ]
Key ESB-343 MB-377
Component/s broker [ 10000 ]
Component/s servicemix-jms [ 10013 ]
Affects Version/s 5.0.0.17-fuse [ 10223 ]
Affects Version/s 5.1.0.0-fuse [ 10190 ]
Affects Version/s  3.3.1.3-fuse [ 10221 ]
Hiram Chirino made changes - 22/Jul/08 01:29 PM
Summary JMS producer caching leads to all consumers running as fast as the slowest consumer. Using small queue prefetch sizes cause all consumers to run as fast as the slowest consumer.
Hiram Chirino made changes - 22/Jul/08 01:33 PM
Hiram Chirino made changes - 22/Jul/08 01:46 PM
Attachment AMQ1866.java [ 11927 ]
Hiram Chirino made changes - 07/Aug/08 11:12 AM
Attachment AMQ-1866.patch [ 12002 ]
Gary Tully made changes - 20/Aug/08 09:03 AM
Status In Progress [ 3 ] Resolved [ 5 ]
Fix Version/s 5.0.0.19-fuse [ 10260 ]
Resolution Fixed [ 1 ]