Uses of Class
org.apache.storm.kinesis.spout.KinesisMessageId

Packages that use KinesisMessageId

Package	Description
org.apache.storm.kinesis.spout

Uses of KinesisMessageId in org.apache.storm.kinesis.spout

Methods in org.apache.storm.kinesis.spout that return KinesisMessageId

Modifier and Type	Method and Description
KinesisMessageId	ExponentialBackoffRetrier.getNextFailedMessageToRetry()
KinesisMessageId	FailedMessageRetryHandler.getNextFailedMessageToRetry() Get the next failed message's id to retry if any, null otherwise.

Methods in org.apache.storm.kinesis.spout with parameters of type KinesisMessageId

Modifier and Type	Method and Description
void	ExponentialBackoffRetrier.acked(KinesisMessageId messageId)
void	FailedMessageRetryHandler.acked(KinesisMessageId messageId) message with messageId succeeded/acked in the spout.
boolean	ExponentialBackoffRetrier.failed(KinesisMessageId messageId)
boolean	FailedMessageRetryHandler.failed(KinesisMessageId messageId) message with messageId failed in the spout.
void	ExponentialBackoffRetrier.failedMessageEmitted(KinesisMessageId messageId)
void	FailedMessageRetryHandler.failedMessageEmitted(KinesisMessageId messageId) message with messageId returned by last call to getNextFailedMessageToRetry was emitted/retried by the spout.