queue-slayer

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

License

License

Categories

Categories

Realm Data Databases
GroupId

GroupId

com.blacklocus.queue-slayer
ArtifactId

ArtifactId

qs-realm-server
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-realm-server

How to add to project

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

Dependencies

compile (2)

Group / Artifact Type Version
com.yammer.dropwizard : dropwizard-core jar 0.6.2
com.blacklocus.queue-slayer : qs-worker-core jar 0.3.4

test (3)

Group / Artifact Type Version
junit : junit jar 4.11
com.blacklocus.queue-slayer : qs-worker-elasticsearch jar 0.3.4
com.blacklocus : jres-test jar 0.1.4

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