Sorry, would have included this in the last email but I was on my phone. The specific wrapper class I meant was backtype.storm.topology.BasicBoltExecutor. To see how the iBasicBolts get wrapped. have a look at backtype.storm.topology.TopologyBuilder.setBolt(String id, IBasicBolt bolt, Number parallelism_hint) (Line 170 in 0.9.1-incubating)
Ciao, -- Angelo Genovese On Thu, Mar 27, 2014 at 2:17 PM, Software Dev <[email protected]> wrote: > Ok, I havent come across that class. > > What creates that class? > > On Wed, Mar 26, 2014 at 10:21 PM, Angelo Genovese <[email protected]> wrote: >> BasicBolts are wrapped automatically with a basic bolt executor. It does the >> back/fail >> >> On Mar 26, 2014 9:40 PM, "Software Dev" <[email protected]> wrote: >>> >>> Sorry for the basic question but... >>> >>> Where does BaseBasicBolt auto ack? It looks like it uses >>> BasicOutputCollector which doesn't even have an ack or fail method >>> whereas OutputCollector does?
