Moleculer-amqp NPM

moleculer-amqp

Task queue mixin for AMQP

Description

In order to divide RabbitMQ working queues and transport queues, this mixin was created. Also, it can be used with any moleculer transport you want.

Installation

$ npm install moleculer-amqp --save

Usage

Simple queue handler with validation

const amqpMixin = require('moleculer-amqp');

broker.createService({
  name: 'greeting',
  mixins: [amqpMixin('amqp://localhost')],
  actions: {
    sendGreeting: {
      params: {
        text: { type: 'string', min: 2 },
      },
      handler(ctx) {
        const { params: text } = ctx;
        return this.sendToQueue('greetings', text, { persistent: true });
      },
    },
  },
  queues: {
    // Assign to greeting queue
    greetings: {
      // Params validation with moleculer validator
      params: {
        text: { type: 'string' },
      },
      // Error strategy defines how to nack message on error
      errorStrategy: {
        requeue: false,
      },
      // Handler will receive decoded message on consume
      handler({ text }) {
        console.log('Hello from amqp with new message:', text);
      },
    },
  },
});