3.2.9 • Published 1 year 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
1 year ago
3.2.8
1 year ago
3.2.5
2 years ago
3.2.4
2 years ago
3.2.3
2 years ago
3.2.2
2 years ago
3.2.1
2 years ago
3.1.2
2 years ago
3.0.7
2 years ago
3.0.6
2 years ago
3.0.5
2 years ago
3.0.4
2 years ago
3.0.3
2 years ago
3.0.2
2 years ago
3.0.0
2 years ago
3.0.1
2 years ago
2.0.1
2 years ago
2.0.0
2 years ago
1.1.8
2 years ago
1.1.7
2 years ago
1.1.6
2 years ago
1.1.5
2 years ago
1.1.0
2 years ago
1.0.0
2 years ago