diff --git a/server/service/bufferService.js b/server/service/bufferService.js index c98dde759..255c3db9f 100755 --- a/server/service/bufferService.js +++ b/server/service/bufferService.js @@ -80,7 +80,16 @@ class BufferService { }); continue; } - await operation(buffer); + try { + await operation(buffer); + } catch (error) { + this.logger.error({ + message: error.message, + service: this.SERVICE_NAME, + method: "flushBuffers", + stack: error.stack, + }); + } this.buffers[bufferName] = []; } this.logger.info({