The synaps.cep.check_spout Module

class CheckSpout

Bases: synaps.cep.storm.Spout

SPOUT_NAME = 'CheckSpout'

ack(id)

check_counter = 0

fail(id)

get_now()

initialize(conf, context)

lastchecked = 0

nextTuple()

warmup_period = 3