YUKI Hiroshi
null+****@clear*****
Fri Feb 1 10:48:43 JST 2013
YUKI Hiroshi 2013-02-01 10:48:43 +0900 (Fri, 01 Feb 2013) New Revision: ffdc6a78dc8ea1618a41bbf392e6e3de88eeb83e https://github.com/groonga/express-kotoumi/commit/ffdc6a78dc8ea1618a41bbf392e6e3de88eeb83e Log: Rename Receiver to FluentReceiver and receive messages from the backend as fluent packets Modified files: lib/backend/connection.js lib/backend/receiver.js Modified: lib/backend/connection.js (+2 -2) =================================================================== --- lib/backend/connection.js 2013-01-30 13:16:14 +0900 (23fadb4) +++ lib/backend/connection.js 2013-02-01 10:48:43 +0900 (c6d0a34) @@ -8,7 +8,7 @@ var EventEmitter = require('events').EventEmitter; var fluent = require('fluent-logger'); -var Receiver = require('./receiver').Receiver; +var FluentReceiver = require('./receiver').FluentReceiver; var DEFAULT_FLUENT_TAG = Connection.DEFAULT_FLUENT_TAG = @@ -59,7 +59,7 @@ Connection.prototype._initReceiver = function() { this.receiveHostName = this._params.receiveHostName || DEFAULT_RECEIVE_HOST_NAME; this.receivePort = this._params.receivePort; - var receiver = new Receiver(this.receivePort); + var receiver = new FluentReceiver(this.receivePort); receiver.listen((function() { this.receivePort = receiver.port; }).bind(this)); Modified: lib/backend/receiver.js (+6 -5) =================================================================== --- lib/backend/receiver.js 2013-01-30 13:16:14 +0900 (022165f) +++ lib/backend/receiver.js 2013-02-01 10:48:43 +0900 (8ac4510) @@ -52,14 +52,15 @@ MsgPackReceiver.prototype.close = function() { exports.MsgPackReceiver = MsgPackReceiver; -function Receiver(port) { +function FluentReceiver(port) { MsgPackReceiver.apply(this, arguments); } -Receiver.prototype = Object.create(MsgPackReceiver.prototype); +FluentReceiver.prototype = Object.create(MsgPackReceiver.prototype); -Receiver.prototype._onMessageReceive = function(message) { - this.emit(message.tag, message.data); +FluentReceiver.prototype._onMessageReceive = function(packet) { + MsgPackReceiver.prototype._onMessageReceive.call(this, packet); + this.emit(packet[0], packet[2]); }; -exports.Receiver = Receiver; +exports.FluentReceiver = FluentReceiver; -------------- next part -------------- HTML����������������������������...다운로드
