Browse Source
Merge pull request #3798 from YevhenBondarenko/fix-api-usage
fix NPE (skip usage state messages for deleted tenants)
pull/3799/head
Igor Kulikov
6 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with
6 additions and
1 deletions
-
application/src/main/java/org/thingsboard/server/service/apiusage/DefaultTbApiUsageStateService.java
-
application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCoreConsumerService.java
|
|
|
@ -147,6 +147,11 @@ public class DefaultTbApiUsageStateService implements TbApiUsageStateService { |
|
|
|
public void process(TbProtoQueueMsg<ToUsageStatsServiceMsg> msg, TbCallback callback) { |
|
|
|
ToUsageStatsServiceMsg statsMsg = msg.getValue(); |
|
|
|
TenantId tenantId = new TenantId(new UUID(statsMsg.getTenantIdMSB(), statsMsg.getTenantIdLSB())); |
|
|
|
|
|
|
|
if (tenantProfileCache.get(tenantId) == null) { |
|
|
|
return; |
|
|
|
} |
|
|
|
|
|
|
|
TenantApiUsageState tenantState; |
|
|
|
List<TsKvEntry> updatedEntries; |
|
|
|
Map<ApiFeature, ApiUsageStateValue> result; |
|
|
|
|
|
|
|
@ -297,7 +297,7 @@ public class DefaultTbCoreConsumerService extends AbstractConsumerService<ToCore |
|
|
|
try { |
|
|
|
handleUsageStats(msg, callback); |
|
|
|
} catch (Throwable e) { |
|
|
|
log.warn("[{}] Failed to process usge stats: {}", id, msg, e); |
|
|
|
log.warn("[{}] Failed to process usage stats: {}", id, msg, e); |
|
|
|
callback.onFailure(e); |
|
|
|
} |
|
|
|
}); |
|
|
|
|