diff --git a/common/utils/ocp_itti/intertask_interface.cpp b/common/utils/ocp_itti/intertask_interface.cpp
index d66ea027c99253f8c7918ecdd67555144462ee74..a1455577d32f7dd3373f1d343af4547a8b0b554e 100644
--- a/common/utils/ocp_itti/intertask_interface.cpp
+++ b/common/utils/ocp_itti/intertask_interface.cpp
@@ -336,7 +336,7 @@ extern "C" {
     usleep(100*1000); // Allow the tasks to receive the message before going returning to main thread
   }
 
-  void itti_create_queue(const task_info_t *task_info) {
+  int itti_create_queue(const task_info_t *task_info) {
     pthread_mutex_lock (&lock_nb_queues);
     int newQueue=nb_queues;
     nb_queues++;
@@ -351,6 +351,7 @@ extern "C" {
 
     if (tasks[newQueue].admin.threadFunc != NULL)
       itti_create_task((task_id_t)newQueue, tasks[newQueue].admin.threadFunc, NULL);
+    return newQueue;
   }
 
   int itti_init(task_id_t task_max,
diff --git a/common/utils/ocp_itti/intertask_interface.h b/common/utils/ocp_itti/intertask_interface.h
index 53d76b7a77106a318c41c2845097dc477ba8710a..beec767829394f2db3af14796e8af41d300d833a 100644
--- a/common/utils/ocp_itti/intertask_interface.h
+++ b/common/utils/ocp_itti/intertask_interface.h
@@ -501,6 +501,8 @@ int itti_create_task(task_id_t task_id,
                      void *(*start_routine) (void *),
                      void *args_p);
 
+int itti_create_queue(const task_info_t *task_info);
+
 /** \brief Exit the current task.
  **/
 void itti_exit_task(void);