(get-tx-report-queue-multicast! conn id)
(get-tx-report-queue-multicast! conn id send-end-token?)
Multicast the datomic.api/tx-report-queue to different consumers.
A multicaster thread is started on demand per connection. conn
and id
identifies the consumer.
Repeated calls using the same conn
and id
returns the same queue.
The optional third parameter, send-end-token?
, if set to true
, instructs the multicaster thread
to send :end
if the queue is stopped. The default value is false
.
A queue may be stopped using stop-multicaster-id!
, stop-multicaster!
or stop-all-multicasters!
.
Returns a java.util.concurrent.BlockingQueue
like datomic.api/tx-report-queue
.
Multicast the datomic.api/tx-report-queue to different consumers. A multicaster thread is started on demand per connection. `conn` and `id` identifies the consumer. Repeated calls using the same `conn` and `id` returns the same queue. The optional third parameter, `send-end-token?`, if set to `true`, instructs the multicaster thread to send `:end` if the queue is stopped. The default value is `false`. A queue may be stopped using `stop-multicaster-id!`, `stop-multicaster!` or `stop-all-multicasters!`. Returns a `java.util.concurrent.BlockingQueue` like `datomic.api/tx-report-queue`.
cljdoc builds & hosts documentation for Clojure/Script libraries
Ctrl+k | Jump to recent docs |
← | Move to previous article |
→ | Move to next article |
Ctrl+/ | Jump to the search field |