0.1.11 • Published 2 years ago

@lindorm-io/koa-amqp v0.1.11

Weekly downloads
-
License
AGPL-3.0-or-later
Repository
-
Last release
2 years ago

@lindorm-io/koa-amqp

AMQP middleware for @lindorm-io/koa applications

Installation

npm install --save @lindorm-io/koa-amqp

Peer Dependencies

This package has the following peer dependencies:

Usage

Amqp Connection Middleware

import amqp from "amqplib";
import { AmqpConnection } from "@lindorm-io/amqp";

const amqpConnection = new AmqpConnection({ ...options });

koaApp.addMiddleware(amqpMiddleware(amqpConnection));

const amqp: amqp = await ctx.connection.amqp.connect();

Repository Middleware

koaApp.addMiddleware(messageBusMiddleware(YourMessageBus));

await ctx.messageBus.publish([yourMessage]);
0.1.11

2 years ago

0.1.10

2 years ago

0.1.2

2 years ago

0.1.8

2 years ago

0.1.7

2 years ago

0.1.9

2 years ago

0.1.4

2 years ago

0.1.3

2 years ago

0.1.6

2 years ago

0.1.5

2 years ago

0.1.1

2 years ago

0.0.20

2 years ago

0.0.21

2 years ago

0.1.0

2 years ago

0.0.17

2 years ago

0.0.18

2 years ago

0.0.19

2 years ago

0.0.15

2 years ago

0.0.16

2 years ago

0.0.10

3 years ago

0.0.11

3 years ago

0.0.12

3 years ago

0.0.13

3 years ago

0.0.14

2 years ago

0.0.9

3 years ago

0.0.8

3 years ago

0.0.5

3 years ago

0.0.7

3 years ago

0.0.6

3 years ago

0.0.4

3 years ago

0.0.3

3 years ago

0.0.2

3 years ago