Core namespace for the MonkeyProjects JMS/ActiveMQ wrapper
Core namespace for the MonkeyProjects JMS/ActiveMQ wrapper
(connect {:keys [username password url client-id]})
Connects to the configured JMS server. The options map takes a url
, and
optional username
and password
. You can also specify a client-id
for
durable subscriptions.
Connects to the configured JMS server. The options map takes a `url`, and optional `username` and `password`. You can also specify a `client-id` for durable subscriptions.
(consume ctx dest & [listener-or-opts opts])
Starts consuming messages from the given destination. Messages are passed
to the listener. Returns an AutoCloseable
that can be used to stop
consuming. The optional opts
argument is a map that can hold an :id
for a durable subscription. Not that you need to set a client id on the
context as well for this to work.
Starts consuming messages from the given destination. Messages are passed to the listener. Returns an `AutoCloseable` that can be used to stop consuming. The optional `opts` argument is a map that can hold an `:id` for a durable subscription. Not that you need to set a client id on the context as well for this to work.
(disconnect ctx)
Shuts down the given connection
Shuts down the given connection
Alias for consume
, to be similar to make-producer
.
Alias for `consume`, to be similar to `make-producer`.
(make-producer ctx dest & [opts])
Creates a producer function. The function accepts a single argument, the
messages to produce. How messages are built can be specified in the options.
The producer also implements AutoCloseable
, to allow it to be shut down.
Creates a producer function. The function accepts a single argument, the messages to produce. How messages are built can be specified in the options. The producer also implements `AutoCloseable`, to allow it to be shut down.
Alias for make-producer
for consistency with consume
.
Alias for `make-producer` for consistency with `consume`.
(unsubscribe ctx id)
Unsubscribes the connection from a durable subscription.
Unsubscribes the connection from a durable subscription.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close