Class AWSKinesisStreamListener

  • All Implemented Interfaces:

    public abstract class AWSKinesisStreamListener
    extends Object
    implements ExtensionPoint
    Extension point to implement by external applications to listen to records coming from a Kinesis stream. The external application has to:
    Fabio Ponciroli
    • Constructor Detail

      • AWSKinesisStreamListener

        public AWSKinesisStreamListener()
    • Method Detail

      • onReceive

        public abstract void onReceive​(String streamName,
                                       byte[] byteRecord)
        This needs to be overridden to implement the logic upon record receive
        streamName - source AWS Kinesis stream name
        byteRecord - input byte record to process
      • fireOnReceive

        public static void fireOnReceive​(String streamName,
                                         byte[] byteRecord)