public BoltDeclarer setBoltWithAck ( String id , IRichBolt bolt , Number parallelismHint ) { return setBolt ( id , new AckTransactionBolt ( bolt ) , parallelismHint ) ; }
Build bolt to provide the compatibility with Storm s ack mechanism