nats-streaming-ps v1.0.5

SIMPLE pub/sub using nats-streaming

Simple example

const { NatsWrapper, Publisher, Subscriber } = require('nats-streaming-ps');

const clusterId = ''
const clientId  = ''
const natsHost = ''

const  main = async () => {
    const stan = await NatsWrapper.connect(clusterId, clientId, {
        url: natsHost
    })


    // Creating subscribe
    Subscribe.create(stan, { 
        onMessage(data, msg) {
            console.log("Yuppp!, my message has been consumed", data)
        }
    }).subscribe({
        target: 'my-job',
        group: 'grp-01',
        options: {
            // ....   
        }
    })

    // Creating publisher
    Publisher.create(stan, { 
        onSended(msgId) {
            console.log("Yuppp!, my message has been sended", msgId)
        }
    }).publish({
        action: 'my-job',
        payload: {
            params: {
                // ....
            },
            data: {
                // ....
            }
        }
    })


}