JarCasting(experimental...)
queue-slayer
A micro pattern for thread-parallelized processing of messages off of a queue.
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
