titanoboa.channel — io.titanoboa/titanoboa 0.8.2

*mq-session* clj

->distributed-ch clj multimethod

ack! clj multimethod

alt!! clj macro

(alt!! & clauses)

alts!! clj multimethod

Enables calling alts!! on a mix of core.async and RabbitMQ channels. If only core.async channels are provided it calls the native core.async alts!! function on them. Otherwise calls rmq-blocking-alts!! which will block and periodically poll all given channels.

Cleanable clj protocol

cleanup! clj

(cleanup! this)

current-session clj

(current-session)

If used within (with-connection conn ...), returns the currently bound connection.

delete-mq-chan clj multimethod

distributed? clj multimethod

mq-chan clj multimethod

nack! clj multimethod

poll! clj multimethod

Synchronous poll operation. Reads from given channel or immediatelly returns nil if the channel is empty.

TransChannelProtocol clj protocol

generic interface for channel implementaiton - from core.async through JMS to AMQP

with-mq-session clj macro

(with-mq-session conn & body)

Binds session to a value you can retrieve with (current-session) within body.

with-mq-sessionpool clj macro

(with-mq-sessionpool pool & body)

Retrieves a session from provided session pool (which is expected to be a simple core.async chan that provides maps in a format of {:connection RMQ-Connection-object :session RMQ-Session-object}). Binds session to a value you can retrieve with (current-session) within body. If the session has already been bound then does nothing - to enable nested use of this macro without furhter consumption from the session pool.