0.3.2 • Published 2 years 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
2 years ago
0.3.1
2 years ago
0.2.16
2 years ago
0.2.15
2 years ago
0.2.14
2 years ago
0.3.0
2 years ago
0.2.18
2 years ago
0.2.17
2 years ago
0.2.13
2 years ago
0.2.12
2 years ago
0.2.11
2 years ago
0.2.10
2 years ago
0.2.7
2 years ago
0.2.6
2 years ago
0.2.9
2 years ago
0.2.8
2 years ago
0.2.3
2 years ago
0.2.2
2 years ago
0.2.5
2 years ago
0.2.4
2 years ago
0.2.1
3 years ago
0.2.0
3 years ago
0.1.0
3 years ago