Class KinesisConsumer
- java.lang.Object
-
- io.jenkins.plugins.aws.kinesisconsumer.KinesisConsumer
-
public class KinesisConsumer extends Object
Responsible to connect to the configured Kinesis streams and start the scheduler threads to begin polling records- Author:
- Fabio Ponciroli
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
KinesisConsumer.Factory
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
shutdown()
Stop the scheduler threads to end consuming records from the Kinesis streamsvoid
subscribe()
-