sbis3-rabbit-subscribe

Модуль подписки на события облака SBIS3

Использование

var
   Rabbit = require('sbis3-rabbit-subscribe'),
   connection = Rabbit({
      amqp: 'amqp://cloud_service:cloud_service@test-eventmq.unix.tensor.ru', // адресс брокера сообщений
      cloud: 'dev-cloud.sbis.ru' // облако, на события которого необходимо подписаться
   }),
   options = {
         queue: 'my_queue_' + process.pid // имя очереди(опционально)
   };

connection.on('eventName1', function (msg) {
   console.log('eventName: %s', msg);
});

connection.on('eventName2', function (msg) {
   console.log('eventName2: %s', msg);
});

connection.on('error', function (err) {
   console.log(err);
});

connection.on('close', function () {
   console.log('Connection closed');
});

rabbit.subscribe('eventName1', options);
rabbit.subscribe('eventName2', options);

Описание

Параметры amqp и cloud можно получить с помощью модуля sbis3-cloud-config

amqp - Ядро.Асинхронные сообщения.БрокерыПодпискиНаСобытия

cloud - это hostname от параметра СервисАдминистрирования.Адрес

API

subscribe('eventName'[,options])

eventName - строка, имя события на которое необходимо подписаться

options - опциональный параметр для конфигурирования exchange и queue

По умолчанию:

{
   queue: os.hostname() + '_' + process.pid  + '_' + timeInNanosec,
   exOptions: {
      durable: false
   },
   qOptions: {
      autoDelete: true,
      durable: false
   }
}

События

eventName

публикует событие с именем эвента, на который была осуществлена подписка

message - сообщение от кролика

error

error - ошибка

close