eva.v2.messaging.jms.beta.patterns — com.workiva/eva 2.0.4

*default-message-expiration* clj

MessageProtocol clj protocol

data-message? clj

(data-message? mp msg)

error-message? clj

(error-message? mp msg)

new-data-message clj

(new-data-message mc session)

new-error-message clj

(new-error-message mc session)

read-data-message clj

(read-data-message mc msg)

read-error-message clj

(read-error-message mc msg)

write-data-message clj

(write-data-message mc msg data)

write-error-message clj

(write-error-message mc msg err)

publish! clj

(publish! {:as publisher :keys [session concurrent? message-protocol producer]}
          data)

Broadcasts a message to the Topic of the publisher

publisher clj

(publisher connection
           {:keys [concurrent? topic delivery-mode time-to-live
                   message-protocol]
            :or {concurrent? true
                 delivery-mode :non-persistent
                 time-to-live *default-message-expiration*}})

Builds a publisher object for unidirectional async messaging to multiple consumers

publisher? clj

(publisher? x)

read-message-type clj

(read-message-type m)

rebuild-requestor clj

(rebuild-requestor c r)

Closes Requestor r and then creates a new Requestor on Connection c that uses the same settings as the original Requestor r.

rebuild-responder clj

(rebuild-responder c r)

Closes Responder r and then creates a new Responder on Connection c that uses the same settings as the original responder r.

rebuild-subscriber clj

(rebuild-subscriber c s)

Closes Subscriber s and then creates a new Subscriber with the same settings on Connection c

requestor clj

(requestor connection
           {:keys [concurrent? request-queue request-delivery-mode
                   request-expiration message-protocol]
            :or {concurrent? true
                 request-delivery-mode :non-persistent
                 request-expiration *default-message-expiration*}})

Constructs a new Requestor on the JMS connection. The following options are accepted:

• :request-queue :: required. The name of the queue where requests will be sent.

• :message-protocol :: required. Implementation of MessageProtocol used to encode request messages and decode response messages.

• :concurrent? :: optional, default=true. When true, the requestor is thread-safe under concurrency. When false the requestor is NOT thread-safe.

• :request-delivery-mode :: optional, default=:non-persistent. The delivery-mode used for request messages.

• :request-expiration :: optional, default=default-message-expiration. The time-to-live for request messages.

requestor? clj

(requestor? x)

Tests if x is a Requestor

responder clj

(responder connection
           {:keys [request-queue message-protocol request-handler
                   reply-delivery-mode reply-expiration]})

Creates a new Responder on connection using the settings specified in the option map:

• :request-queue :: required, the name of the queue to listen on for requests.

• :message-protocol :: required, implementation of MessageProtocol that defines how request messages are decoded/read and how response messages are created/encoded.

• :request-handler :: required, a function that accepts the decoded request data and returns the data that should be sent in response.

• :reply-delivery-mode :: optional, the delivery-mode to use for reply/response messages.

• :reply-expiration :: optional, the time-to-live for reply/response messages.

responder? clj

(responder? x)

Tests if x is a Responder

send-request! clj

(send-request! r data)

Uses Requestor r to send data to a remote Responder service.

set-exscriber! clj

(set-exscriber! exscribe)

set-message-type! clj

(set-message-type! m t)

subscriber clj

(subscriber connection {:keys [topic message-protocol handler]})

Creates a new Subscriber on the connection that will listen for messages broadcast to the topic.

The following options are required:

• :topic :: required, the name of the topic to subscribe to.
• :message-protocol :: required, an instance of MessageProtocol used to decode messages.
• :handler :: a function of 2 arguments s (the Subscriber) and d (the data contained the message), called whenever a message is received.

subscriber? clj

(subscriber? x)