org.apache.storm.kinesis.spout

Interface FailedMessageRetryHandler

All Superinterfaces:

Serializable

All Known Implementing Classes:

ExponentialBackoffRetrier

public interface FailedMessageRetryHandler
extends Serializable

Method Summary

Modifier and Type	Method and Description
void	acked(KinesisMessageId messageId) message with messageId succeeded/acked in the spout.
boolean	failed(KinesisMessageId messageId) message with messageId failed in the spout.
void	failedMessageEmitted(KinesisMessageId messageId) message with messageId returned by last call to getNextFailedMessageToRetry was emitted/retried by the spout.
KinesisMessageId	getNextFailedMessageToRetry() Get the next failed message's id to retry if any, null otherwise.

Method Detail

failed

boolean failed(KinesisMessageId messageId)

message with messageId failed in the spout.

Parameters:

messageId - the message id

Returns:

true if this failed message was scheduled to be retried, false otherwise

acked

void acked(KinesisMessageId messageId)

message with messageId succeeded/acked in the spout.

Parameters:

messageId - the message id

getNextFailedMessageToRetry

KinesisMessageId getNextFailedMessageToRetry()

Get the next failed message's id to retry if any, null otherwise.

Returns:

messageId

failedMessageEmitted

void failedMessageEmitted(KinesisMessageId messageId)

message with messageId returned by last call to getNextFailedMessageToRetry was emitted/retried by the spout.

Parameters:

messageId - the message id