NSS Gateway/xyz.noisif.nss.gateway.queue.listener/TranscodeProgressEventsListener

TranscodeProgressEventsListener

@Singleton

open class TranscodeProgressEventsListener : QueueListener<TranscodeProgressEvent>

Constructors

TranscodeProgressEventsListener

@Inject

constructor(wsBroadcaster: WsBroadcaster, protobufJsonPrinter: ProtobufJsonPrinter)

Properties

protobufJsonPrinter

private val protobufJsonPrinter: ProtobufJsonPrinter

private val wsBroadcaster: WsBroadcaster

Functions

open fun getFormat(): SerializerFormat

open fun getMessageType(): Class<TranscodeProgressEvent>

open fun getQueueName(): String

open fun getTopology(): QueueTopology

open fun onMessage(message: TranscodeProgressEvent)