monkey.jms — com.monkeyprojects/monkey-jms 0.1.1

Core namespace for the MonkeyProjects JMS/ActiveMQ wrapper

->destination clj multimethod

connect clj

(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.

consume clj

(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.

disconnect clj

(disconnect ctx)

Shuts down the given connection

make-consumer clj

Alias for consume, to be similar to make-producer.

make-listener clj

(make-listener f)

make-producer clj

(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.

make-queue clj

(make-queue s ctx)

make-topic clj

(make-topic s ctx)

produce clj

Alias for make-producer for consistency with consume.

queue-prefix clj

topic-prefix clj

unsubscribe clj

(unsubscribe ctx id)

Unsubscribes the connection from a durable subscription.