Should be very simple:
When large messages and continuations arrive:
largeMessage.addBytes(continuation);
myConcurrentQueue.add(largeMessage);
replicate(largeMessage);
Then as replications come back:
largeMessage = myConcurrentQueue.poll();
if (last)
{
processLocally();
}
etc
Should just be a few extra lines of code.
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4202670#...
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&a...