rabbit-queue
Advanced tools
Comparing version 5.0.0 to 5.0.1
export default function getLogger(component: any): { | ||
debug: (...args: any[]) => Promise<any>; | ||
warn: (...args: any[]) => Promise<any>; | ||
info: (...args: any[]) => Promise<any>; | ||
error: (...args: any[]) => Promise<any>; | ||
trace: (...args: any[]) => Promise<any>; | ||
debug: (...args: any[]) => any; | ||
warn: (...args: any[]) => any; | ||
info: (...args: any[]) => any; | ||
error: (...args: any[]) => any; | ||
trace: (...args: any[]) => any; | ||
}; |
"use strict"; | ||
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) { | ||
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); } | ||
return new (P || (P = Promise))(function (resolve, reject) { | ||
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } } | ||
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } } | ||
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); } | ||
step((generator = generator.apply(thisArg, _arguments || [])).next()); | ||
}); | ||
}; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
function getLogger(component) { | ||
const logger = (level) => (...args) => __awaiter(this, void 0, void 0, function* () { | ||
const rabbit = (yield Promise.resolve().then(() => require('./rabbit'))).default; | ||
const logger = (level) => (...args) => { | ||
const rabbit = require('./rabbit').default; | ||
if (rabbit.INSTANCE && rabbit.INSTANCE.listenerCount('log') > 0) { | ||
@@ -19,3 +10,3 @@ return void rabbit.INSTANCE.emit('log', component, level, ...args); | ||
console.log(`[${level}] ${component}`, ...args); | ||
}); | ||
}; | ||
return { | ||
@@ -22,0 +13,0 @@ debug: logger('debug'), |
@@ -88,3 +88,3 @@ "use strict"; | ||
} | ||
else if (!name.startsWith(`${prefix}_`)) { | ||
else if (!name.startsWith(`${prefix}_`) && !name.startsWith(`${prefix}.`)) { | ||
name = `${prefix}_${name}`; | ||
@@ -91,0 +91,0 @@ } |
{ | ||
"name": "rabbit-queue", | ||
"version": "5.0.0", | ||
"version": "5.0.1", | ||
"description": "AMQP/RabbitMQ queue management library.", | ||
@@ -5,0 +5,0 @@ "main": "js/index.js", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
91347
34
1068