Rqueue is an asynchronous task executor(worker) built for spring framework based on the spring framework's messaging library backed by Redis. It can be used as message broker as well, where all services code is in Spring.
implementation 'com.github.sonus21:rqueue-spring-boot-starter:2.6.1-RELEASE'
<dependency>
<groupId>com.github.sonus21</groupId>
<artifactId>rqueue-spring-boot-starter</artifactId>
<version>2.6.1-RELEASE</version>
</dependency>
implementation 'com.github.sonus21:rqueue-spring:2.6.1-RELEASE'
<dependency>
<groupId>com.github.sonus21</groupId>
<artifactId>rqueue-spring</artifactId>
<version>2.6.1-RELEASE</version>
</dependency>
EnableRqueue
on application config class@EnableRqueue
public class Application {
@Bean
public RedisConnectionFactory redisConnectionFactory() {
// return a redis connection factory
}
}
All messages need to be sent using RqueueMessageEnqueuer
bean's enqueueXXX
, enqueueInXXX
and enqueueAtXXX
methods. It has handful number of enqueue
, enqueueIn
, enqueueAt
methods, we
can use one of them based on the use case.
public class MessageService {
@AutoWired
private RqueueMessageEnqueuer rqueueMessageEnqueuer;
public void doSomething() {
rqueueMessageEnqueuer.enqueue("simple-queue", "Rqueue is configured");
}
public void createJOB(Job job) {
rqueueMessageEnqueuer.enqueue("job-queue", job);
}
// send notification in 30 seconds
public void sendNotification(Notification notification) {
rqueueMessageEnqueuer.enqueueIn("notification-queue", notification, 30 * 1000L);
}
// enqueue At example
public void createInvoice(Invoice invoice, Instant instant) {
rqueueMessageEnqueuer.enqueueAt("invoice-queue", invoice, instant);
}
// enqueue with priority, when sub queues are used as explained in the queue priority section.
enum SmsPriority {
CRITICAL("critical"),
HIGH("high"),
MEDIUM("medium"),
LOW("low");
private String value;
}
public void sendSms(Sms sms, SmsPriority priority) {
rqueueMessageEnqueuer.enqueueWithPriority("sms-queue", priority.value(), sms);
}
// enqueue periodic job, email should be sent every 30 seconds
public void sendPeriodicEmail(Email email) {
rqueueMessageEnqueuer.enqueuePeriodic("email-queue", invoice, 30_000);
}
}
Any method that's part of spring bean, can be marked as worker/message listener
using RqueueListener
annotation
@Component
@Slf4j
public class MessageListener {
@RqueueListener(value = "simple-queue")
public void simpleMessage(String message) {
log.info("simple-queue: {}", message);
}
@RqueueListener(value = "job-queue", numRetries = "3",
deadLetterQueue = "failed-job-queue", concurrency = "5-10")
public void onMessage(Job job) {
log.info("Job alert: {}", job);
}
@RqueueListener(value = "push-notification-queue", numRetries = "3",
deadLetterQueue = "failed-notification-queue")
public void onMessage(Notification notification) {
log.info("Push notification: {}", notification);
}
@RqueueListener(value = "sms", priority = "critical=10,high=8,medium=4,low=1")
public void onMessage(Sms sms) {
log.info("Sms : {}", sms);
}
@RqueueListener(value = "chat-indexing", priority = "20", priorityGroup = "chat")
public void onMessage(ChatIndexing chatIndexing) {
log.info("ChatIndexing message: {}", chatIndexing);
}
@RqueueListener(value = "chat-indexing-daily", priority = "10", priorityGroup = "chat")
public void onMessage(ChatIndexing chatIndexing) {
log.info("ChatIndexing message: {}", chatIndexing);
}
// checkin job example
@RqueueListener(value = "chat-indexing-weekly", priority = "5", priorityGroup = "chat")
public void onMessage(ChatIndexing chatIndexing,
@Header(RqueueMessageHeaders.JOB) com.github.sonus21.rqueue.core.Job job) {
log.info("ChatIndexing message: {}", chatIndexing);
job.checkIn("Chat indexing...");
}
}
Link: http://localhost:8080/rqueue
Rqueue is stable and production ready, it's processing thousands of messages daily in production deployments.
We would love to add your organization name here, if you're one of the Rqueue users, please raise a PR/issue .
You are most welcome for any pull requests for any feature/bug/enhancement. You would need Java8 and
gradle to start with. In root build.gradle
file comment out spring related versions, or set
environment variables for Spring versions.
Please format your code with Google Java formatter.
// springBootVersion = '2.2.0.RELEASE'
// springVersion = '5.2.0.RELEASE'
// springDataVersion = '2.2.0.RELEASE'
// microMeterVersion = '1.3.2'
Documentation: https://github.com/sonus21/rqueue/wiki
Issue tracker: https://github.com/sonus21/rqueue/issues
Maven Central:
StackOverflow: https://stackoverflow.com/tags/rqueue
Discord: https://discord.gg/2hgQZXS2
Project Progress: https://github.com/sonus21/rqueue/projects/3
© Sonu Kumar 2019-Instant.now
The Rqueue is released under version 2.0 of the Apache License.