eva.v2.messaging.node.local-simulation — com.workiva/eva 2.0.3

This messaging implementation was forked from the local messaging node to provide a less restricted more-nondeterministic broker.

*instance-id* clj

facade-messenger clj

(facade-messenger shared-messenger instance-id)

get-responder clj

(get-responder node addr)

get-subscribers clj

(get-subscribers node addr)

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)

with-instance-id clj macro

(with-instance-id id & body)