If applied, this commit will update the latency log registration.

UellingtonDamasceno · Feb 8, 2024 · abd3172 · abd3172
1 parent d2e155f
commit abd3172
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/main/java/com/device/fot/virtual/controller/DefaultFlowCallback.java b/src/main/java/com/device/fot/virtual/controller/DefaultFlowCallback.java
@@ -99,7 +99,7 @@ public void deliveryComplete(IMqttDeliveryToken imdt) {
         MqttMessage deliveredMessage;
         try {
             deliveredMessage = imdt.getMessage();
-            if(deliveredMessage.getPayload().length == 0){
+            if(deliveredMessage == null || deliveredMessage.getPayload().length == 0){
                 return;
             }
             String messageContent = new String(deliveredMessage.getPayload());

diff --git a/src/main/java/com/device/fot/virtual/model/FoTSensor.java b/src/main/java/com/device/fot/virtual/model/FoTSensor.java
@@ -50,7 +50,7 @@ public FoTSensor(String deviceId,
         this.flow = false;
         this.running = false;
         this.random = new Random();
-        this.lastValue = minValue + random.nextInt() * (maxValue - minValue);
+        this.lastValue = (minValue <= 0 && maxValue <= 0) ? 0 : random.nextInt(minValue, maxValue);
         this.flowThreadName = this.buildFlowThreadName(deviceId, id);
     }
 
@@ -139,8 +139,8 @@ private Data<Integer> getDataFlow() throws InterruptedException {
     }
 
     public Integer getCurrentValue() {
-        //Integer variation = random.nextInt()* delta * (random.nextBoolean() ? 1 : -1);
-        //this.lastValue = Math.min(maxValue, Math.max(minValue, lastValue + variation));
+        Integer variation = delta * (random.nextBoolean() ? 1 : -1);
+        this.lastValue = Math.min(maxValue, Math.max(minValue, lastValue + variation));
         return lastValue;
     }