kubets

KubeTS - A typesafe wrapper for KubeMQ.

A KubeMQ Library for Typescript enables Typescript developers to communicate with KubeMQ server in a type-safe way!.

Prerequisites

KubeMQ is what powers the library! NPM Package is the best way to install this package.

Examples

First steps

yarn add kubets
Or
npm i -s kubets

Initialising the classes.

import { ReceiverType, GeneralReceiver, GeneralSender } from 'kubets'
const reciever = new GeneralReceiver({
    host: '127.0.0.1',
    port: 50000,
    channel: 'testing_Command_channel',
    client: 'hello-world-receiver',
    type: ReceiverType.Query,
    defaultTimeout: 50000
});
const sender = new GeneralSender({
    host: '127.0.0.1',
    port: 50000,
    channel: 'testing_Command_channel',
    client: 'hello-world-sender',
    type: ReceiverType.Query,
    defaultTimeout: 50000
});

Listening to a message via RPC.

import { Request, Response } from 'kubets';
receiver.subscribe(async (cmd: Request) => {
    console.log('Received a message.')
    // ...
 
    const res = new Response();
    res.setBody(Buffer.from('example body!'))
    await receiver.ack(cmd, res);
})

Sending a message via RPC.

import { Request } from 'kubets'
 
const request = new Request();
request.setBody(Buffer.from(JSON.stringify({
    data: 'xxxx',
    moreData: 50513
})));
request.setTimeout(10000);
 
const res = await sender.send(request);
res.xxx