org.gridgain.grid.streamer

Interface GridStreamerFailureListener

public interface GridStreamerFailureListener

Streamer failure listener. Asynchronous callback passed to user in case of any failure determined by streamer.

See Also:

GridStreamer.addStreamerFailureListener(GridStreamerFailureListener)

Method Summary

Methods

Modifier and Type	Method and Description
void	onFailure(String stageName, Collection<Object> evts, Throwable err) Callback invoked when unrecoverable failure is detected by streamer.

Method Detail

onFailure

void onFailure(String stageName,
             Collection<Object> evts,
             Throwable err)

Callback invoked when unrecoverable failure is detected by streamer.

If GridStreamerConfiguration.isAtLeastOnce() is set to false, then this callback will be invoked on node on which failure occurred. If GridStreamerConfiguration.isAtLeastOnce() is set to true, then this callback will be invoked on node on which GridStreamer.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).

Parameters:

stageName - Failed stage name.

evts - Failed set of events.

err - Error cause.