diff --git a/lib/session.js b/lib/session.js index 34d86d5..74de912 100644 --- a/lib/session.js +++ b/lib/session.js @@ -760,6 +760,14 @@ function session(sock) { log.debug('larvitsmpp: lib/session.js: session() - sock.on(close) - socket closed'); }); + sock.on('error', function() { + log.warn('larvitsmpp: lib/session.js: session() - sock.on(error) - Socket error detected!'); + if (returnObj.enqLinkTimer) { + log.debug('larvitsmpp: lib/session.js: session() - sock.on(error) - enqLinkTimer found, clearing.'); + clearTimeout(returnObj.enqLinkTimer); + } + }); + return returnObj; }