All Classes (AWS Kinesis Consumer Plugin 1.0.5 API)

All Classes Interface Summary Class Summary
Class	Description
AWSKinesisStreamListener	Extension point to implement by external applications to listen to records coming from a Kinesis stream.
GlobalKinesisConfiguration	Class representing the Global Kinesis configuration
KinesisConsumer	Responsible to connect to the configured Kinesis streams and start the scheduler threads to begin polling records
KinesisConsumer.Factory
KinesisConsumerManager	Manager of stream connections
KinesisConsumerModule
KinesisRecordProcessor	Implements the `ShardRecordProcessor` interface to process data records fetched from Amazon Kinesis
KinesisRecordProcessor.Factory
KinesisRecordProcessorFactory	Factory to create `KinesisRecordProcessor` instances.
KinesisStreamItem	Class representing a Stream configuration
KinesisStreamItem.DescriptorImpl
SaveableListenerImpl	Extends `SaveableListener` to listen to `GlobalKinesisConfiguration` changes.