0.3.2 • Published 2 years ago

@lindorm-io/amqp v0.3.2

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

@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