public interface Subscriber extends Serializable
Modifier and Type | Method and Description |
---|---|
void |
apply(Data data,
Object... env)
Called when data from the corresponding producer has arrived
|
void apply(Data data, Object... env)
data
- Data received from the sensorenv
- Extra variables needed to process the message, set by Route.setEnvironment(int, Object...)