com.amazonaws.kinesisvideo.streaming

Class DefaultStreamCallbacks

java.lang.Object

com.amazonaws.kinesisvideo.streaming.DefaultStreamCallbacks

All Implemented Interfaces:

StreamCallbacks

public class DefaultStreamCallbacks
extends java.lang.Object
implements StreamCallbacks

Constructor Summary

Constructors

Constructor and Description
DefaultStreamCallbacks()

Method Summary

Modifier and Type	Method and Description
void	droppedFragmentReport(long fragmentTimecode) Reports a dropped fragment for the stream.
void	droppedFrameReport(long frameTimecode) Reports a dropped frame for the stream.
void	fragmentAckReceived(KinesisVideoFragmentAck fragmentAck) Reports the received ACK.
void	streamClosed(long uploadHandle) Stream has been closed.
void	streamConnectionStale(long lastAckDuration) Reports the stream staleness when the data is read and sent but no ACKs are received.
void	streamDataAvailable(long uploadHandle, long duration, long availableSize) New data is available for the stream.
void	streamErrorReport(long frameTimecode, long statusCode) Reports an error for the stream.
void	streamLatencyPressure(long duration) Reports the stream latency pressure.
void	streamReady() Ready to stream data.
void	streamUnderflowReport() Reports the stream underflow.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultStreamCallbacks

public DefaultStreamCallbacks()

Method Detail

streamUnderflowReport

public void streamUnderflowReport()
                           throws ProducerException

Description copied from interface: StreamCallbacks

Reports the stream underflow.

Specified by:

streamUnderflowReport in interface StreamCallbacks

Throws:

ProducerException

streamLatencyPressure

public void streamLatencyPressure(long duration)
                           throws ProducerException

Description copied from interface: StreamCallbacks

Reports the stream latency pressure.

Specified by:

streamLatencyPressure in interface StreamCallbacks

Parameters:

duration - The buffer duration in 100ns.

Throws:

ProducerException

streamConnectionStale

public void streamConnectionStale(long lastAckDuration)
                           throws ProducerException

Description copied from interface: StreamCallbacks

Reports the stream staleness when the data is read and sent but no ACKs are received.

Specified by:

streamConnectionStale in interface StreamCallbacks

Parameters:

lastAckDuration - The duration of time window when the last "buffering" ACK is received in 100ns.

Throws:

ProducerException

fragmentAckReceived

public void fragmentAckReceived(KinesisVideoFragmentAck fragmentAck)
                         throws ProducerException

Description copied from interface: StreamCallbacks

Reports the received ACK.

Specified by:

fragmentAckReceived in interface StreamCallbacks

Parameters:

fragmentAck - The received fragment ACK.

Throws:

ProducerException

droppedFrameReport

public void droppedFrameReport(long frameTimecode)
                        throws ProducerException

Description copied from interface: StreamCallbacks

Reports a dropped frame for the stream.

Specified by:

droppedFrameReport in interface StreamCallbacks

Parameters:

frameTimecode - Frame time code of the dropped frame.

Throws:

ProducerException

streamErrorReport

public void streamErrorReport(long frameTimecode,
                              long statusCode)
                       throws ProducerException

Description copied from interface: StreamCallbacks

Reports an error for the stream. The client should terminate the connection as the inlet host would have/has already terminated the connection.

Specified by:

streamErrorReport in interface StreamCallbacks

Parameters:

frameTimecode - Fragment time code of the errored fragment.

statusCode - Status code of the failure.

Throws:

ProducerException

droppedFragmentReport

public void droppedFragmentReport(long fragmentTimecode)
                           throws ProducerException

Description copied from interface: StreamCallbacks

Reports a dropped fragment for the stream.

Specified by:

droppedFragmentReport in interface StreamCallbacks

Parameters:

fragmentTimecode - Fragment time code of the dropped fragment.

Throws:

ProducerException

streamDataAvailable

public void streamDataAvailable(long uploadHandle,
                                long duration,
                                long availableSize)
                         throws ProducerException

Description copied from interface: StreamCallbacks

New data is available for the stream.

Specified by:

streamDataAvailable in interface StreamCallbacks

Parameters:

uploadHandle - The client stream upload handle.

duration - The duration of content available in the stream.

availableSize - The size of the content available in the stream.

Throws:

ProducerException

streamReady

public void streamReady()
                 throws ProducerException

Description copied from interface: StreamCallbacks

Ready to stream data.

Specified by:

streamReady in interface StreamCallbacks

Throws:

ProducerException

streamClosed

public void streamClosed(long uploadHandle)
                  throws ProducerException

Description copied from interface: StreamCallbacks

Stream has been closed.

Specified by:

streamClosed in interface StreamCallbacks

Parameters:

uploadHandle - The client stream upload handle.

Throws:

ProducerException