Skip to content
Plugin with interface to AMQP protocol - RabbitMQ
Branch: master
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
.circleci
.gitignore
LICENSE
README.md
index.js
package.json
test.js

README.md

fastify-amqp

Fastify AMQP connection plugin wrapper to amqplib, to use with RabbitMQ

Installation

This is a Node.js module available through the npm registry. It can be installed using the npm or yarn command line tools.

npm install fastify-amqp --save

Tests

npm install
npm test

Usage

const fastify = require('fastify')()

fastify.register(require('fastify-amqp'), {
  host: 'localhost',
  // the default value is 5672
  port: 5672,
  // the default value is 5672
  user: 'guest',
  // the default value is 5672
  pass: 'guest'
})

fastify.get('/', function (request, reply) {
  const channel = this.amqpChannel

  const queue = 'hello'
  const msg = 'Hello world'

  channel.assertQueue(queue, {
    durable: false
  })
  
  channel.sendToQueue(queue, Buffer.from(msg))
  reply.send(' [x] Sent ' + msg)
})

fastify.listen(3000, err => {
  if (err) throw err
})

Reference

This plugin is just a wrapper to amqplib.

Contains:

  • amqpConn API to here
  • amqpChannel API to here

Dependencies

Dev Dependencies

  • fastify: Fast and low overhead web framework, for Node.js
  • pre-commit: Automatically install pre-commit hooks for your npm modules.
  • standard: JavaScript Standard Style
  • tap: A Test-Anything-Protocol library for JavaScript
  • typescript: TypeScript is a language for application scale JavaScript development

License

MIT

You can’t perform that action at this time.