eva.v2.messaging.node.local — com.workiva/eva 2.0.4

local-messenger clj

(local-messenger)

pub->sub! clj

(pub->sub! {:as subscriber :keys [f]} msg)

publish! clj

(publish! node publisher msg)

publish!* clj

(publish!* {:as publisher :keys [addr]} node msg)

publisher clj

(publisher addr opts)

requestor clj

(requestor addr opts)

respond! clj

(respond! {:as responder :keys [f]} {:as enveloped-msg :keys [msg reply-to]})

responder clj

(responder addr f opts)

response! clj

(response! {:as requestor :keys [promises]} id res)

send* clj

(send* msgr f & args)

send-request! clj

(send-request! node requestor msg)

send-request!* clj

(send-request!* {:as requestor :keys [addr promises]} node msg res)

subscriber clj

(subscriber id addr f opts)