igr / jrsmq Goto Github PK

View Code? Open in Web Editor NEW

35.0 8.0 13.0 186 KB

A lightweight message queue for Java that requires no dedicated queue server. Just a Redis server.

JavaScript 4.88% Java 95.12%

rsmq queue message-queue fifo redis java

jrsmq's Introduction

Redis Simple Message Queue

A lightweight message queue for Java that requires no dedicated queue server. Just a Redis server.

Java implementation of https://github.com/smrchy/rsmq.

Version

com.oblac:jrsmq:1.3.0

Java implementation notes

We are trying to follow the javascript contract as much as possible, including the method and properties naming.

Example

RedisSMQ rsmq = new RedisSMQ();

rsmq.createQueue()
    .qname("myqueue")
    .exec();

String id = rsmq.sendMessage()
                .qname("myqueue")
                .message("Hello World")
                .exec();

QueueMessage msg = rsmq.receiveMessage()
                        .qname("myqueue")
                        .exec();

rsmq.deleteQueue()
    .qname("myqueue")
    .exec();

rsmq.quit();

Enjoy!

jrsmq's People

Contributors

Stargazers

Watchers

Forkers

mdelapenya tunks ti-net vonvey michaeldreams ryanlavers 40a prakharkohq arthurccosta ccjcu sidorowartem plinerm bytechefhq

jrsmq's Issues

Add support for Sentinel API

Hey,

in order to use https://redis.io/topics/sentinel for HA jrsmq would need to get a master from the sentinel API.

Wdyt of adding support for it?

Thx!

Method not found when migrating to jedis4

Hi,
we are trying to version up dependencies to reduce the impacts of vulnerabilities.
and we encounter a problem when upgrading the jedis to version 4.
the error is:

An attempt was made to call a method that does not exist. The attempt was made from the following location:
    com.oblac.jrsmq.cmd.BaseQueueCmd.getQueue(BaseQueueCmd.java:51)
The following method did not exist:
    redis.clients.jedis.Transaction.time()Lredis/clients/jedis/Response;

does jrsmq has a plan to version its dependency with the newer release? (now it depends on jedis 2.10.2, which has vulnerabilities)
or if there are any recommended alternatives? (since I noticed the source code is not updated for a long term)

   > Could not get unknown property 'wedeployRepo' for object of type org.gradle.api.internal.artifacts.repositories.DefaultMavenArtifactRepository.

Warnings raised during build