@@ -19,7 +19,7 @@ require(pathToBootstrap);
1919
2020const analyticsLoggingService = injector . resolve < IFileLogService > (
2121 FileLogService ,
22- { logFile }
22+ { logFile } ,
2323) ;
2424analyticsLoggingService . logData ( { message : "Initializing AnalyticsBroker." } ) ;
2525
@@ -32,7 +32,7 @@ let trackingQueue: Promise<void> = Promise.resolve();
3232
3333const sendDataForTracking = async ( data : ITrackingInformation ) => {
3434 trackingQueue = trackingQueue . then ( ( ) =>
35- analyticsBroker . sendDataForTracking ( data )
35+ analyticsBroker . sendDataForTracking ( data ) ,
3636 ) ;
3737 await trackingQueue ;
3838} ;
@@ -55,7 +55,7 @@ const killCurrentProcessGracefully = () => {
5555process . on ( "message" , async ( data : ITrackingInformation ) => {
5656 analyticsLoggingService . logData ( {
5757 message : `analytics-broker-process received message of type: ${ JSON . stringify (
58- data
58+ data ,
5959 ) } `,
6060 } ) ;
6161
@@ -66,12 +66,17 @@ process.on("message", async (data: ITrackingInformation) => {
6666 analyticsLoggingService . logData ( {
6767 message : `analytics-broker-process will send ${ DetachedProcessMessages . ProcessFinishedTasks } message` ,
6868 } ) ;
69- process . send ( DetachedProcessMessages . ProcessFinishedTasks , ( ) => {
70- analyticsLoggingService . logData ( {
71- message : `analytics-broker-process sent ${ DetachedProcessMessages . ProcessFinishedTasks } message and will exit gracefully now` ,
72- } ) ;
73- killCurrentProcessGracefully ( ) ;
74- } ) ;
69+ process . send (
70+ DetachedProcessMessages . ProcessFinishedTasks ,
71+ null ,
72+ null ,
73+ ( ) => {
74+ analyticsLoggingService . logData ( {
75+ message : `analytics-broker-process sent ${ DetachedProcessMessages . ProcessFinishedTasks } message and will exit gracefully now` ,
76+ } ) ;
77+ killCurrentProcessGracefully ( ) ;
78+ } ,
79+ ) ;
7580 }
7681
7782 return ;
0 commit comments