This repository was archived by the owner on Feb 11, 2020. It is now read-only.
Commit 8d134ab 1 parent 09def4f commit 8d134ab Copy full SHA for 8d134ab
File tree 3 files changed +12
-4
lines changed
3 files changed +12
-4
lines changed Original file line number Diff line number Diff line change @@ -17,7 +17,7 @@ var rewriteTopic = function(topic) {
17
17
function Client ( conn , server ) {
18
18
this . connection = conn ;
19
19
this . server = server ;
20
- this . logger = server . logger ;
20
+ this . logger = server . logger . child ( { client : this } , true ) ;
21
21
this . subscriptions = { } ;
22
22
23
23
this . nextId = 0 ;
@@ -226,7 +226,6 @@ Client.prototype.handleConnect = function(packet) {
226
226
var that = this , logger = this . logger , client = this . connection ;
227
227
228
228
this . id = packet . clientId ;
229
- logger = that . logger . child ( { client : this } ) ;
230
229
231
230
if ( this . id . length > 23 ) {
232
231
client . connack ( {
Original file line number Diff line number Diff line change @@ -38,6 +38,7 @@ var defaults = {
38
38
* - `baseRetryTimeout`, the retry timeout for the exponential
39
39
* backoff algorithm (default is 1s).
40
40
* - `logger`, the options for Bunyan.
41
+ * - `logger.childOf`, the parent Bunyan logger.
41
42
* - `persitance`, the options for the persistence.
42
43
* A sub-key `factory` is used to specify what persitance
43
44
* to use.
@@ -75,7 +76,15 @@ function Server(opts, callback) {
75
76
callback = callback || function ( ) { } ;
76
77
77
78
this . clients = { } ;
78
- this . logger = bunyan . createLogger ( this . opts . logger ) ;
79
+
80
+ if ( this . opts . logger . childOf ) {
81
+ this . logger = this . opts . logger . childOf ;
82
+ delete this . opts . logger . childOf ;
83
+ delete this . opts . logger . name ;
84
+ this . logger = this . logger . child ( this . opts . logger ) ;
85
+ } else {
86
+ this . logger = bunyan . createLogger ( this . opts . logger ) ;
87
+ }
79
88
80
89
var that = this ;
81
90
Original file line number Diff line number Diff line change @@ -38,7 +38,7 @@ global.moscaSettings = function() {
38
38
return {
39
39
port : nextPort ( ) ,
40
40
logger : {
41
- name : "moscaTests" ,
41
+ childOf : globalLogger ,
42
42
level : 60
43
43
}
44
44
} ;
You can’t perform that action at this time.
0 commit comments