ywadi / crimsonq Goto Github PK

One Message to Multi Consumer Queue with persistence and Queue Stages. Crimson Queue allows you to have multiple consumers listening on topics and receive a copy of a message that targets its topic providing multiple consumers for a queue message and complex message routing. Utilizes the same methodology as MQTT topic routing but with queue stages and persistence.,

License: MIT License

Go 88.13% Shell 11.87%

go message-queue mqtt queue

crimsonq's People

Contributors

Stargazers

Watchers

Forkers

ola-alkhateeb ramcoelho

crimsonq's Issues

Add Log Rotate for Docker

Setup logrotate(8) for the docker images

Change Basic Auth to JWT

Basic Auth for REST API changed to JWT token

Enable TLS support for RESP

Need to enable TLS support on the RESP interface, using the Redcon TLS

Create an MQTT Bridge in and out

Allow for mqtt messages to be bridged into CrimsonQ and placed in consumer queue and allow to bridge out

Enable HTTPS for REST api

Verbose Logs

Logs need more verbose messages and cover more areas

Add HTTP Route to handle get detail info for consumer

Provide the data for a consumer

Name
Topics
Last Read Data
Queue Status Totals
Consumer Concurrency

Get a single Message's Data as JSON (OFF PULL)

Add the ability to preview what is in a single message and return it as JSON.

CLI AUTH error no response

No response is sent from CLI if auth is incorrect

Override default username and password with ENV

Allow to override the username and password with an ENV defined username and password.
Add this to docker-compose as well

Unit Tests

Add unit tests to the repo

Allow for crimsonq settingst to be on a host machine volume for easy edit access

Web UI

Develop a Web UI to manage consumers and message statuses

Create a custom CLI over RESP

Create a custom CLI to replace the usage of Redis-Cli

Empty queue pull returns RESP error

The RESP should respond with null not an error response.

Consumer Considered Inactive

If the producer has not created any messages for a consumer, and the consumer client is connected, there should be a heart beat to extend the inactive state