From 0e73a014339a41d6385f7049dea33a0e47bbe66c Mon Sep 17 00:00:00 2001
From: Bart Polot <bart.polot+voyager@gmail.com>
Date: Tue, 31 Jan 2017 05:06:36 +0100
Subject: [PATCH] Implement incoming traffic handling on MQ

---
 src/cadet/cadet_api.c | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/src/cadet/cadet_api.c b/src/cadet/cadet_api.c
index a1c7e8461..7640a924a 100644
--- a/src/cadet/cadet_api.c
+++ b/src/cadet/cadet_api.c
@@ -975,6 +975,12 @@ handle_local_data (void *cls,
        ntohl (message->ccn.channel_of_client),
        GC_m2s (type),
        type);
+  if (NULL != ch->mq)
+  {
+    GNUNET_MQ_inject_message (ch->mq, payload);
+    return;
+  }
+  /** @a deprecated */
   for (unsigned i=0;i<h->n_handlers;i++)
   {
     handler = &h->message_handlers[i];
@@ -1006,6 +1012,8 @@ handle_local_data (void *cls,
  *
  * @param h Cadet handle.
  * @param message Message itself.
+ *
+ * FIXME either delete or port to MQ
  */
 static void
 handle_local_ack (void *cls,
-- 
2.25.1