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 -

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 -

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 -