3.2.9 • Published 3 years ago
@alliedpayment/message-bridge v3.2.9
@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