I have attached a patch for MessageGroupRouting (JBMESSAGING-375) in JIRA.
The patch contains the new Router, some tests, a temporary modification of
PagingFilteredQueue.java ( to enable the new Router), and some modifications to the
RoundRobinPointToPointRouter to extend it.
This should NOT be considered as a final patch, but it should be enough to demonstrate a
working solution I can improve and complete based on feedback.
There are two minor things left (which I'm currently aware of :) ).
1)A way to enable the router by configuration, so that the PagingFilteredQueue can create
a router based on this configuration.
Maybe a mbean attribute on the queue configuration
<consumer-routing-policy>message-group-routing</consumer-routing-policy> or
something ?
2) I should also try to make the algorithm more readable and avoid some code duplication.
I have done some testing to simulate different scenarios where receivers are closing and
client side buffers gets full. But there may be scenarios I have not thought about :).
Stian
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4054317#...
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&a...