require File.expand_path("storm", File.dirname(__FILE__)) | |
class TesterBolt < Storm::Bolt | |
def prepare(conf, context) | |
emit ['bolt initializing'] | |
end | |
def process(tuple) | |
word = tuple.values[0] | |
if (rand < 0.75) | |
emit [word + "lalala"], :anchor => tuple | |
ack tuple | |
else | |
log(word + ' randomly skipped!') | |
end | |
end | |
end | |
TesterBolt.new.run |