Better handle error
This commit is contained in:
@@ -413,8 +413,10 @@ export class MessagesEventBus {
|
|||||||
if (needsEmit) {
|
if (needsEmit) {
|
||||||
try {
|
try {
|
||||||
this.emitter.emit('events', batch)
|
this.emitter.emit('events', batch)
|
||||||
} catch (e) {
|
} catch (e: any) {
|
||||||
logger.error(e)
|
logger.error(e, {
|
||||||
|
context: `${LOGGER_CONTEXT}: process latest events`,
|
||||||
|
})
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user