io.jenkins.plugins.aws.kinesisconsumer

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 and Description
static interface	KinesisConsumer.Factory

Method Summary

Modifier and Type	Method and Description
void	shutdown() Stop the scheduler threads to end consuming records from the Kinesis streams
void	start() Starts the scheduler threads to begin polling records from the Kinesis streams configured

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

start

public void start()

Starts the scheduler threads to begin polling records from the Kinesis streams configured

shutdown

public void shutdown()

Stop the scheduler threads to end consuming records from the Kinesis streams