Disq

Disk-backed queue for fun and profit

License

License

Categories

Categories

Net
GroupId

GroupId

net.intelie.disq
ArtifactId

ArtifactId

disq
Last Version

Last Version

0.13
Release Date

Release Date

Type

Type

jar
Description

Description

Disq
Disk-backed queue for fun and profit
Source Code Management

Source Code Management

http://github.com/intelie/disq/tree/master

Download disq

How to add to project

<!-- https://jarcasting.com/artifacts/net.intelie.disq/disq/ -->
<dependency>
    <groupId>net.intelie.disq</groupId>
    <artifactId>disq</artifactId>
    <version>0.13</version>
</dependency>
// https://jarcasting.com/artifacts/net.intelie.disq/disq/
implementation 'net.intelie.disq:disq:0.13'
// https://jarcasting.com/artifacts/net.intelie.disq/disq/
implementation ("net.intelie.disq:disq:0.13")
'net.intelie.disq:disq:jar:0.13'
<dependency org="net.intelie.disq" name="disq" rev="0.13">
  <artifact name="disq" type="jar" />
</dependency>
@Grapes(
@Grab(group='net.intelie.disq', module='disq', version='0.13')
)
libraryDependencies += "net.intelie.disq" % "disq" % "0.13"
[net.intelie.disq/disq "0.13"]

Dependencies

compile (1)

Group / Artifact Type Version
org.slf4j : slf4j-api jar 1.7.25

test (9)

Group / Artifact Type Version
org.slf4j : slf4j-simple jar 1.7.25
net.intelie.introspective : introspective jar 0.1
org.mongodb : bson jar 3.11.0-beta4
de.ruedigermoeller : fst jar 2.51
junit : junit jar 4.10
org.mockito : mockito-all jar 1.9.5
org.assertj : assertj-core jar 3.6.2
com.google.guava : guava jar 20.0
com.google.code.gson : gson jar 2.7

Project Modules

There are no modules declared in this project.

Disq

Simple, fast, disk-backed queue and task executor for Java 8.

Features:

  • PersistentQueue<T>: a disk-backed blocking queue;
  • Disq<T>: a disk-backed task executor.

Usage

Disq is available through Maven Central repository, just add the following dependency to your pom.xml file:

<dependency>
    <groupId>net.intelie.disq</groupId>
    <artifactId>disq</artifactId>
    <version>0.12</version>
</dependency>

Then, you can use it like that:

Processor<String> processor = x -> {
    System.out.println(x);
};

Disq<String> disq = Disq.builder(processor)
        .setDirectory("my_queue")
        .setThreadCount(8)
        .setMaxSize(1024 * 1024 * 1024) //1GB
        .build();

disq.submit("some item");
disq.submit("another item");
net.intelie.disq

Intelie

Versions

Version
0.13
0.12
0.11
0.10
0.9
0.8
0.7
0.6
0.5
0.4
0.3
0.2
0.1