Security News
The Unpaid Backbone of Open Source: Solo Maintainers Face Increasing Security Demands
Solo open source maintainers face burnout and security challenges, with 60% unpaid and 60% considering quitting.
A lightweight message queue for Node.js that requires no dedicated queue server. Just a Redis server.
tl;dr: If you run a Redis server and currently use Amazon SQS or a similar message queue you might as well use this fast little replacement. Using a shared Redis server multiple Node.js processes can send / receive messages.
sendMessage
and receiveMessage
method.Note: RSMQ uses the Redis EVAL command (LUA scripts) so the minimum Redis version is 2.6+.
id
that you can use to delete the message.sendMessage
method will return the id
for a sent message.receiveMessage
method will return an id
along with the message and some stats.createQueue
and receiveMessage
methods described below for optional parameters like visibility timeout and delay.npm install rsmq
To keep the core of RSMQ small additional functionality is available as modules:
RedisSMQ = require("rsmq");
rsmq = new RedisSMQ( {host: "127.0.0.1", port: 6379, ns: "rsmq"} );
Parameters for RedisSMQ via an options object:
host
(String): optional (Default: "127.0.0.1") The Redis serverport
(Number): optional (Default: 6379) The Redis portoptions
(Object): optional (Default: {}) The Redis https://github.com/mranney/node_redis#rediscreateclientport-host-options options
object.client
(RedisClient): optional A existing redis client instance. host
and server
will be ignored.ns
(String): optional (Default: "rsmq") The namespace prefix used for all keys created by RSMQPlease look at the Methods section for optional parameters when creating a queue.
rsmq.createQueue({qname:"myqueue"}, function (err, resp) {
if (resp===1) {
console.log("queue created")
}
});
rsmq.sendMessage({qname:"myqueue", message:"Hello World"}, function (err, resp) {
if (resp) {
console.log("Message sent. ID:", resp);
}
});
rsmq.receiveMessage({qname:"myqueue"}, function (err, resp) {
if (resp.id) {
console.log("Message received.", resp)
}
else {
console.log("No messages for me...")
}
});
rsmq.deleteMessage({qname:"myqueue", id:"dhoiwpiirm15ce77305a5c3a3b0f230c6e20f09b55"}, function (err, resp) {
if (resp===1) {
console.log("Message deleted.")
}
else {
console.log("Message not found.")
}
});
Change the visibility timer of a single message.
The time when the message will be visible again is calculated from the current time (now) + vt
.
Parameters:
qname
(String): The Queue name.id
(String): The message id.vt
(Number): The length of time, in seconds, that this message will not be visible. Allowed values: 0-9999999 (around 115 days)Returns:
1
if successful, 0
if the message was not found.Create a new queue.
Parameters:
qname
(String): The Queue name. Maximum 160 characters; alphanumeric characters, hyphens (-), and underscores (_) are allowed.vt
(Number): optional (Default: 30) The length of time, in seconds, that a message received from a queue will be invisible to other receiving components when they ask to receive messages. Allowed values: 0-9999999 (around 115 days)delay
(Number): optional (Default: 0) The time in seconds that the delivery of all new messages in the queue will be delayed. Allowed values: 0-9999999 (around 115 days)maxsize
(Number): optional (Default: 65536) The maximum message size in bytes. Allowed values: 1024-65536Returns:
1
Parameters:
qname
(String): The Queue name.id
(String): message id to delete.Returns:
1
if successful, 0
if the message was not found.Deletes a queue and all messages.
Parameters:
qname
(String): The Queue name.Returns:
1
Get queue attributes, counter and stats
Parameters:
qname
(String): The Queue name.Returns an object:
vt
: The visibility timeout for the queue in secondsdelay
: The delay for new messages in secondsmaxsize
: The maximum size of a message in bytestotalrecv
: Total number of messages received from the queuetotalsent
: Total number of messages sent to the queuecreated
: Timestamp (epoch in seconds) when the queue was createdmodified
: Timestamp (epoch in seconds) when the queue was last modified with setQueueAttributes
msgs
: Current number of messages in the queuehiddenmsgs
: Current number of hidden / not visible messages. A message can be hidden while "in flight" due to a vt
parameter or when sent with a delay
List all queues
Returns an array:
["qname1", "qname2"]
Receive the next message from the queue and delete it.
Important: This method deletes the message it receives right away. There is no way to receive the message again if something goes wrong while working on the message.
Parameters:
qname
(String): The Queue name.Returns an object:
message
: The message's contents.id
: The internal message id.sent
: Timestamp of when this message was sent / created.fr
: Timestamp of when this message was first received.rc
: Number of times this message was received.Note: Will return an empty object if no message is there
Receive the next message from the queue.
Parameters:
qname
(String): The Queue name.vt
(Number): optional (Default: queue settings) The length of time, in seconds, that the received message will be invisible to others. Allowed values: 0-9999999 (around 115 days)Returns an object:
message
: The message's contents.id
: The internal message id.sent
: Timestamp of when this message was sent / created.fr
: Timestamp of when this message was first received.rc
: Number of times this message was received.Note: Will return an empty object if no message is there
Sends a new message.
Parameters:
qname
(String)message
(String)delay
(Number): optional (Default: queue settings) The time in seconds that the delivery of the message will be delayed. Allowed values: 0-9999999 (around 115 days)Returns:
id
: The internal message id.
Sets queue parameters.
Parameters:
qname
(String): The Queue name.vt
(Number): optional * The length of time, in seconds, that a message received from a queue will be invisible to other receiving components when they ask to receive messages. Allowed values: 0-9999999 (around 115 days)delay
(Number): optional The time in seconds that the delivery of all new messages in the queue will be delayed. Allowed values: 0-9999999 (around 115 days)maxsize
(Number): optional The maximum message size in bytes. Allowed values: 1024-65536Note: At least one attribute (vt, delay, maxsize) must be supplied. Only attributes that are supplied will be modified.
Returns an object:
vt
: The visibility timeout for the queue in seconds
delay
: The delay for new messages in seconds
maxsize
: The maximum size of a message in bytes
totalrecv
: Total number of messages received from the queue
totalsent
: Total number of messages sent to the queue
created
: Timestamp (epoch in seconds) when the queue was created
modified
: Timestamp (epoch in seconds) when the queue was last modified with setQueueAttributes
msgs
: Current number of messages in the queue
hiddenmsgs
: Current number of hidden / not visible messages. A message can be hidden while "in flight" due to a vt
parameter or when sent with a delay
Disconnect the redis client. This is only useful if you are using rsmq within a script and want node to be able to exit.
see the CHANGELOG
Name | Description |
---|---|
node-cache | Simple and fast Node.js internal caching. Node internal in memory cache like memcached. |
redis-tagging | A Node.js helper library to make tagging of items in any legacy database (SQL or NoSQL) easy and fast. |
redis-sessions | An advanced session store for Node.js and Redis |
rsmq-worker | Helper to implement a worker based on RSMQ (Redis Simple Message Queue). |
redis-notifications | A Redis based notification engine. It implements the rsmq-worker to safely create notifications and recurring reports. |
task-queue-worker | A powerful tool for background processing of tasks that are run by making standard http requests. |
obj-schema | Simple module to validate an object by a predefined schema |
connect-redis-sessions | A connect or express middleware to use redis sessions that lets you handle multiple sessions per user_id. |
systemhealth | Node module to run simple custom checks for your machine or it's connections. It will use redis-heartbeat to send the current state to Redis. |
soyer | Soyer is small lib for serverside use of Google Closure Templates with node.js. |
grunt-soy-compile | Compile Goggle Closure Templates (SOY) templates including the handling of XLIFF language files. |
backlunr | A solution to bring Backbone Collections together with the browser fulltext search engine Lunr.js |
Please see the LICENSE.md file.
0.7.2
FAQs
A really simple message queue based on Redis
The npm package rsmq receives a total of 21,069 weekly downloads. As such, rsmq popularity was classified as popular.
We found that rsmq demonstrated a not healthy version release cadence and project activity because the last version was released a year ago. It has 2 open source maintainers collaborating on the project.
Did you know?
Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.
Security News
Solo open source maintainers face burnout and security challenges, with 60% unpaid and 60% considering quitting.
Security News
License exceptions modify the terms of open source licenses, impacting how software can be used, modified, and distributed. Developers should be aware of the legal implications of these exceptions.
Security News
A developer is accusing Tencent of violating the GPL by modifying a Python utility and changing its license to BSD, highlighting the importance of copyleft compliance.