public interface StreamerFailureListener
Modifier and Type | Method and Description |
---|---|
void |
onFailure(String stageName,
Collection<Object> evts,
Throwable err)
Callback invoked when unrecoverable failure is detected by streamer.
|
void onFailure(String stageName, Collection<Object> evts, Throwable err)
If StreamerConfiguration.isAtLeastOnce()
is set to false
, then this callback
will be invoked on node on which failure occurred. If StreamerConfiguration.isAtLeastOnce()
is set to true
, then this callback will be invoked on node on which
IgniteStreamer.addEvents(Collection)
or its variant was called. Callback will be called if maximum
number of failover attempts exceeded or failover cannot be performed (for example, if router
returned null
).
stageName
- Failed stage name.evts
- Failed set of events.err
- Error cause.
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC1 Release Date : February 16 2015