public SpoutDeclarer setSpoutWithAck ( String id , IRichSpout spout , Number parallelismHint ) { return setSpout ( id , new AckTransactionSpout ( spout ) , parallelismHint ) ; }
Build spout to provide the compatibility with Storm s ack mechanism