dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

TbSqlBlockingQueue does not log an error on InterruptedException because of normal lifecycle

Browse Source
This commit is contained in:
Sergey Matvienko 2023-12-11 16:52:45 +01:00
parent da7cc60856
commit 70f7c8a132
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
dao/src/main/java/org/thingsboard/server/dao/sql/TbSqlBlockingQueue.java
View File

@ -84,7 +84,6 @@ public class TbSqlBlockingQueue<E> implements TbSqlQueue<E> {
} }
} }
} catch (Throwable t) { } catch (Throwable t) {
log.error("[{}] Failed to save {} entities", logName, entities.size(), t);
try { try {
stats.incrementFailed(entities.size()); stats.incrementFailed(entities.size());
entities.forEach(entityFutureWrapper -> entityFutureWrapper.getFuture().setException(t)); entities.forEach(entityFutureWrapper -> entityFutureWrapper.getFuture().setException(t));
@ -94,6 +93,8 @@ public class TbSqlBlockingQueue<E> implements TbSqlQueue<E> {
if (t instanceof InterruptedException) { if (t instanceof InterruptedException) {
log.info("[{}] Queue polling was interrupted", logName); log.info("[{}] Queue polling was interrupted", logName);
break; break;
} else {
log.error("[{}] Failed to save {} entities", logName, entities.size(), t);
} }
} finally { } finally {
entities.clear(); entities.clear();