/usr/local/lib/node_modules/pm2/node_modules/pm2-axon/lib/sockets
NameSizeModeActions
pub-emitter.js4680644editdlrm
pub.js11650644editdlrm
pull.js5230644editdlrm
push.js5020644editdlrm
rep.js13320644editdlrm
req.js19060644editdlrm
sock.js91210644editdlrm
sub-emitter.js18100644editdlrm
sub.js26670644editdlrm
Edit: /usr/local/lib/node_modules/pm2/node_modules/pm2-axon/lib/sockets/push.js (502B)
/** * Module dependencies. */ var roundrobin = require('../plugins/round-robin'); var queue = require('../plugins/queue'); var Socket = require('./sock'); /** * Expose `PushSocket`. */ module.exports = PushSocket; /** * Initialize a new `PushSocket`. * * @api private */ function PushSocket() { Socket.call(this); this.use(queue()); this.use(roundrobin({ fallback: this.enqueue })); } /** * Inherits from `Socket.prototype`. */ PushSocket.prototype.__proto__ = Socket.prototype;