java parallel processing demultexed ordered queue of messages