diff --git a/lib/zmq.js b/lib/zmq.js index 7e0b1bf9..268b3724 100644 --- a/lib/zmq.js +++ b/lib/zmq.js @@ -1,6 +1,7 @@ 'use strict' const Zmq = require('zmq') const debug = require('debug')('skyring:transports:zmq') +const monitor = require('debug')('skyring:transports:zmq:monitor') const connections = new Map() const METHODS = new Set(['push', 'pub']) const ZMQ_DEBUG = !!process.env.ZMQ_DEBUG @@ -68,7 +69,7 @@ function startMonitor(socket) { for (const evt of MONITOR_EVENTS) { debug(`adding monitor event ${evt} for socket`) socket.on(evt, (fd, addr) => { - debug(`socket ${evt}: ${addr}`) + monitor(`socket ${evt}: ${addr}`) }) } }