0.3.2 • Published 6 months ago
@lindorm-io/amqp v0.3.2
@lindorm-io/amqp
AMQP connection and message bus for lindorm.io packages.
Installation
npm install --save @lindorm-io/mongo
Usage
AMQP Connection
const connection = new AmqpConnection({
hostname: "amqp.location.com",
port: 5672,
});
await connection.connect();
Message Bus
const messageBus = new MessageBus({
connection,
logger,
});
const callback = async () => {};
await messageBus.subscribe([
{ callback, queue: "1", routingKey: "default.1" },
{ callback, queue: "2", routingKey: "default.2" },
]);
await messageBus.publish([
{
id: randomUUID(),
delay: 0,
mandatory: true,
routingKey: "default.1",
type: "type",
},
]);
0.3.2
6 months ago
0.3.1
11 months ago
0.2.16
1 year ago
0.2.15
1 year ago
0.2.14
1 year ago
0.3.0
1 year ago
0.2.18
1 year ago
0.2.17
1 year ago
0.2.13
1 year ago
0.2.12
1 year ago
0.2.11
1 year ago
0.2.10
1 year ago
0.2.7
1 year ago
0.2.6
1 year ago
0.2.9
1 year ago
0.2.8
1 year ago
0.2.3
1 year ago
0.2.2
1 year ago
0.2.5
1 year ago
0.2.4
1 year ago
0.2.1
2 years ago
0.2.0
2 years ago
0.1.0
2 years ago