0.1.11 • Published 2 years 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
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