Uses of Class
com.amazonaws.kinesisvideo.producer.ProducerException

Packages that use ProducerException

Package	Description
com.amazonaws.kinesisvideo.internal.client
com.amazonaws.kinesisvideo.internal.producer
com.amazonaws.kinesisvideo.internal.producer.jni
com.amazonaws.kinesisvideo.internal.service
com.amazonaws.kinesisvideo.java.service
com.amazonaws.kinesisvideo.producer
com.amazonaws.kinesisvideo.streaming	Concrete implementations of StreamCallbacks.

Uses of ProducerException in com.amazonaws.kinesisvideo.internal.client

Methods in com.amazonaws.kinesisvideo.internal.client that throw ProducerException

Modifier and Type	Method	Description
KinesisVideoProducer	NativeKinesisVideoClient.initializeNewKinesisVideoProducer(DeviceInfo deviceInfo)	Initialize a new native KinesisVideoProducer.

Uses of ProducerException in com.amazonaws.kinesisvideo.internal.producer

Methods in com.amazonaws.kinesisvideo.internal.producer that throw ProducerException

Modifier and Type	Method	Description
void	PendingCreationKinesisVideoStream.bufferDurationOverflowPressure(long remainDuration)
void	KinesisVideoProducer.create(DeviceInfo deviceInfo)	Creates the underlying producer client.
void	ServiceCallbacks.createDevice(String deviceName, long callAfter, long timeout, byte[] authData, int authType, long customData)	Asynchronous call to create device
void	KinesisVideoProducer.createDeviceResult(long customData, String deviceArn, int httpStatusCode)	CreateDevice result event
KinesisVideoProducerStream	KinesisVideoProducer.createStream(StreamInfo streamInfo, StreamCallbacks streamCallbacks)	Creates Kinesis Video stream
void	ServiceCallbacks.createStream(String deviceName, String streamName, String contentType, String kmsKeyId, long retentionPeriod, long callAfter, long timeout, byte[] authData, int authType, KinesisVideoProducerStream stream)	Asynchronous call to create stream with the specified parameters.
void	KinesisVideoProducer.createStreamResult(KinesisVideoProducerStream stream, String streamArn, int httpStatusCode)	CreateStream result event
KinesisVideoProducerStream	KinesisVideoProducer.createStreamSync(StreamInfo streamInfo, StreamCallbacks streamCallbacks)	Creates Kinesis Video stream synchronously
void	KinesisVideoProducer.createSync(DeviceInfo deviceInfo)	Creates the underlying producer client synchronously.
void	ServiceCallbacks.describeStream(String streamName, long callAfter, long timeout, byte[] authData, int authType, long streamHandle, KinesisVideoProducerStream stream)	Asynchronous call to describe stream with the specified parameters.
void	KinesisVideoProducer.describeStreamResult(KinesisVideoProducerStream stream, long streamHandle, StreamDescription streamDescription, int httpStatusCode)	DescribeStream result event
void	ServiceCallbacks.deviceCertToToken(String deviceName, long callAfter, long timeout, byte[] authData, int authType, long customData)	Asynchronous call to device certificate to token API.
void	KinesisVideoProducer.deviceCertToTokenResult(long customData, byte[] token, long expiration, int httpStatusCode)	DeviceCertToToken result event
void	PendingCreationKinesisVideoStream.droppedFragmentReport(long fragmentTimecode)
void	PendingCreationKinesisVideoStream.droppedFrameReport(long frameTimecode)
void	KinesisVideoProducerStream.fragmentAck(long uploadHandle, KinesisVideoFragmentAck kinesisVideoFragmentAck)	Reports an ACK for a fragment.
void	PendingCreationKinesisVideoStream.fragmentAck(long uploadHandle, KinesisVideoFragmentAck kinesisVideoFragmentAck)
void	PendingCreationKinesisVideoStream.fragmentAckReceived(long uploadHandle, KinesisVideoFragmentAck fragmentAck)
void	KinesisVideoProducer.free()	Stops the streams and frees/releases the underlying object
void	KinesisVideoProducer.freeStream(KinesisVideoProducerStream stream)	Frees the specified stream
void	KinesisVideoProducer.freeStreams()	Frees all of the underlying streams
InputStream	KinesisVideoProducerStream.getDataStream(long uploadHandle)	Returns the input stream to retrieve the data from.
InputStream	PendingCreationKinesisVideoStream.getDataStream(long uploadHandle)
KinesisVideoMetrics	KinesisVideoProducer.getMetrics()
KinesisVideoStreamMetrics	KinesisVideoProducerStream.getMetrics()	Returns stream specific metrics.
KinesisVideoStreamMetrics	PendingCreationKinesisVideoStream.getMetrics()
void	KinesisVideoProducerStream.getStreamData(long uploadHandle, byte[] fillBuffer, int offset, int length, ReadResult readResult)	Get stream data from the buffer.
void	PendingCreationKinesisVideoStream.getStreamData(long uploadHandle, byte[] fillBuffer, int offset, int length, ReadResult readResult)
void	ServiceCallbacks.getStreamingEndpoint(String streamName, String apiName, long callAfter, long timeout, byte[] authData, int authType, long streamHandle, KinesisVideoProducerStream stream)	Asynchronous call to get streaming endpoint with the specified parameters.
void	KinesisVideoProducer.getStreamingEndpointResult(KinesisVideoProducerStream stream, long streamHandle, String endpoint, int httpStatusCode)	GetStreamingEndpoint result event
void	ServiceCallbacks.getStreamingToken(String streamName, long callAfter, long timeout, byte[] authData, int authType, long streamHandle, KinesisVideoProducerStream stream)	Asynchronous call to get streaming token
void	KinesisVideoProducer.getStreamingTokenResult(KinesisVideoProducerStream stream, long streamHandle, byte[] token, long expiration, int httpStatusCode)	GetStreamingToken result event
void	ServiceCallbacks.initialize(KinesisVideoProducer kinesisVideoProducer)	Initializes the callbacks object
void	KinesisVideoProducerStream.parseFragmentAck(long uploadHandle, String kinesisVideoFragmentAck)	Parses and processes a response which can contain partial/multiple fragment ACK.
void	PendingCreationKinesisVideoStream.parseFragmentAck(long uploadHandle, String kinesisVideoFragmentAck)
void	KinesisVideoProducerStream.putEventMetadata(int event, StreamEventMetadata streamEventMetadata)	Puts an event metadata into the stream.
void	PendingCreationKinesisVideoStream.putEventMetadata(int event, StreamEventMetadata streamEventMetadata)
void	KinesisVideoProducerStream.putFragmentMetadata(String metadataName, String metadataValue, boolean persistent)	Puts a fragment metadata into the stream.
void	PendingCreationKinesisVideoStream.putFragmentMetadata(String metadataName, String metadataValue, boolean persistent)
void	KinesisVideoProducerStream.putFrame(KinesisVideoFrame kinesisVideoFrame)	Puts a frame into the stream.
void	PendingCreationKinesisVideoStream.putFrame(KinesisVideoFrame kinesisVideoFrame)
void	ServiceCallbacks.putStream(String streamName, String containerType, long streamStartTime, boolean absoluteFragmentTimes, boolean ackRequired, String streamingEndpoint, long callAfter, long timeout, byte[] authData, int authType, KinesisVideoProducerStream stream)	Asynchronous call to put stream API
void	KinesisVideoProducer.putStreamResult(KinesisVideoProducerStream stream, long uploadHandle, int httpStatusCode)	PutStream result event
void	KinesisVideoProducerStream.resetConnection()	Reset current connection of producer stream
void	PendingCreationKinesisVideoStream.resetConnection()
void	KinesisVideoProducerStream.stopStream()	Stops the Kinesis Video stream.
void	PendingCreationKinesisVideoStream.stopStream()
void	KinesisVideoProducer.stopStreams()	Stops all the streams
void	KinesisVideoProducerStream.stopStreamSync()	Stops the Kinesis Video stream and awaits for the stream stopped notification in a sync call.
void	PendingCreationKinesisVideoStream.stopStreamSync()
void	PendingCreationKinesisVideoStream.streamClosed(long uploadHandle)
void	PendingCreationKinesisVideoStream.streamConnectionStale(long lastAckDuration)
void	PendingCreationKinesisVideoStream.streamDataAvailable(long uploadHandle, long duration, long availableSize)
void	PendingCreationKinesisVideoStream.streamErrorReport(long uploadHandle, long fragmentTimecode, long statusCode)
void	KinesisVideoProducerStream.streamFormatChanged(byte[] codecPrivateData, int trackId)	Indicates that the stream format has changed.
void	PendingCreationKinesisVideoStream.streamFormatChanged(byte[] codecPrivateData, int trackId)
void	KinesisVideoProducerStream.streamFreed()	Free the Kinesis Video stream.
void	PendingCreationKinesisVideoStream.streamFreed()
void	PendingCreationKinesisVideoStream.streamLatencyPressure(long duration)
void	PendingCreationKinesisVideoStream.streamReady()
void	KinesisVideoProducerStream.streamTerminated(long uploadHandle, int statusCode)	Reports an abnormal stream termination
void	PendingCreationKinesisVideoStream.streamTerminated(long uploadHandle, int statusCode)
void	PendingCreationKinesisVideoStream.streamUnderflowReport()
void	ServiceCallbacks.tagResource(String resourceArn, Tag[] tags, long callAfter, long timeout, byte[] authData, int authType, long streamHandle, KinesisVideoProducerStream stream)	Asynchronous call to tag resource API
void	KinesisVideoProducer.tagResourceResult(KinesisVideoProducerStream stream, long streamHandle, int httpStatusCode)	TagResource result event

Uses of ProducerException in com.amazonaws.kinesisvideo.internal.producer.jni

Methods in com.amazonaws.kinesisvideo.internal.producer.jni that throw ProducerException

Modifier and Type	Method	Description
void	NativeKinesisVideoProducerStream.awaitReady()	Deprecated.
void	NativeKinesisVideoProducerStream.awaitReady(Set<Long> readyStreamHandles)
void	NativeKinesisVideoProducerStream.awaitStopped()
void	NativeKinesisVideoProducerStream.bufferDurationOverflowPressure(long remainDuration)
void	NativeKinesisVideoProducerJni.create(DeviceInfo deviceInfo)	Creates the underlying Kinesis Video client object
void	NativeKinesisVideoProducerJni.create(DeviceInfo deviceInfo, String nativeLibraryPath)	Creates the underlying Kinesis Video client object.
void	NativeKinesisVideoProducerJni.createDeviceResult(long customData, String deviceArn, int httpStatusCode)
KinesisVideoProducerStream	NativeKinesisVideoProducerJni.createStream(StreamInfo streamInfo, StreamCallbacks streamCallbacks)	Creates a Kinesis Video stream
void	NativeKinesisVideoProducerJni.createStreamResult(KinesisVideoProducerStream stream, String streamArn, int httpStatusCode)
KinesisVideoProducerStream	NativeKinesisVideoProducerJni.createStreamSync(StreamInfo streamInfo, StreamCallbacks streamCallbacks)	Creates an Kinesis Video stream synchronously
void	NativeKinesisVideoProducerJni.createSync(DeviceInfo deviceInfo)	Creates the underlying Kinesis Video client object synchronously
void	NativeKinesisVideoProducerJni.createSync(DeviceInfo deviceInfo, String nativeLibraryPath)	Creates the underlying Kinesis Video client object synchronously.
void	NativeKinesisVideoProducerJni.describeStreamResult(KinesisVideoProducerStream stream, long streamHandle, StreamDescription streamDescription, int httpStatusCode)
void	NativeKinesisVideoProducerJni.deviceCertToTokenResult(long customData, byte[] token, long expiration, int httpStatusCode)
void	NativeKinesisVideoProducerStream.droppedFragmentReport(long fragmentTimecode)
void	NativeKinesisVideoProducerStream.droppedFrameReport(long frameTimecode)
void	NativeKinesisVideoProducerJni.fragmentAck(long streamHandle, long uploadHandle, KinesisVideoFragmentAck kinesisVideoFragmentAck)	Report an ACK for a fragment
void	NativeKinesisVideoProducerStream.fragmentAck(long uploadHandle, KinesisVideoFragmentAck kinesisVideoFragmentAck)
void	NativeKinesisVideoProducerStream.fragmentAckReceived(long uploadHandle, KinesisVideoFragmentAck fragmentAck)
void	NativeKinesisVideoProducerJni.free()	Frees the underlying Kinesis Video object.
void	NativeKinesisVideoProducerJni.freeStream(KinesisVideoProducerStream stream)
void	NativeKinesisVideoProducerJni.freeStreams()
InputStream	NativeKinesisVideoProducerStream.getDataStream(long uploadHandle)
KinesisVideoMetrics	NativeKinesisVideoProducerJni.getMetrics()
KinesisVideoStreamMetrics	NativeKinesisVideoProducerStream.getMetrics()
void	NativeKinesisVideoProducerJni.getStreamData(long streamHandle, long uploadHandle, byte[] fillBuffer, int offset, int length, ReadResult readResult)	Get stream data from the buffer for specific upload Handle.
void	NativeKinesisVideoProducerStream.getStreamData(long uploadHandle, byte[] fillBuffer, int offset, int length, ReadResult readResult)
void	NativeKinesisVideoProducerJni.getStreamingEndpointResult(KinesisVideoProducerStream stream, long streamHandle, String endpoint, int httpStatusCode)
void	NativeKinesisVideoProducerJni.getStreamingTokenResult(KinesisVideoProducerStream stream, long streamHandle, byte[] token, long expiration, int httpStatusCode)
void	NativeKinesisVideoProducerJni.getStreamMetrics(long streamHandle, KinesisVideoStreamMetrics streamMetrics)	Fills in the stream metrics object
void	NativeKinesisVideoProducerJni.parseFragmentAck(long streamHandle, long uploadHandle, String kinesisVideoFragmentAck)	Parses and processes an ACK string
void	NativeKinesisVideoProducerStream.parseFragmentAck(long uploadHandle, String kinesisVideoFragmentAck)
void	NativeKinesisVideoProducerJni.putEventMetadata(long streamHandle, int event, StreamEventMetadata streamEventMetadata)	Put an event metadata.
void	NativeKinesisVideoProducerStream.putEventMetadata(int event, StreamEventMetadata streamEventMetadata)
void	NativeKinesisVideoProducerJni.putFragmentMetadata(long streamHandle, String metadataName, String metadataValue, boolean persistent)	Put a fragment metadata.
void	NativeKinesisVideoProducerStream.putFragmentMetadata(String metadataName, String metadataValue, boolean persistent)
void	NativeKinesisVideoProducerJni.putFrame(long streamHandle, KinesisVideoFrame kinesisVideoFrame)	Put a frame.
void	NativeKinesisVideoProducerStream.putFrame(KinesisVideoFrame kinesisVideoFrame)
void	NativeKinesisVideoProducerJni.putStreamResult(KinesisVideoProducerStream stream, long clientStreamHandle, int httpStatusCode)
void	NativeKinesisVideoProducerStream.resetConnection()	Create a new connection to continue sending data in current buffer
void	NativeKinesisVideoProducerJni.stopStream(long streamHandle)	Stops an Kinesis Video stream.
void	NativeKinesisVideoProducerStream.stopStream()
void	NativeKinesisVideoProducerJni.stopStreams()	Stops all Kinesis Video streams.
void	NativeKinesisVideoProducerStream.stopStreamSync()
void	NativeKinesisVideoProducerStream.streamClosed(long uploadHandle)
void	NativeKinesisVideoProducerStream.streamConnectionStale(long lastAckDuration)
void	NativeKinesisVideoProducerStream.streamDataAvailable(long uploadHandle, long duration, long availableSize)
void	NativeKinesisVideoProducerStream.streamErrorReport(long uploadHandle, long fragmentTimecode, long statusCode)
void	NativeKinesisVideoProducerJni.streamFormatChanged(long streamHandle, byte[] codecPrivateData, long trackId)	Stream format has changed.
void	NativeKinesisVideoProducerStream.streamFormatChanged(byte[] codecPrivateData, int trackId)
void	NativeKinesisVideoProducerStream.streamFreed()
void	NativeKinesisVideoProducerStream.streamLatencyPressure(long duration)
void	NativeKinesisVideoProducerStream.streamReady()
void	NativeKinesisVideoProducerJni.streamTerminated(long streamHandle, long uploadHandle, int statusCode)	Reports an abnormal stream termination event.
void	NativeKinesisVideoProducerStream.streamTerminated(long uploadHandle, int statusCode)
void	NativeKinesisVideoProducerStream.streamUnderflowReport()
void	NativeKinesisVideoProducerJni.tagResourceResult(KinesisVideoProducerStream stream, long streamHandle, int httpStatusCode)

Constructors in com.amazonaws.kinesisvideo.internal.producer.jni that throw ProducerException

Constructor	Description
NativeKinesisVideoProducerJni(AuthCallbacks authCallbacks, StorageCallbacks storageCallbacks, ServiceCallbacks serviceCallbacks)	Public constructor.
NativeKinesisVideoProducerJni(AuthCallbacks authCallbacks, StorageCallbacks storageCallbacks, ServiceCallbacks serviceCallbacks, org.apache.logging.log4j.Logger log)	Public constructor
NativeKinesisVideoProducerJni(AuthCallbacks authCallbacks, StorageCallbacks storageCallbacks, ServiceCallbacks serviceCallbacks, org.apache.logging.log4j.Logger log, CountDownLatch readyLatch)	Public constructor
NativeKinesisVideoProducerJni(AuthCallbacks authCallbacks, StorageCallbacks storageCallbacks, ServiceCallbacks serviceCallbacks, org.apache.logging.log4j.Logger log, CountDownLatch readyLatch, boolean isTrackingMallocs)	Public constructor

Uses of ProducerException in com.amazonaws.kinesisvideo.internal.service

Methods in com.amazonaws.kinesisvideo.internal.service with parameters of type ProducerException

Modifier and Type	Method	Description
protected void	DefaultServiceCallbacksImpl.notifyCallResult(KinesisVideoProducerStream stream, String methodName, ProducerException ex)	Post the exception onto the StreamCallbacks.streamErrorReport(long, long, long) callback so the application can decide what to do with the error.

Methods in com.amazonaws.kinesisvideo.internal.service that throw ProducerException

Modifier and Type	Method	Description
void	DefaultServiceCallbacksImpl.createDevice(String deviceName, long callAfter, long timeout, byte[] authData, int authType, long customData)
void	DefaultServiceCallbacksImpl.createStream(String deviceName, String streamName, String contentType, String kmsKeyId, long retentionPeriod, long callAfter, long timeout, byte[] authData, int authType, KinesisVideoProducerStream stream)
void	DefaultServiceCallbacksImpl.describeStream(String streamName, long callAfter, long timeout, byte[] authData, int authType, long streamHandle, KinesisVideoProducerStream stream)
void	DefaultServiceCallbacksImpl.deviceCertToToken(String deviceName, long callAfter, long timeout, byte[] authData, int authType, long customData)
void	DefaultServiceCallbacksImpl.getStreamingEndpoint(String streamName, String apiName, long callAfter, long timeout, byte[] authData, int authType, long streamHandle, KinesisVideoProducerStream stream)
void	DefaultServiceCallbacksImpl.getStreamingToken(String streamName, long callAfter, long timeout, byte[] authData, int authType, long streamHandle, KinesisVideoProducerStream stream)
void	DefaultServiceCallbacksImpl.putStream(String streamName, String containerType, long streamStartTime, boolean absoluteFragmentTimes, boolean ackRequired, String dataEndpoint, long callAfter, long timeout, byte[] authData, int authType, KinesisVideoProducerStream kinesisVideoProducerStream)
void	DefaultServiceCallbacksImpl.tagResource(String resourceArn, Tag[] tags, long callAfter, long timeout, byte[] authData, int authType, long streamHandle, KinesisVideoProducerStream stream)

Uses of ProducerException in com.amazonaws.kinesisvideo.java.service

Methods in com.amazonaws.kinesisvideo.java.service that throw ProducerException

Modifier and Type	Method	Description
void	CachedInfoMultiAuthServiceCallbacksImpl.createStream(String deviceName, String streamName, String contentType, String kmsKeyId, long retentionPeriod, long callAfter, long timeout, byte[] authData, int authType, KinesisVideoProducerStream stream)
void	MultiAuthServiceCallbacksImpl.createStream(String deviceName, String streamName, String contentType, String kmsKeyId, long retentionPeriod, long callAfter, long timeout, byte[] authData, int authType, KinesisVideoProducerStream stream)
void	CachedInfoMultiAuthServiceCallbacksImpl.describeStream(String streamName, long callAfter, long timeout, byte[] authData, int authType, long streamHandle, KinesisVideoProducerStream stream)
void	MultiAuthServiceCallbacksImpl.describeStream(String streamName, long callAfter, long timeout, byte[] authData, int authType, long streamHandle, KinesisVideoProducerStream stream)
void	CachedInfoMultiAuthServiceCallbacksImpl.getStreamingEndpoint(String streamName, String apiName, long callAfter, long timeout, byte[] authData, int authType, long streamHandle, KinesisVideoProducerStream stream)
void	MultiAuthServiceCallbacksImpl.getStreamingEndpoint(String streamName, String apiName, long callAfter, long timeout, byte[] authData, int authType, long streamHandle, KinesisVideoProducerStream stream)
void	CachedInfoMultiAuthServiceCallbacksImpl.getStreamingToken(String streamName, long callAfter, long timeout, byte[] authData, int authType, long streamHandle, KinesisVideoProducerStream stream)
void	MultiAuthServiceCallbacksImpl.getStreamingToken(String streamName, long callAfter, long timeout, byte[] authData, int authType, long streamHandle, KinesisVideoProducerStream stream)
void	CachedInfoMultiAuthServiceCallbacksImpl.tagResource(String resourceArn, Tag[] tagsUnused, long callAfter, long timeout, byte[] authData, int authType, long streamHandle, KinesisVideoProducerStream stream)
void	MultiAuthServiceCallbacksImpl.tagResource(String resourceArn, Tag[] tags, long callAfter, long timeout, byte[] authData, int authType, long streamHandle, KinesisVideoProducerStream stream)

Uses of ProducerException in com.amazonaws.kinesisvideo.producer

Methods in com.amazonaws.kinesisvideo.producer that throw ProducerException

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

Uses of ProducerException in com.amazonaws.kinesisvideo.streaming

Methods in com.amazonaws.kinesisvideo.streaming that throw ProducerException

Modifier and Type	Method	Description
void	DefaultStreamCallbacks.bufferDurationOverflowPressure(long remainDuration)
void	DefaultStreamCallbacks.droppedFragmentReport(long fragmentTimecode)
void	DefaultStreamCallbacks.droppedFrameReport(long frameTimecode)
void	DefaultStreamCallbacks.fragmentAckReceived(long uploadHandle, KinesisVideoFragmentAck fragmentAck)
void	DefaultStreamCallbacks.streamClosed(long uploadHandle)
void	DefaultStreamCallbacks.streamConnectionStale(long lastAckDuration)
void	DefaultStreamCallbacks.streamDataAvailable(long uploadHandle, long duration, long availableSize)
void	DefaultStreamCallbacks.streamErrorReport(long uploadHandle, long frameTimecode, long statusCode)
void	DefaultStreamCallbacks.streamLatencyPressure(long duration)
void	DefaultStreamCallbacks.streamReady()
void	DefaultStreamCallbacks.streamUnderflowReport()