Commit1623b0a

authored

Merge pull request#136 from sphansekar-cci/reconnect-and-flush-on-reconnect

#135 Error handling and flushing message on reconnection.

2 parents7f75c65 +4aa6354 commit1623b0aCopy full SHA for 1623b0a

File tree

-0

lines changed

-0

lines changed

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -451,6 +451,7 @@ class FluentSender {`
`451`	`451`	`lettimeoutId=setTimeout(()=>{`
`452`	`452`	`this.internalLogger.info('Fluentd is reconnecting...');`
`453`	`453`	`this._connect(()=>{`
	`454`	`+this._flushSendQueue()`
`454`	`455`	`this.internalLogger.info('Fluentd reconnection finished!!');`
`455`	`456`	`});`
`456`	`457`	`},this.reconnectInterval);`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -32,6 +32,7 @@ module.exports = class FluentTransport extends Transport {`
`32`	`32`	`super(options);`
`33`	`33`	`this.name='fluent';`
`34`	`34`	`this.sender=newFluentSender(tag,options);`
	`35`	`+this.sender._setupErrorHandler();`
`35`	`36`	`}`
`36`	`37`
`37`	`38`	`log(info,callback){`

Comments

(0)