lupapiste-jms.client — lupapiste/jms-client 0.3.0

Thin Clojure wrapper for JMS client-side usage.

byte-message-as-array clj

(byte-message-as-array m)

byte-message-producer clj

(byte-message-producer session producer)

Creates producer function, which sends given bytes data as a ByteMessage to producer's destination.

create-connection clj

(create-connection connection-factory)

(create-connection connection-factory {:keys [username password ex-listener]})

Creates connection to given connection factory. Doesn't start the connection. Options map: - :username - :password - :ex-listener - sets exception listener for connection, see exception-listener.

create-consumer clj

(create-consumer session destination)

create-context clj

(create-context cf)

(create-context cf
                {:keys [session-mode username password ex-listener]
                 :or {session-mode JMSContext/AUTO_ACKNOWLEDGE}})

Creates JMSContext (JMS 2.0). Optional parameters as map:

• :username
• :password
• :session-mode (see JMSContext API docs)
• :ex-listener (ExceptionListener)

create-jms-producer clj

(create-jms-producer ctx)

(create-jms-producer ctx
                     {:keys [delivery-mode delivery-delay ttl correlation-id
                             reply-to]})

Creates JMS 2.0 defined JMSProducer. Optional parameters as map:

• :delivery-mode
• :delivery-delay
• :ttl
• :correlation-id
• :reply-to

create-producer clj

(create-producer session destination)

Creates message producer for given destination (JMS 1.1)

create-queue clj

(create-queue session name)

create-session clj

(create-session conn)

(create-session conn session-mode)

JMS 2.0 spec'd session creator.

create-topic clj

(create-topic session name)

exception-listener clj

(exception-listener listener-fn)

Implements ExceptionListener. Passes exception to given listener-fn.

listen clj

(listen session destination listener-fn)

Start consuming destination with listener-fn, which can be a Clojure function or instance of javax.jms.MessageListener. Returns created consumer.

message-listener clj

(message-listener cb)

Creates a MessageListener instance. Given callback function is fed with data from javax.jms.Message. Data type depends on message type: ByteMessage -> bytes, TextMessage -> string, ObjectMessage -> object.

MessageCreator clj protocol

Protocol for creating instance of javax.jms.Message.

create-message clj

(create-message data message-factory)

Create Message depending on type of data.

MessageFactory clj protocol

Protocol for creating specific javax.jms.Message subtypes.

create-byte-message clj

(create-byte-message factory bytes)

Create a javax.jms.BytesMessage from the byte array.

create-text-message clj

(create-text-message factory s)

Create a javax.jms.TextMessage from the String.

producer-fn clj

(producer-fn producer message-fn)

Returns function that takes one parameter: data to be sent. The data is sent via producer's send method. message-fn is called with raw data to create needed javax.jms.Message. Thus message-fn should create a javax.jms.Message which can be send with producer.

send-with-context clj

(send-with-context cf dest data & [options-map])

JMS 2.0 style producing. Creates context, sends data to destination and finally closes context. Message is created by default with 'create-message'. 'create-message' function can be extended for other types than String and bytes. Also message creating function can be passed as :message-fn option. That function is invoked with two params: data and the created context. Options map is passed to create-context and create-jms-producer, see them for usable keys.

set-listener clj

(set-listener consumer listener-fn)

Set a MessageListener for consumer. Listener-fn can be instance of MessageListener or a regular Clojure function. For regular function, an MessageListener instance is created and the function is fed with data from javax.jms.Message. Given consumer is returned.

set-message-properties clj

(set-message-properties msg properties)

Sets given properties (a map) into Message. Returns possibly mutated msg.

text-message-producer clj

(text-message-producer session producer)

Creates producer function, which sends given data as a TextMessage to producer's destination.