helpers.clj

(ns de.mpg.shh.util-message-server.helpers
  (:require [clojure.tools.logging :refer [info error]]
            [clojure.core.async :as async]))

(defn synch-send
  [request-channel host port username password address msg & {:keys [properties encoding timeout result-channel] :or {properties nil encoding :edn timeout 1000 result-channel (async/chan 1)}}]
  (async/>!! request-channel {:msg msg
                              :properties properties
                              :encoding encoding
                              :command :send
                              :host host
                              :port port
                              :username username
                              :password password
                              :address address
                              :result-channel result-channel})
  (first (async/alts!! [(async/timeout timeout) result-channel])))