Class KinesisStreamItem

    • Constructor Detail

      • KinesisStreamItem

        @DataBoundConstructor
        public KinesisStreamItem​(String streamName,
                                 String initialPositionInStream)
        Creates KinesisStreamItem instance.
        Parameters:
        streamName - the queue name.
    • Method Detail

      • getStreamName

        public String getStreamName()
        Get the stream name
        Returns:
        the stream name
      • setStreamName

        public void setStreamName​(String streamName)
        Set the stream name
        Parameters:
        streamName - stream name
      • getInitialPositionInStream

        public String getInitialPositionInStream()
        Get the initial position in the Kinesis stream Valid values are: LATEST or TRIM_HORIZON. Not all the positions have been implemented for the time being.
        Returns:
        the initial position in the Kinesis stream
        See Also:
        Kinesis Staring Positions
      • setInitialPositionInStream

        public void setInitialPositionInStream​(String initialPositionInStream)
        Set the initial position in the Kinesis stream
        Parameters:
        initialPositionInStream - initial position in the Kinesis stream