Uses of Interface
org.apache.storm.kinesis.spout.FailedMessageRetryHandler

Packages that use FailedMessageRetryHandler

Package	Description
org.apache.storm.kinesis.spout

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

Classes in org.apache.storm.kinesis.spout that implement FailedMessageRetryHandler

Modifier and Type	Class and Description
class	ExponentialBackoffRetrier

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

Modifier and Type	Method and Description
FailedMessageRetryHandler	KinesisConfig.getFailedMessageRetryHandler()

Constructors in org.apache.storm.kinesis.spout with parameters of type FailedMessageRetryHandler

Constructor and Description
KinesisConfig(String streamName, com.amazonaws.services.kinesis.model.ShardIteratorType shardIteratorType, RecordToTupleMapper recordToTupleMapper, Date timestamp, FailedMessageRetryHandler failedMessageRetryHandler, ZkInfo zkInfo, KinesisConnectionInfo kinesisConnectionInfo, Long maxUncommittedRecords)