Minimal example to reproduce <div class="snippet-clipboard-content notranslate pos

No this is a complex problem, due follow code (sender.js:108): <div class="snippet

<a class="user-mention notranslate" data-hovercard-type="user" data-hovercard-url="/us

when use as log4j appender, when fluentd is dead application also died about fluent-logger-node HOT 4 CLOSED

tantra35 commented on August 23, 2024

when use as log4j appender, when fluentd is dead application also died

from fluent-logger-node.

Comments (4)

edsiper commented on August 23, 2024

Looks like the problem is with Unix domain sockets, if you try the TCP connection does it works ?

from fluent-logger-node.

tantra35 commented on August 23, 2024

No this is a complex problem, due follow code (sender.js:108):

  var self = this;
  if( self._socket === null ){
    self._socket = new net.Socket();
    self._socket.setTimeout(self.timeout);
    self._socket.on('error', function(err){
      if( self._socket ){
        self._socket.destroy();
        self._socket = null;
//        callback(err);
        self._eventEmitter.emit('error', err); //if socket error happens this call print stack trace and kill node
      }
    });

So as expected when we use tcp connection we got the same error:

root@social:/home/ruslan/test/log# node ./test.js
[2015-09-23 18:11:14.888] [INFO] foo - this log record is sent to fluent daemon
events.js:141
      throw er; // Unhandled 'error' event
      ^

Error: connect ECONNREFUSED 127.0.0.1:24224
    at Object.exports._errnoException (util.js:837:11)
    at exports._exceptionWithHostPort (util.js:860:20)
    at TCPConnectWrap.afterConnect [as oncomplete] (net.js:1060:14)

from fluent-logger-node.

okkez commented on August 23, 2024

Application does not crash when we use plain FluentSender.
We should fix log4js.js in this library.

var logger = require('fluent-logger').createFluentSender('tag', {
  host: 'localhost',
  port: 5170,
  timeout: 3.0
});

setInterval(function() {
  latency = Math.round(Math.random() * 100);
  console.log('.');
  logger.emit('label', { message: 'this log record is sent to fluent daemon' });
}, 1000);