@indevweb/moleculer-transport-amazonsqs v0.0.2-dev

WIP Moleculer SQS Transport

Moleculer SQS is transport for use AWS SQS.

How To

1 Step

npm i @indevweb/moleculer-transport-amazonsqs

2 Step

Use a official AWS SQS Doc for more details of configuration.

const { ServiceBroker } = require("moleculer");
const SQSTransporter = require("@indevweb/moleculer-transport-amazonsqs");

const transport = new SQSTransporter({
    accessKeyId: "",
    secretAccessKey: "",
    apiVersion: '',
    region: '',
})


// Create a ServiceBroker
const broker = new ServiceBroker({
    transporter: transport,
});

// Define a service
broker.createService({
    name: "calcular",
    actions: {
       async add(ctx) {
           const result = ctx.params.a + ctx.params.b;
            return result
        }
    }

});


broker.start()
    // Call the service
    .then(() => broker.call("calcular.add", { a: 5, b: 3 }))
    // Print the response
    .then(res => {
        console.log("5 + 3 =", res)

    })
    .catch(err => {
        console.error("Error occured!" ,${err.message})

    });