wamp.clj

(ns crossbar-clj.core
  (:require [promissum.core :as p])
  (:import [io.crossbar.autobahn.wamp Session Client]))

(defn -main []
  (let [wampSession (new Session)
        wampClient (new Client
                        wampSession
                        "ws://localhost:8080/ws"
                        "realm1"
                        )]
    #_(.addOnJoinListener wampSession
                        (fn [session, details]
                          (let [callFuture (.call session "my.com.date")
                                ]
                            (.whenComplete callFuture (fn [date, throwable]
                                                        (println date))))))
    (.connect wampClient)
    (Thread/sleep 1000)
    (println (first (.results (p/await (.call wampSession "my.com.date")))))

    ))