org.apache.storm.kinesis.spout

## Interface FailedMessageRetryHandler

- All Superinterfaces:
    Serializable
  All Known Implementing Classes:
    ExponentialBackoffRetrier

      public interface FailedMessageRetryHandler
      extends Serializable

- - ### Method Summary

    All Methods Instance Methods Abstract Methods
    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

Copyright © 2021 The Apache Software Foundation. All rights reserved.