employer
/
liza
1
0
Fork 0
Code Releases Activity

bin/delta-processor: Log DeltaProcessor#process errors

master
Mike Gerwitz 2019-12-09 14:51:44 -05:00 committed by Austin Schaffer
parent 2fb47cc993
commit e13a062f2b
1 changed files with 19 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
bin/delta-processor.ts
View File

@ -79,22 +79,31 @@ getMongoCollection( db, db_conf )
.then( ( mongoDao: MongoDeltaDao ) => { dao = mongoDao; } )
.then( _ => amqp_connection.connect() )
.then( _ =>
{
log.info( 'Liza Delta Processor' );
handleShutdown();
const processor = new DeltaProcessor( dao, publisher, emitter );
return new Promise( ( _resolve, reject ) =>
{
log.info( 'Liza Delta Processor' );
handleShutdown();
const processor = new DeltaProcessor( dao, publisher, emitter );
process_interval = setInterval( () =>
{
processor.process();
try
{
processor.process()
.catch( err => reject( err ) );
}
catch ( err )
{
reject( err );
}
dao.getErrorCount()
.then( count => { metrics.updateErrorCount( count ) } );
},
process_interval_ms,
);
}, process_interval_ms );
} );
} )
.catch( e =>
{