The synaps.cep.api_spout Module

class ApiSpout

Bases: synaps.cep.storm.Spout

SPOUT_NAME = 'APISpout'

ack(id)

fail(id)

initialize(conf, context)

nextTuple()

read_from_queue()