deepstream.io-msg-amqp

A deepstream.io message connector for amqp This connector uses the npm amqp package. Please have a look there for detailed options.

##Basic Setup

plugins:
  message:
    name: amqp
    options:
      host: ${AMQP_HOST}
      port: ${AMQP_PORT}

var Deepstream = require( 'deepstream.io' ),
    AMQPConnector = require( 'deepstream.io-msg-amqp' ),
    server = new Deepstream();

server.set( 'messageConnector', new AMQPConnector( {
  port: 5672,
  host: 'localhost'
}));

server.start();