io.jenkins.plugins.aws.kinesisconsumer

Class KinesisRecordProcessor

java.lang.Object

io.jenkins.plugins.aws.kinesisconsumer.KinesisRecordProcessor

All Implemented Interfaces:

software.amazon.kinesis.processor.ShardRecordProcessor

public class KinesisRecordProcessor
extends Object
implements software.amazon.kinesis.processor.ShardRecordProcessor

Implements the ShardRecordProcessor interface to process data records fetched from Amazon Kinesis

Author:

Fabio Ponciroli

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	KinesisRecordProcessor.Factory

Field Summary

Fields

Modifier and Type	Field and Description
String	streamName

Method Summary

Modifier and Type	Method and Description
void	initialize(software.amazon.kinesis.lifecycle.events.InitializationInput initializationInput)
void	leaseLost(software.amazon.kinesis.lifecycle.events.LeaseLostInput leaseLostInput)
void	processRecords(software.amazon.kinesis.lifecycle.events.ProcessRecordsInput processRecordsInput) Forward each byte record of ProcessRecordsInput to the AWSKinesisStreamListener interface
void	shardEnded(software.amazon.kinesis.lifecycle.events.ShardEndedInput shardEndedInput)
void	shutdownRequested(software.amazon.kinesis.lifecycle.events.ShutdownRequestedInput shutdownRequestedInput)

Methods inherited from class java.lang.Object

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

Field Detail

streamName

public final String streamName

Method Detail

initialize

public void initialize(software.amazon.kinesis.lifecycle.events.InitializationInput initializationInput)

Specified by:

initialize in interface software.amazon.kinesis.processor.ShardRecordProcessor

processRecords

public void processRecords(software.amazon.kinesis.lifecycle.events.ProcessRecordsInput processRecordsInput)

Forward each byte record of ProcessRecordsInput to the AWSKinesisStreamListener interface

Specified by:

processRecords in interface software.amazon.kinesis.processor.ShardRecordProcessor

Parameters:

processRecordsInput - ProcessRecordsInput to process

leaseLost

public void leaseLost(software.amazon.kinesis.lifecycle.events.LeaseLostInput leaseLostInput)

Specified by:

leaseLost in interface software.amazon.kinesis.processor.ShardRecordProcessor

shardEnded

public void shardEnded(software.amazon.kinesis.lifecycle.events.ShardEndedInput shardEndedInput)

Specified by:

shardEnded in interface software.amazon.kinesis.processor.ShardRecordProcessor

shutdownRequested

public void shutdownRequested(software.amazon.kinesis.lifecycle.events.ShutdownRequestedInput shutdownRequestedInput)

Specified by:

shutdownRequested in interface software.amazon.kinesis.processor.ShardRecordProcessor