@@ -263,19 +263,24 @@ var config = {
263263 requireAckResponse: true // Add this option to wait response from Fluentd certainly
264264};
265265var fluentTransport= require (' fluent-logger' ).support .winstonTransport ();
266+ var fluent= new fluentTransport (' mytag' , config);
266267var logger= winston .createLogger ({
267- transports: [new fluentTransport ( ' mytag ' , config) ,new (winston .transports .Console )()]
268+ transports: [fluent ,new (winston .transports .Console )()]
268269});
269270
270- logger .on (' logging' , (transport ,level ,message ,meta )=> {
271- if (meta .end && transport .sender && transport .sender .end ) {
272- transport .sender .end ();
273- }
271+ logger .on (' flush' , ()=> {
272+ console .log (" flush" );
273+ })
274+
275+ logger .on (' finish' , ()=> {
276+ console .log (" finish" );
277+ fluent .sender .end (" end" , {}, ()=> {})
274278});
275279
276280logger .log (' info' ,' this log record is sent to fluent daemon' );
277281logger .info (' this log record is sent to fluent daemon' );
278- logger .info (' end of log message' , { end: true });
282+ logger .info (' end of log message' );
283+ logger .end ();
279284` ` `
280285
281286**NOTE** If you use` winston@2 ` , you can use` fluent- logger@2.7 .0 ` or earlier. If you use` winston@3 ` , you can use` fluent- logger@2.8 ` or later.