nodejs rabbitjs 간단한 pub sub rabbitmq

Question

NodeJS 및 RabbitMQ의 새로운 기능. 나는 술집에서 메시지를받을 때 간단한 술집과 술집을하고 서브의 출력을 저장하려고 시도하고 있습니다.

sub.js :

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

    }); 
    }); 

pub.js :

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

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

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

    }) 

이 잘 작동하고 내가 콘솔 실행에 (sub.pipe에서 (process.stdout))를 표준 출력 메시지가 sub.js,하지만 내 질문은 어떻게이 개체와 함께 일할 수 있습니까? 출력을 변수에 저장하고 다른 함수로 전달할 수 있습니까?

Answer 1

소켓은 node streams입니다. 따라서 표준 출력으로 배관하는 대신에 다음과 같이 읽을 수 있습니다.

sub.on('data', function(message) { /** Do something with message */ });