com.timezynk.bus.core — com.timezynk/bus 1.2.1

Bus clj protocol

Abstraction for media which transfer messages to subscribers. Subscription is done by declaring interest in a topic. Topics get published on the bus, which routes them to eligible subscribers.

destroy clj

(destroy this)

Releases all associated resources.

eligible-for clj

(eligible-for bus topic collection)

Sequence of subscribers eligible for topic on collection.

initialize clj

(initialize this)

(initialize this num-workers)

(initialize this num-workers params)

Acquires all associated resources.

length clj

(length this)

Number of enqueued messages.

publish clj

(publish this context topic collection messages)

Puts messages on the bus.

subscribe clj

(subscribe this topic collection subscriber)

Registers subscriber for topic on collection.

unsubscribe-all clj

(unsubscribe-all this)

Unregisters all subscribers.

create clj

(create group)

wait-for clj

(wait-for timeout-ms reply-channel)

Awaits responses on reply-channel. Returns false on timeout. Throws the caught exception on error. Returns true otherwise.