async-messaging.protocols

Liking cljdoc? Tell your friends :D

Clojure only.

CommonConsumer
CommonProducer

CommonConsumer^cljprotocol

Start a consumer worker for a given settings settings is a map with the following keys: {:event-consumer-x {:handler s/fn :reciever-details s/map}} details will be provided by the implementation detail for each messaging technology and optionally an ops map for implementation-specific options.

Start a consumer worker for a given settings
settings is a map with the following keys: {:event-consumer-x {:handler s/fn :reciever-details s/map}}
 details will be provided by the implementation detail for each messaging technology
 and optionally an `ops` map for implementation-specific options.

listen^clj

(listen this setting)

(listen this setting ops)

source raw docstring

CommonProducer^cljprotocol

A protocol for sending messages to a message queue, has to be generic to the point of not knowing the underlying implementation and working fine with Redis, Kafka, SQS, RabbitMQ, etc. message is a map and at least it has a key :message and :destination each being a map witch underling component implementation may require diferent keys ops is a config map that should be adhered by all implementations with the following keys :async? s/Bool default false, this will indicate if the producer will be async or not for blocking or non blocking operation

A protocol for sending messages to a message queue, 
has to be generic to the point of not knowing the underlying implementation 
and working fine with Redis, Kafka, SQS, RabbitMQ, etc.
message is a map and at least it has a key :message and :destination each being a map 
witch underling component implementation may require diferent keys
 ops is a config map that should be adhered by all implementations with the following keys
 :async? s/Bool default false, this will indicate if the producer will be async or not for blocking or non blocking operation