A file-backed async queue with auto-processing for Node.js
npm install local-log-queuebash
Using npm
npm install local-log-queue
Using yarn
yarn add local-log-queue
`
Usage
$3
`js
const LocalQueue = require('local-log-queue');
// Initialize queue with a callback
const queue = new LocalQueue(async (item) => {
console.log('Processing item:', item);
});
// Add items to the queue
queue.enqueue({ task: 'Task 1' });
queue.enqueue({ task: 'Task 2' });
queue.enqueue({ task: 'Task 3' });
`
Express with localQueue
`js
let express = require('express');
let LocalQueue = require('local-log-queue');
let app = express();
let port = 3000;
const queue = new LocalQueue((item)=>{
setTimeout(() => {
console.log('Processed item:', item);
}, 4000);
})
app.get('/', (req, res) => {
queue.enqueue({id:new Date().toISOString(),data : "Hello World"});
res.send('Hello World!');
});
app.listen(port, () => {
console.log(Example app listening at http://localhost:${port});
});
`
$3
`js
const LocalQueue = require('local-log-queue');
const messageQueue = new LocalQueue(async (item) => {
console.log('Message:', item.text);
});
// Add messages
messageQueue.enqueue({ text: 'Hello World!' });
messageQueue.enqueue({ text: 'Queue is working!' });
messageQueue.enqueue({ text: 'This is easy to understand!' });
`
2. Simple Task Queue
`js
const LocalQueue = require('local-log-queue');
const taskQueue = new LocalQueue(async (item) => {
console.log(Processing Task #${item.id}: ${item.name});
});
// Add tasks
taskQueue.enqueue({ id: 1, name: 'Wash dishes' });
taskQueue.enqueue({ id: 2, name: 'Clean room' });
taskQueue.enqueue({ id: 3, name: 'Do homework' });
`
3. Number Processing Queue
`js
const LocalQueue = require('local-log-queue');
const numberQueue = new LocalQueue(async (item) => {
console.log(Number squared: ${item.num * item.num});
});
// Add numbers
numberQueue.enqueue({ num: 2 });
numberQueue.enqueue({ num: 5 });
numberQueue.enqueue({ num: 10 });
``