0.1.11 • Published 5 months ago
@lindorm-io/koa-amqp v0.1.11
@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
5 months ago
0.1.10
5 months ago
0.1.2
6 months ago
0.1.8
6 months ago
0.1.7
6 months ago
0.1.9
5 months ago
0.1.4
6 months ago
0.1.3
6 months ago
0.1.6
6 months ago
0.1.5
6 months ago
0.1.1
11 months ago
0.0.20
1 year ago
0.0.21
1 year ago
0.1.0
1 year ago
0.0.17
1 year ago
0.0.18
1 year ago
0.0.19
1 year ago
0.0.15
1 year ago
0.0.16
1 year ago
0.0.10
1 year ago
0.0.11
1 year ago
0.0.12
1 year ago
0.0.13
1 year ago
0.0.14
1 year ago
0.0.9
1 year ago
0.0.8
1 year ago
0.0.5
1 year ago
0.0.7
1 year ago
0.0.6
1 year ago
0.0.4
2 years ago
0.0.3
2 years ago
0.0.2
2 years ago