From 6c2a3337da0df8597fedba21cfc9c87fb9f4f651 Mon Sep 17 00:00:00 2001
From: "kshitij.patil" <kshitij.patil@espressif.com>
Date: Tue, 3 Jun 2025 15:07:07 +0530
Subject: [PATCH] Subscribe to topic notify-next

---
 .../ota_over_mqtt_demo/ota_over_mqtt_demo.c         | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/main/demo_tasks/ota_over_mqtt_demo/ota_over_mqtt_demo.c b/main/demo_tasks/ota_over_mqtt_demo/ota_over_mqtt_demo.c
index 49818f6..4eb2ff2 100644
--- a/main/demo_tasks/ota_over_mqtt_demo/ota_over_mqtt_demo.c
+++ b/main/demo_tasks/ota_over_mqtt_demo/ota_over_mqtt_demo.c
@@ -1392,6 +1392,19 @@ static void prvOTADemoTask( void * pvParam )
             vTaskDelay( pdMS_TO_TICKS( 100 ) );
         }
 
+        // Subscribe to notify-next
+        char jobNotifyTopic[JOBS_API_MAX_LENGTH(strlen(otademoconfigCLIENT_IDENTIFIER))];
+        size_t jobNotifyTopicLen = 0;
+
+        JobsStatus_t status = Jobs_GetTopic( jobNotifyTopic,
+                                             sizeof(jobNotifyTopic),
+                                             otademoconfigCLIENT_IDENTIFIER,
+                                             strlen(otademoconfigCLIENT_IDENTIFIER),
+                                             JobsNextJobChanged,
+                                             &jobNotifyTopicLen);
+
+        prvMQTTSubscribe( jobNotifyTopic, (uint16_t) jobNotifyTopicLen, 1 );
+
         while( otaAgentState != OtaAgentStateStopped )
         {
             processOTAEvents();