Skip to content
zhangwinningPublic

About

using ioredis create point to point mq

Topics

Resources

Stars

5 stars

Watchers

1 watching

Forks

Latest commit

 

History

15 Commits

Folders and files

NameName
Last commit message
Last commit date
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Build Status

ioredisMq

Another point to point mq's implementation based ioredis。inspired by rsmp

Install

npm install ioredisMq

Usage

const MQ = require("ioredisMq");
const mq = new MQ( {host: "127.0.0.1", port: 6379, ns: "rsmq"} );

createQueue

const resp = await mq.createQueue({qname: 'test'})

sendMessage

const resp = await mq.sendMessage({qname: 'test', message: 'hello world'})
if (resp) {
    console.log('sendMessage success')
}

receiveMessage

const resp = await mq.receiveMessage({qname: 'test'})
if (resp) {
    console.log(resp)   // { id: 'fjpelmxa4ssQUxNw1Xv2plsvoCPOsrXv', message: 'hello world' }
}

License

MIT

About

using ioredis create point to point mq

Topics

Resources

Stars

5 stars

Watchers

1 watching

Forks

Releases

Packages

Used by

Contributors

Languages