chore: loggin word
This commit is contained in:
parent
0c933745bd
commit
69c664087e
2 changed files with 2 additions and 2 deletions
|
|
@ -28,7 +28,7 @@ app.use(swaggerSpecs.basePath, router);
|
||||||
app.use(errorHandler);
|
app.use(errorHandler);
|
||||||
|
|
||||||
app.listen(PORT, "0.0.0.0", () =>
|
app.listen(PORT, "0.0.0.0", () =>
|
||||||
console.log(`Application is running on http://localhost:${PORT}`),
|
console.log(`[APP] Application is running on http://localhost:${PORT}`),
|
||||||
);
|
);
|
||||||
|
|
||||||
rabbitmq.init(amqHandler).catch((e) => console.error(e));
|
rabbitmq.init(amqHandler).catch((e) => console.error(e));
|
||||||
|
|
|
||||||
|
|
@ -12,7 +12,7 @@ export async function init(cb: (key: string, event: string) => boolean | Promise
|
||||||
channel.assertQueue(queue, { durable: true });
|
channel.assertQueue(queue, { durable: true });
|
||||||
channel.prefetch(1);
|
channel.prefetch(1);
|
||||||
|
|
||||||
console.log("[RabbitMQ] Listening for message...");
|
console.log("[AMQ] Listening for message...");
|
||||||
|
|
||||||
channel.consume(
|
channel.consume(
|
||||||
queue,
|
queue,
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue