const mq = new Rbtmq()
const config = {
exchanges: [
{
name: 'test-exchange',
type: 'topic',
options: {
autoDelete: true
},
queues: [
{
name: 'test-queue',
pattern: 'path',
options: {
autoDelete: true
}
}
]
}
]
}
const data = {test: 'data'}
const spy = sinon.spy(function (msg) {
assert.deepEqual(msg.body, data)
msg.ack(false)
})
await mq.boot(config)
await mq.sub('test-queue', spy)
await mq.pub('test-exchange', 'path', data)
-
Notifications
You must be signed in to change notification settings - Fork 0
avoronkin/rbtmq
Folders and files
Name | Name | Last commit message | Last commit date | |
---|---|---|---|---|
Repository files navigation
About
[WIP] AMQP client
Resources
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published