org.thales.punch.libraries.storm.core.topology.light

Interface LightAcker

All Known Implementing Classes:

LightSpout

public interface LightAcker

Method Summary

Modifier and Type	Method and Description
void	ack(Object o) Ack a (spout) tuple.
void	fail(Object o) Fail a (spout) tuple.

Method Detail

ack

void ack(Object o)

Ack a (spout) tuple. This method is thread safe : the tuple is enqueued and effectively acked later on by the spout thread itself.

Parameters:

o - the associated object

fail

void fail(Object o)

Fail a (spout) tuple. This method is thread safe : the tuple is enqueued and effectively acked later on by the spout thread itself.

Parameters:

o - the associated object