amqp

Pub/Sub and Queue implementation using amqp protocol. You can use it with RabbitMQ or any other AMQP compatible server.

Usage

{
  "services": {
    "queue": {
      "type": "AMQPQueue",
      "endpoint": "amqp://localhost:5672",
      "queue": "webda-test",
      "maxConsumers": 1
    },
    "pubsub": {
      "type": "AMQPPubSub",
      "endpoint": "amqp://localhost:5672",
      "channel": "webda-test-pub",
      "maxConsumers": 1
    }
  }
}