graphql-amqp-subscriptions

This package implements the PubSubEngine Interface from the graphql-subscriptions package.
It allows you to connect your subscriptions manager to a AMQP PubSub mechanism.

This package is influenced by graphql-redis-subscriptions and graphql-rabbitmq-subscriptions.


graphql-subscriptions@2

If you are using graphql-subscriptions@2.x please use graphql-amqp-subscriptions@2.

Basic usage

``javascript
import { AMQPPubSub } from 'graphql-amqp-subscriptions';
import amqp from 'amqplib';

amqp.connect('amqp://guest:guest@localhost:5672?heartbeat=30')
.then(conn => {
const pubsub = new AMQPPubSub({
connection: conn
/* exchange: {
name: 'exchange',
type: 'topic',
options: {
durable: false,
autoDelete: true
}
},
queue: {
name: 'queue'
options: {
exclusive: true,
durable: true,
autoDelete: true
},
unbindOnDispose: false;
deleteOnDispose: false;
} */
});
// Use the pubsub instance from here on
})
.catch(err => {
console.error(err);
});
`

Benefits

- Reusing existing amqplib Connection
- Reusing channels (one for subscriptions, one for publishing)
- Performance/Ressource-usage benefits on AMQP (RabbitMQ) because of the aforementioned reasons more info
- Using Topic Exchange (e.g. you publish to agreements.eu.berlin.headstore and subscribe to agreements.eu.#) more info

Debug

This package uses Debug.
To show the logs run your app with the environment variable DEBUG="AMQPPubSub"

Tests

You'll need to have a local AMPQ instance such as RabbitMQ running to run tests.

If you have Docker, you can run:

`bash
docker run --hostname my-rabbit -p 5672:5672 rabbitmq:3
`

Then

`bash
npm test
``