[jboss-dev-forums] [Design of Messaging on JBoss (Messaging/JBoss)] - Re: LargeMessage & Failover Update

[timfox]

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#4202670

Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4202670