All, I'll delete Spilling queue, and rewrite checkpoint/recovery implementation (checkpointing bundles is better than checkpointing all messages). Current implementation is quite mess :/ there are huge deserialization/serialization overheads..
-- Best Regards, Edward J. Yoon CEO at DataSayer Co., Ltd.
