Liking cljdoc? Tell your friends :D
shovel.consumer
consumer-connectorclj
(consumer-connector h)returns a ConsumerConnector that can be used to create consumer streams
returns a ConsumerConnector that can be used to create consumer streams
message-streamsclj
(message-streams consumer-conn topic number-of-streams)returning the message-streams with a certain topic and thread-pool-size message-streams can be processed in threads with simple blocking on empty queue
returning the message-streams with a certain topic and thread-pool-size message-streams can be processed in threads with simple blocking on empty queue
message-to-stringclj
(message-to-string message)returns a string for a message
returns a string for a message
message-to-vecclj
(message-to-vec message)returns a vector of all of the message fields
returns a vector of all of the message fields
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close