apgapg / azure-queue-wrapper Goto Github PK

This package provides a convenient wrapper for working with Azure Storage Queues in Node.js applications.

You can install the package using npm:

npm install azure-queue-wrapper

1. Initialize Azure Queue Wrapper Import the package and initialize the Azure Queue Wrapper in your code:

const { ProcessAzureQueueMessage, AddMessageToQueue } = require('azure-queue-wrapper');

2. Process Messages from Queue Use the @ProcessAzureQueueMessage decorator to process messages from a queue based on a specified time interval:

class MyQueueProcessor {
@ProcessAzureQueueMessage(connectionString,{ queue: 'my-queue', timeInterval: [5, 'seconds'], maxRetry: 3, deadLetterQueue: 'poison-queue-name' }) // Replace with your queue name, retries count(default: 3), interval (default:5 seconds) and deadLetterQueue name( default: <queue-name>-poison)
async processQueueMessage(message) { // Replace with your function name
// Your message processing logic here
}
}

The following time units are supported for specifying the time interval:

• Seconds
• Minutes
• Hours
• Days
• Weeks

The time interval should be specified as a tuple with a numeric value and the unit, for example, (5, 'seconds') for 5 seconds, (10, 'minutes') for 10 minutes, and so on. 3. Add Message to Queue Use the @AddMessageToQueue decorator to add a message to a queue:

class MyQueueProducer {
@AddMessageToQueue(connectionString)
async addMessageToQueue(queueName, message) { // Your function name
// Your message adding logic here
return { status: 'success' };
}
}

Contributing Contributions are welcome! Please feel free to submit issues or pull requests on the GitHub repository.

This project is licensed under the MIT License.