in order to understand the problem, here is what happening when the example pass (i.e. server1/data contains bindings and logs from a previous run): - a consumer is created on server0 => server1 is notified the consumer is created - on server1, the queue has no local consumers but 5 message references => a redistributor is created However, there shouldn't be 5 messages references in the queue! They come from the previous run where a NPE occurs and there remains 5 messages in the queue. To sum up, the example will always fail the 1st time and this failure will make the example succeeds unless the server1/data is cleaned up. Now, the example will systematically fail. What I'm expecting is that a redistributor must be added to server1 when it is notified that *its own consumer is closed*, there should be 5 messages references in the queue (since they were not acked by the consumer) but there is none. I'm investigating why it is so. To prevent that, I'll make the example use non persistent messages so that they won't be any messages from a previous run. View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4234156#... Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&a...