Liking cljdoc? Tell your friends :D

qbits.tape.queue


->roll-cycle

source

IQueueprotocol

close!
(close! q)

Closes the queue

Closes the queue

closed?
(closed? q)

Returns true if the queue is closed

Returns true if the queue is closed

codec
(codec q)

Returns codec to be used with queue instance

Returns codec to be used with queue instance

underlying-queue
(underlying-queue q)

Returns the underlying chronicle-queue instance

Returns the underlying chronicle-queue instance

source

make

(make dir)
(make dir
      {:keys [roll-cycle autoclose-on-jvm-exit? cycle-release-tasks
              cycle-acquire-tasks codec],
       :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
sourceraw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close