`mq`

Message queue clients (RabbitMQ, Kafka, SQS, NATS).

Load with: use mq

Quick example

use mq

result = rbne("./example")
prn(result)

Functions

RabbitMQ

rbne(url)

Creates a new instance. Takes url.

rbco(c)

Connects. Takes c.

rbdc(c)

Performs the operation. Takes c.

rbde(c, q, og)

Decodes. Takes c, q, og.

rbsb(c, ex, rk, msg)

Performs the operation. Takes c, ex, rk, msg.

rbcu(c, q, cb)

Performs the operation. Takes c, q, cb.

rbrk(c, q, ct)

Performs the operation. Takes c, q, ct.

Kafka

kfne(br)

Creates a new instance. Takes br.

kfpr(c, tp)

Processes or prints. Takes c, tp.

kfsd(c, key, vl)

Performs the operation. Takes c, key, vl.

kfcs(c, gid, tps)

Performs the operation. Takes c, gid, tps.

kfpf(c)

Performs the operation. Takes c.

kfcm(c, pt)

Performs the operation. Takes c, pt.

AWS SQS

sqsne(rg, ak, sk)

Creates a new instance. Takes rg, ak, sk.

sqsmk(c, nm, og)

Creates a new instance. Takes c, nm, og.

sqssm(c, url, msg)

Performs the operation. Takes c, url, msg.

sqsrc(c, url, og)

Performs the operation. Takes c, url, og.

sqsdl(c, url, rh)

Deletes an item. Takes c, url, rh.

NATS

ntne(url)

Creates a new instance. Takes url.

ntco(c)

Connects. Takes c.

ntdc(c)

Performs the operation. Takes c.

ntpb(c, sb, msg)

Performs the operation. Takes c, sb, msg.

ntsb(c, sb, cb)

Performs the operation. Takes c, sb, cb.

ntun(c, sb)

Performs the operation. Takes c, sb.

ntrq(c, sb, msg, tm)

Performs the operation. Takes c, sb, msg, tm.

JetStream

ntjs(c, nm)

Performs the operation. Takes c, nm.

ntjsc(c, nm, sb, cb)

Performs the operation. Takes c, nm, sb, cb.

Generic

mqne(tp, cn)

Creates a new instance. Takes tp, cn.

mqsnd(q, msg)

Performs the operation. Takes q, msg.

mqrcv(q, cb)

Performs the operation. Takes q, cb.

Notes

Message queue - publish, subscribe, acknowledge.