@mediaadmin/service-bus v1.0.7

@mediaadmin/service-bus

It's a NodeJS library for use Azure Service Bus

Installation

Use the package manager npm to install.

npm i --save @mediaadmin/service-bus

Usage

Define the environment variables

Create

To create a new queue on azure service bus you can use the next function

(alias) const create: (queueName: string) => Promise<boolean>

Example:

const { create } = require('@mediaadmin/service-bus');

create('xiaomi').then(res => {
    console.log(res); // true : false
});

Delete

To delete a queue on azure service bus you can use the next function

(alias) const remove: (queueName: string) => Promise<boolean>

Example:

const { remove } = require('@mediaadmin/service-bus');

remove('xiaomi').then(res => {
    console.log(res); // true : false
});

Send Message

To send a message to specific queue on azure service bus you can use the next function

(alias) const send: (queue: string, message: any) => Promise<void>

Example:

const { send } = require('@mediaadmin/service-bus');

send('xiaomi', { model: 'MI 9T pro' });

Recive Messages

To recibe a messages from specific queue on azure service bus you can use the next function

(alias) const receive: (queue: string, handler: any) => Promise<void>

Example:

const { receive } = require('@mediaadmin/service-bus');

receive('xiaomi', message => {
    console.log(message); // any (json)
})
.catch(console.error);