@xtreamr/ds_rabbitmq

RabbitMQ queues package

Config

Sample of config:

{
  "messageQueue": {
    "protocol": "amqp",
    "hostname": "127.0.0.1",
    "port": 5672,
    "username": "guest",
    "password": "guest",
    "vhost": "/",
    "heartbeat": 120,
    "prefetch": 2,
    "consumeFailed": true
  },
  "rabbitmq": {
    "attemptTime": 1000
  }
}

The field "messageQueue" also includes two optional fields:

{
  "exchange": {
    "durable": true,
    "autoDelete": false
  },
  "queue": {
    "durable": true,
    "autoDelete": false
  },
  "message": {
    "persistent": true
  }
}

They default to the example values.