amqp-producer

AMQP Producer wrapper for emails

Package is able to connect to AMQP server and send messages to queue. Messages will be send as encoded JSON. The main approach is to send encoded JSON as message to queue in which it should be decoded and send an email based on given JSON

Usage

const {MailerProducerService} = require('amqp-producer');

// Create mailerProducer instance
const mailerProducerConfig = [
    'amqp',
    'localhost',
    5672,
    'guest',
    'guest',
    '/',
    'email_queue'
];
const mailerProducer = new MailerProducerService(...mailerProducerConfig);


const start = async () => {
    // Start mailProducer
    await mailerProducer.start();
    
    // Send message to queue 
    const emailConfig = [
        '[e-mail]',
        ['[e-mail]', '[e-mail]'],
        'My Subject',
        'My Text'
    ];
    mailerProducer.sendEmailMsg(...emailConfig);
    
    // Stop mailProducer 
    mailerProducer.stop();
};

start();

API

MailerProducerService

An implementation of AMQP Producer

Kind: global class

• MailerProducerService
  • new MailerProducerService(protocol, hostname, port, username, password, vhost, queue)
  • .start() ⇒ Promise.<void>
  • .stop()
  • .sendEmailMsg(to, cc, subject, text)

new MailerProducerService(protocol, hostname, port, username, password, vhost, queue)

Param	Type
protocol	string
hostname	string
port	number
username	string
password	string
vhost	string
queue	string

mailerProducerService.start() ⇒ Promise.<void>

Setup connection, channel and queue

Kind: instance method of MailerProducerService

mailerProducerService.stop()

Close connection

Kind: instance method of MailerProducerService

mailerProducerService.sendEmailMsg(to, cc, subject, text)

Send email msg to queue

Kind: instance method of MailerProducerService

Param	Type
to	string
cc	Array.<string>
subject	string
text	string