3.2.9 • Published 3 years ago

@alliedpayment/message-bridge v3.2.9

Weekly downloads
-
License
MIT
Repository
github
Last release
3 years ago

@alliedpayment/message-bridge

Bridge to send RabbitMQ messages to Allied's queues.

Allied uses NServiceBus which requires special headers.

This bridge wraps ampqlib and providing publisher API that handles the needed headers.

Notes:

  • environment variable RABBITMQ_CONNECTION_STRING is expected to be set

example:

"amqp://guest:guest@localhost:5672"

Usage

import bus, { IMessage } from "../src/index";

const queue = "test";

const run = async () => {
  const message: IMessage = {
    $type: "Allied.Data.NServiceBus.Messages.Test.TestMessage",
    payload: {
      id: "123",
      test: "test",
    },
  };
  try {
    const result = await bus.send(queue, message);
    log.info(`send result: ${result ? "successful" : "failed"}`);
    process.exit(0);
  } catch (error) {
    log.error(error);
    process.exit(1);
  }
};

run();
3.2.9

3 years ago

3.2.8

3 years ago

3.2.5

3 years ago

3.2.4

3 years ago

3.2.3

3 years ago

3.2.2

3 years ago

3.2.1

3 years ago

3.1.2

3 years ago

3.0.7

3 years ago

3.0.6

3 years ago

3.0.5

3 years ago

3.0.4

3 years ago

3.0.3

3 years ago

3.0.2

3 years ago

3.0.0

3 years ago

3.0.1

3 years ago

2.0.1

3 years ago

2.0.0

3 years ago

1.1.8

3 years ago

1.1.7

3 years ago

1.1.6

3 years ago

1.1.5

3 years ago

1.1.0

3 years ago

1.0.0

3 years ago