qbits.tape.queue

Liking cljdoc? Tell your friends :D

Clojure only.

->roll-cycle
IQueue
make

->roll-cycle^clj

IQueue^cljprotocol

close!^clj

(close! q)

Closes the queue

Closes the queue

closed?^clj

(closed? q)

Returns true if the queue is closed

Returns true if the queue is closed

codec^clj

(codec q)

Returns codec to be used with queue instance

Returns codec to be used with queue instance

underlying-queue^clj

(underlying-queue q)

Returns the underlying chronicle-queue instance

Returns the underlying chronicle-queue instance

make^clj

(make dir)

(make dir
      {:keys [roll-cycle autoclose-on-jvm-exit? cycle-release-tasks
              cycle-acquire-tasks codec block-size]
       :or {roll-cycle :small-daily
            autoclose-on-jvm-exit? true
            codec fressian.codec/default}})

Return a queue instance that will create/bind to a directory

roll-cycle roll-cycle determines how often you create a new Chronicle Queue data file. Can be :minutely, :daily, :test4-daily, :test-hourly, :hourly, :test-secondly, :huge-daily-xsparse, :test-daily, :large-hourly-xsparse, :large-daily, :test2-daily, :xlarge-daily, :huge-daily, :large-hourly, :small-daily, :large-hourly-sparse
autoclose-on-jvm-exit? wheter to cleanly close the queue on jvm exit (defaults to true)
cycle-release-tasks Tasks to run on queue release. See qbits.tape.cycle-listener
cycle-acquire-tasks Tasks to run on queue acquisition. See qbits.tape.cycle-listener
codec qbits.tape.codec/ICodec instance that will be used to encode/decode messages. Default to qbits.tape.codec.fressian/default

Return a queue instance that will create/bind to a directory

* `roll-cycle` roll-cycle determines how often you create a new
Chronicle Queue data file. Can be `:minutely`, `:daily`,
`:test4-daily`, `:test-hourly`, `:hourly`, `:test-secondly`,
`:huge-daily-xsparse`, `:test-daily`, `:large-hourly-xsparse`,
`:large-daily`, `:test2-daily`, `:xlarge-daily`, `:huge-daily`,
`:large-hourly`, `:small-daily`, `:large-hourly-sparse`

* `autoclose-on-jvm-exit?` wheter to cleanly close the queue on jvm
exit (defaults to true)

* `cycle-release-tasks` Tasks to run on queue release. See
qbits.tape.cycle-listener

* `cycle-acquire-tasks` Tasks to run on queue acquisition. See
qbits.tape.cycle-listener

* `codec` qbits.tape.codec/ICodec instance that will be used to
encode/decode messages. Default to qbits.tape.codec.fressian/default

raw docstring