clojure-message-broker-common.protocols — org.clojars.sn0wf1eld/clojure-message-broker-common 0.1.1

->client clj

(->client [url port])

->server clj

(->server conf handle-fn)

brokers->brokers-by-id clj

(brokers->brokers-by-id brokers)

clients clj

CMBClient clj protocol

initClient clj

(initClient this)

stop clj

(stop this)

stopped? clj

(stopped? this)

write clj

(write this data)

CMBServer clj protocol

init clj

(init this)

data->out-stream clj

(data->out-stream out-stream send-data)

Deserializer clj protocol

deserialize clj

(deserialize this val)

in-stream->deserialized-data clj

(in-stream->deserialized-data in-stream)

make-comm clj

(make-comm success?)

(make-comm value success?)

(make-comm type key value)

(make-comm type key value success?)

(make-comm type key topic value auto-commit?)

(make-comm type brokers key topic value auto-commit? success? error)

make-error-comm clj

(make-error-comm error)

Message clj protocol

getType clj

(getType this)

success? clj

(success? this)

setKey clj

(setKey this key)

replicate? clj

(replicate? this)

getError clj

(getError this)

getBrokers clj

(getBrokers this)

getKey clj

(getKey this)

setError clj

(setError this error)

getValue clj

(getValue this)

getTs clj

(getTs this)

setType clj

(setType this type)

setValue clj

(setValue this value)

setBrokers clj

(setBrokers this brokers)

setTopic clj

(setTopic this topic)

getTopic clj

(getTopic this)

auto-commit? clj

(auto-commit? this)

setTs clj

(setTs this ts)

multi-addresses->broker-by-id clj

(multi-addresses->broker-by-id addresses)

Serializer clj protocol

serialize clj

(serialize this val)