From 4cf85af25d617f9cd76d47ae744fe7e23e2be594 Mon Sep 17 00:00:00 2001
From: Stephen Clayton <clayton@shh.mpg.de>
Date: Mon, 28 Aug 2017 14:36:55 +0200
Subject: [PATCH] add loopback channel to direct local messages to endpoints

---
 project.clj                                                 | 2 +-
 .../de/mpg/shh/util_message_server/message_dispatcher.clj   | 6 ++++--
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/project.clj b/project.clj
index 853dd74..d0153a1 100755
--- a/project.clj
+++ b/project.clj
@@ -1,4 +1,4 @@
-(defproject de.mpg.shh/util-message-server "0.0.12"
+(defproject de.mpg.shh/util-message-server "0.0.13"
   :description "Interop with hornetq"
   :url "http://www.shh.mpg.de/"
   :license {:name "Eclipse Public License"
diff --git a/src/main/clojure/de/mpg/shh/util_message_server/message_dispatcher.clj b/src/main/clojure/de/mpg/shh/util_message_server/message_dispatcher.clj
index c06e17b..6141d6f 100644
--- a/src/main/clojure/de/mpg/shh/util_message_server/message_dispatcher.clj
+++ b/src/main/clojure/de/mpg/shh/util_message_server/message_dispatcher.clj
@@ -49,10 +49,12 @@
             :as message-server} :message-server
            dispatcher-request-transducer :dispatcher-request-transducer
            end-points :end-points
+           loopback-channel :loopback-channel
            :as component}]
          (let [dispatcher-request-channel (async/chan dispatcher-request-buffer-size dispatcher-request-transducer)
-               _ (life-cycle/listen message-server listen-context-config listen-address dispatcher-request-channel listen-selector)]
-    (async/go-loop [dispatcher-request (async/<! dispatcher-request-channel)]
+               _ (life-cycle/listen message-server listen-context-config listen-address dispatcher-request-channel listen-selector)
+               dispatcher-request-merge-channel (async/merge (remove nil? [dispatcher-request-channel loopback-channel]))]
+    (async/go-loop [dispatcher-request (async/<! dispatcher-request-merge-channel)]
                    (if (dispatch request-channel end-points dispatcher-request)
                      (recur (async/<! dispatcher-request-channel))
                      (info "Shutdown dispatcher request channel")))