Ask Your Question

Revision history [back]

click to hide/show revision 1
initial version

So if found a solution. If you use the standard "addMessageListener" method for a subscriber than the internal queue size will be set to 1 (see for example DefaultSubscriber.java). Luckily you can set it yourself with the second "addMessageListener" method which offers a limit parameter. A simple int for the queue size.

So if i found a solution. If you use the standard "addMessageListener" method for a subscriber than the internal queue size will be set to 1 (see for example DefaultSubscriber.java). Luckily you can set it yourself with the second "addMessageListener" method which offers a limit parameter. A simple int for the queue size.