Package org.graylog.integrations.aws.transports

Class KinesisShardProcessorFactory.KinesisShardProcessor

java.lang.Object
org.graylog.integrations.aws.transports.KinesisShardProcessorFactory.KinesisShardProcessor
All Implemented Interfaces:
software.amazon.kinesis.processor.ShardRecordProcessor
Enclosing class:
KinesisShardProcessorFactory
public class KinesisShardProcessorFactory.KinesisShardProcessor extends Object implements software.amazon.kinesis.processor.ShardRecordProcessor

  • Constructor Summary

    Constructors
    Constructor
    Description
    KinesisShardProcessor()
     

  • Method Summary

    Modifier and Type
    Method
    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)
     
    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

  • Constructor Details

    • KinesisShardProcessor

      public KinesisShardProcessor()

  • Method Details

    • 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)
      Specified by:
      processRecords in interface software.amazon.kinesis.processor.ShardRecordProcessor

    • 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