nodejs rabbitjs простой паб суб rabbitmq

Новое для NodeJS и RabbitMQ. Я пытаюсь сделать простой pub и sub и сохранить выходные данные от sub, когда он получает сообщение от pub.

подводная лодка.js:

var context = require('rabbit.js').createContext();
var sub = context.socket('SUB');
context.on('ready', function() {
  sub.pipe(process.stdout);
  sub.connect('events', function() {

    });
  });

паб.js:

var context = require('rabbit.js').createContext();

var pub = context.socket('PUB')
  pub.connect('events', function() {

    pub.write(JSON.stringify({welcome: 'rabbit.js'}), 'utf8');

  })

Это работает хорошо, и я получаю сообщение stdout (от sub.труба (процесс.stdout)) на консоли выполняется sub.js, однако мой вопрос заключается в том, как я могу работать с этим объектом? Можно ли сохранить эти выходные данные в переменную и передать их в другую функцию?

1 ответ