eva.v2.messaging.jms.alpha.core — com.workiva/eva 2.0.1

add-connection-error-watch clj

(add-connection-error-watch r key f)

bytes-message clj

(bytes-message x)

(bytes-message x msg-or-throwable)

Wraps and serializes either a POCO or a throwable into a message object

bytes-message-payload clj

(bytes-message-payload msg)

Read out the contents of the maybe-exception monad payload.

Returns POCO or Throwable.

connection-error clj

(connection-error r)

connection-error? clj

(connection-error? r)

connection-factory-from-uri clj

(connection-factory-from-uri uri)

connection-factory-ha-with-discovery-group clj

(connection-factory-ha-with-discovery-group dgc)

connection-factory-uri clj

(connection-factory-uri cf)

consumer clj

(consumer c d)

create-context clj

(create-context connection-factory)

(create-context connection-factory ack-behavior)

error-key->error-type clj

error-type clj

(error-type x)

error-type->error-key clj

error-type= clj

(error-type= x y)

invalid-request? clj

(invalid-request? spec request msg)

Returns an ExceptionInfo if the provided request does not satisfy the spec

message clj

(message x)

MessageCreation clj protocol

-create-bytes-message clj

(-create-bytes-message x)

-create-message clj

(-create-message x)

-create-text-message clj

(-create-text-message x)

(-create-text-message x s)

producer clj

(producer c)

publish! clj

(publish! p message-object)

publisher clj

(publisher {:keys [connection-factory context topic outbound-spec]})

Builds a publisher object for unidirectional async messaging to multiple consumers

queue clj

(queue queue-name)

rebuild-responder clj

(rebuild-responder r)

remove-connection-error-watch clj

(remove-connection-error-watch r key)

requestor clj

(requestor {:keys [connection-factory request-queue outbound-spec
                   inbound-spec]})

responder clj

(responder {:keys [connection-factory request-queue request-handler interceptors
                   inbound-spec outbound-spec]})

send-request! clj

(send-request! r message-object)

subscriber clj

(subscriber {:keys [connection-factory topic subscriber-id inbound-spec
                    handler]})

text-message clj

(text-message x)

(text-message x s)

topic clj

(topic topic-name)

wrap-msg clj

(wrap-msg msg)

Build an artisanal exception monad around the message contents