kehaar.wire-up
async->fire-and-forget-fnclj
(async->fire-and-forget-fn channel)(async->fire-and-forget-fn channel metadata)Returns a fn that takes a message and puts message and metadata on the channel. Returns the value of async/>!! which returns true if it was successfull putting a message on the channel.
Returns a fn that takes a message and puts message and metadata on the channel. Returns the value of async/>!! which returns true if it was successfull putting a message on the channel.
async->fnclj
(async->fn channel)Returns a fn that takes a message, creates a core.async channel for the response for that message, and puts [response-channel, message] on the channel given. Returns the response-channel.
Returns a fn that takes a message, creates a core.async channel for the response for that message, and puts [response-channel, message] on the channel given. Returns the response-channel.
declare-events-exchangeclj
(declare-events-exchange connection name type options)Declare an events exchange.
Returns a langohr channel. Please close it on exit.
Declare an events exchange. Returns a langohr channel. Please close it on exit.
external-serviceclj
(external-service connection queue-name channel)(external-service connection exchange queue-name queue-options timeout channel)Wires up a core.async channel to a RabbitMQ queue that provides
responses. Use async->fn to create a function that puts to
that channel.
Wires up a core.async channel to a RabbitMQ queue that provides responses. Use `async->fn` to create a function that puts to that channel.
external-service-fire-and-forgetclj
(external-service-fire-and-forget connection queue-name channel)(external-service-fire-and-forget connection
exchange
queue-name
queue-options
channel)Wires up a core.async channel to a RabbitMQ queue. Just put a
message on the channel. Use async->fire-and-forget-fn to create a
function that puts to that channel.
Wires up a core.async channel to a RabbitMQ queue. Just put a message on the channel. Use `async->fire-and-forget-fn` to create a function that puts to that channel.
incoming-events-channelclj
(incoming-events-channel connection
queue-name
options
topic-name
routing-key
channel
timeout)(incoming-events-channel connection
queue-name
options
topic-name
routing-key
channel
timeout
prefetch-limit)Wire up a channel that will receive incoming events that match
routing-key.
Returns a langohr channel. Please close it on exit.
Wire up a channel that will receive incoming events that match `routing-key`. Returns a langohr channel. Please close it on exit.
incoming-serviceclj
(incoming-service connection queue-name options in-channel out-channel)(incoming-service connection
exchange
queue-name
options
in-channel
out-channel
ignore-no-reply-to)(incoming-service connection
exchange
queue-name
options
in-channel
out-channel
ignore-no-reply-to
prefetch-limit)Wire up an incoming channel and an outgoing channel. Later, you
should call start-responder! with the same channels and a handler
function.
Returns a langohr channel. Please close it on exit.
Wire up an incoming channel and an outgoing channel. Later, you should call `start-responder!` with the same channels and a handler function. Returns a langohr channel. Please close it on exit.
outgoing-events-channelclj
(outgoing-events-channel connection topic-name routing-key channel)Wire up a queue listening to a channel for events.
Returns a langohr channel. Please close it on exit.
Wire up a queue listening to a channel for events. Returns a langohr channel. Please close it on exit.
start-event-handler!clj
(start-event-handler! channel handler)(start-event-handler! channel handler threads)Start new threads listening for messages on channel and passing
them to handler. Will loop over all messages, logging errors. When
channel is closed, stop looping.
Start new threads listening for messages on `channel` and passing them to `handler`. Will loop over all messages, logging errors. When `channel` is closed, stop looping.
start-jobs-handler!clj
(start-jobs-handler! rabbit-channel in-chan f threads)Start new threads that listen on in-channel, calling f for each message. f must be a function of 3 arguments: a core.async channel to send responses on, the routing-key of the job, and the message received.
Start new threads that listen on in-channel, calling f for each message. f must be a function of 3 arguments: a core.async channel to send responses on, the routing-key of the job, and the message received.
start-responder!clj
(start-responder! in-channel out-channel f)(start-responder! in-channel out-channel f threads)Start new threads that listen on in-channel and responds on out-channel.
Start new threads that listen on in-channel and responds on out-channel.
start-streaming-responder!clj
(start-streaming-responder! connection in-channel out-channel f threshold)(start-streaming-responder! connection
in-channel
out-channel
f
threshold
threads)Start new threads that listen on in-channel and respond on out-channel. threshold is the number of elements beyond which they should be placed on a bespoke RabbitMQ for the consumer.
Start new threads that listen on in-channel and respond on out-channel. threshold is the number of elements beyond which they should be placed on a bespoke RabbitMQ for the consumer.
streaming-external-serviceclj
(streaming-external-service connection queue-name channel)(streaming-external-service connection
exchange
queue-name
queue-options
timeout
channel)Wires up a core.async channel to a RabbitMQ queue that provides
responses. Use async->fn to create a function that puts to
that channel.
Wires up a core.async channel to a RabbitMQ queue that provides responses. Use `async->fn` to create a function that puts to that channel.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close