nodejs rabbitjs簡易パブサブ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 */ });