deepstream.io-msg-amqp

A deepstream.io cache 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-cache-amqp' ),
    server = new Deepstream();

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

server.start();