qbits.tape.queue — cc.qbits/tape 0.3.0-rc2

->roll-cycle clj

IQueue clj protocol

close! clj

(close! q)

Closes the queue

closed? clj

(closed? q)

Returns true if the queue is closed

codec clj

(codec q)

Returns codec to be used with queue instance

underlying-queue clj

(underlying-queue q)

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
            block-size 1.0E9}})

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