reauthTime check (#415)

faucetsdn · Aug 10, 2022 · 4a9118b · 4a9118b
1 parent 3d390b9
commit 4a9118b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pubber/src/main/java/daq/pubber/MqttPublisher.java b/pubber/src/main/java/daq/pubber/MqttPublisher.java
@@ -380,7 +380,7 @@ private void sendMessage(String deviceId, String mqttTopic,
   private void checkAuthentication(String deviceId) {
     String authId = isProxyDevice(deviceId) ? configuration.gatewayId : deviceId;
     Instant reauthTime = reauthTimes.get(authId);
-    if (reauthTime != null && Instant.now().isBefore(reauthTime)) {
+    if (reauthTime == null || (reauthTime != null && Instant.now().isBefore(reauthTime))) {
       return;
     }
     warn("Authentication retry time reached for " + authId);