mqemitter-cs

Expose a MQEmitter via a simple client/server protocol

See MQEmitter for the actual API.

Install

$ npm install mqemitter-cs --save

Example

Server

'use strict'
 
var mqemitter = require('mqemitter')
var cs = require('./')
var net = require('net')
var main = mqemitter()
var server = net.createServer(cs.server(main))
 
server.listen(8800, function (err) {
  if (err) {
    throw new Error('unable to listen')
  }
  console.log('server listening on port', 8800)
})

Client: publishing

'use strict'
 
var cs = require('../')
var net = require('net')
var client = cs.client(net.connect(8800))
 
client.emit({
  topic: 'hello',
  args: process.argv.slice(2)
}, function () {
  client.close()
})

Client: subscribing

'use strict'
 
var cs = require('../')
var net = require('net')
var client = cs.client(net.connect(8800))
 
client.on('hello', function (chunk, cb) {
  console.log(chunk)
  cb()
})

MIT

MIT