1.2.1 • Published 1 month ago

graphql-amqp-subscriptions v1.2.1

Weekly downloads
3,951
License
MIT
Repository
github
Last release
1 month ago

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.

npm Version npm Downloads CircleCI Known Vulnerabilities

Basic usage

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:

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

Then

npm test
1.2.1

1 month ago

1.2.0

1 year ago

1.1.2

2 years ago

1.1.1

2 years ago

1.1.0

2 years ago

1.0.9

2 years ago

1.0.8

2 years ago

1.0.7

2 years ago

1.0.6

3 years ago

1.0.5

3 years ago

1.0.4

4 years ago

1.0.3

4 years ago

1.0.2

4 years ago

1.0.1

4 years ago

1.0.0

4 years ago

0.0.1

4 years ago