nathanmarz/storm-kestrel — pull request #9 by acromusashi (2012-11-25 23:26:08+00:00)
Title: Add MultiPortDefine, Add Customize Point

Add Below Function
1. Use multi port config for source kestrel.(with KestrelThriftSpout(List hostnames, int port, String queueName) )
2.KestrelSourceId's toString method (useful for topology.debug)

Add Below Customize Point
1.blackListTimeMs configurable in child class.
2.messageTimeoutMillis configurable in child class.
3.Message restriction if need in child class(isRestricted() method)
4.Make custom message in child class(generateEmitItem method)
5.queueName configurable in child class.
(ex:kestrel queue numbering "queueName" + context.getThisTaskIndex() )