Finish processing hp events

2024-11-21 11:53:56 +02:00 · 2024-11-21 11:53:56 +02:00 · 8c16f8c2da
commit 8c16f8c2da
parent be25681416
1 changed files with 1 additions and 0 deletions
--- a/application/src/main/java/org/thingsboard/server/service/edge/rpc/KafkaEdgeGrpcSession.java
+++ b/application/src/main/java/org/thingsboard/server/service/edge/rpc/KafkaEdgeGrpcSession.java
@ -116,6 +116,7 @@ public class KafkaEdgeGrpcSession extends AbstractEdgeGrpcSession {
    public void processHighPriorityEvents() {
        isHighPriorityProcessing = true;
        super.processHighPriorityEvents();
+        isHighPriorityProcessing = false;
    }

    @Override