From bb8f311ebbad876d8cee1493bbf336b91742beaf Mon Sep 17 00:00:00 2001 From: Brage Date: Mon, 24 Jul 2023 18:09:35 +0200 Subject: [PATCH] Updated code base --- .../streamit/content/encode/runner/RunnerCoordinator.kt | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/Encode/src/main/kotlin/no/iktdev/streamit/content/encode/runner/RunnerCoordinator.kt b/Encode/src/main/kotlin/no/iktdev/streamit/content/encode/runner/RunnerCoordinator.kt index 21b8545c..4d65411f 100644 --- a/Encode/src/main/kotlin/no/iktdev/streamit/content/encode/runner/RunnerCoordinator.kt +++ b/Encode/src/main/kotlin/no/iktdev/streamit/content/encode/runner/RunnerCoordinator.kt @@ -49,7 +49,7 @@ class RunnerCoordinator { } } catch (e: Exception) { e.printStackTrace() - producer.sendMessage(KafkaEvents.EVENT_ENCODER_ENDED_VIDEO_FILE.event, message.withNewStatus(Status(StatusType.ERROR, e.message))) + producer.sendMessage(KafkaEvents.EVENT_ENCODER_STARTED_VIDEO_FILE.event, message.withNewStatus(Status(StatusType.ERROR, e.message))) } } @@ -70,7 +70,7 @@ class RunnerCoordinator { } } catch (e: Exception) { e.printStackTrace() - producer.sendMessage(KafkaEvents.EVENT_ENCODER_ENDED_SUBTITLE_FILE.event, message.withNewStatus(Status(StatusType.ERROR, e.message))) + producer.sendMessage(KafkaEvents.EVENT_ENCODER_STARTED_SUBTITLE_FILE.event, message.withNewStatus(Status(StatusType.ERROR, e.message))) } } }