fix rabbit
This commit is contained in:
parent
71d5ad0ab9
commit
5c2c898d82
1 changed files with 1 additions and 1 deletions
|
|
@ -49,7 +49,7 @@ export async function init() {
|
||||||
|
|
||||||
let retries = 0;
|
let retries = 0;
|
||||||
|
|
||||||
function createConsumer( //----> consumer
|
async function createConsumer( //----> consumer
|
||||||
queue: string,
|
queue: string,
|
||||||
channel: amqp.Channel,
|
channel: amqp.Channel,
|
||||||
handler: (msg: amqp.ConsumeMessage) => Promise<boolean> | boolean,
|
handler: (msg: amqp.ConsumeMessage) => Promise<boolean> | boolean,
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue