mqemitter-cs

    1.0.1 • Public • Published

    mqemitter-cs

    Expose a MQEmitter via a simple client/server protocol

    See MQEmitter for the actual API.

    js-standard-style

    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

    Install

    npm i mqemitter-cs

    DownloadsWeekly Downloads

    3

    Version

    1.0.1

    License

    MIT

    Last publish

    Collaborators

    • avatar