Revert removal of runtime exception

3 years ago · 1303975c05
1 changed files with 1 additions and 1 deletions
--- a/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCoreConsumerService.java
+++ b/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCoreConsumerService.java
@ -624,7 +624,7 @@ public class DefaultTbCoreConsumerService extends AbstractConsumerService<ToCore
            callback.onSuccess();
        } catch (Exception e) {
            log.warn("[{}] Failed to process device activity message for device [{}]", tenantId.getId(), deviceId.getId(), e);
-            callback.onFailure(e);
+            callback.onFailure(new RuntimeException("Failed to update device activity for device [" + deviceId.getId() + "]!", e));
        }
    }