queue-slayer

An in-jvm processing pattern for parallelized work off of a queue.

License

License

GroupId

GroupId

com.blacklocus.queue-slayer
ArtifactId

ArtifactId

qs-worker-core
Last Version

Last Version

0.3.4
Release Date

Release Date

Type

Type

jar
Description

Description

queue-slayer
An in-jvm processing pattern for parallelized work off of a queue.
Project URL

Project URL

https://github.com/blacklocus/queue-slayer
Project Organization

Project Organization

BlackLocus
Source Code Management

Source Code Management

https://github.com/blacklocus/queue-slayer.git

Download qs-worker-core

How to add to project

<!-- https://jarcasting.com/artifacts/com.blacklocus.queue-slayer/qs-worker-core/ -->
<dependency>
    <groupId>com.blacklocus.queue-slayer</groupId>
    <artifactId>qs-worker-core</artifactId>
    <version>0.3.4</version>
</dependency>
// https://jarcasting.com/artifacts/com.blacklocus.queue-slayer/qs-worker-core/
implementation 'com.blacklocus.queue-slayer:qs-worker-core:0.3.4'
// https://jarcasting.com/artifacts/com.blacklocus.queue-slayer/qs-worker-core/
implementation ("com.blacklocus.queue-slayer:qs-worker-core:0.3.4")
'com.blacklocus.queue-slayer:qs-worker-core:jar:0.3.4'
<dependency org="com.blacklocus.queue-slayer" name="qs-worker-core" rev="0.3.4">
  <artifact name="qs-worker-core" type="jar" />
</dependency>
@Grapes(
@Grab(group='com.blacklocus.queue-slayer', module='qs-worker-core', version='0.3.4')
)
libraryDependencies += "com.blacklocus.queue-slayer" % "qs-worker-core" % "0.3.4"
[com.blacklocus.queue-slayer/qs-worker-core "0.3.4"]

Dependencies

compile (7)

Group / Artifact Type Version
com.fasterxml.jackson.core : jackson-databind jar 2.3.0
com.google.guava : guava jar 15.0
com.blacklocus.queue-slayer : qs-core jar 0.3.4
com.github.rholder : moar-concurrent jar 1.0.2
commons-configuration : commons-configuration jar 1.10
commons-io : commons-io jar 2.4
com.github.rholder.fauxflake : fauxflake-core jar 1.0.0

test (3)

Group / Artifact Type Version
org.slf4j : slf4j-simple jar 1.7.5
org.mockito : mockito-core jar 1.9.5
junit : junit jar 4.11

Project Modules

There are no modules declared in this project.

(experimental...)

queue-slayer

A micro pattern for thread-parallelized processing of messages off of a queue.

Build Status

Usage

repositories {
    mavenCentral()
}

dependencies {

    compile 'com.blacklocus.queue-slayer:qs-core:0.5.1'

    // for AWS SQS message providers
    compile 'com.blacklocus.queue-slayer:qs-aws:0.5.1'
}

other dependency syntax on mvnrepository.com

A quick look:

// Reads in work items
MessageProvider provider = ...;

// Processes work items
MessageHandler handler = ...;

// Provides worker threads which process work items through the MessageHandler logic.
ExecutorService executor = ...;

// The orchestration of these components together.
MessageQueueReader reader = new MessageQueueReader(provider, handler, executor);

// The current thread will read in the items through the MessageProvider
// and pass them to the threads running the work items through the MessageHandler
// logic. The worker threads themselves are provided by the ExecutorService.
reader.run();

License

Copyright 2013-2015 BlackLocus under the Apache 2.0 license

com.blacklocus.queue-slayer

BlackLocus

Versions

Version
0.3.4
0.3.3
0.3.2
0.3.1
0.3.0
0.2.1
0.1.2