UdpClientProtocol bug fixes

openremote · Jul 2, 2019 · 73e580b · 73e580b
1 parent af34f4f
commit 73e580b
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/agent/src/main/java/org/openremote/agent/protocol/udp/UdpClientProtocol.java b/agent/src/main/java/org/openremote/agent/protocol/udp/UdpClientProtocol.java
@@ -173,7 +173,7 @@ protected synchronized void processNextCommand(String str, Consumer<String> resp
 
 
             client.sendMessage(str);
-            responseMonitor = executorService.scheduleWithFixedDelay(failureAction, 0, timeoutMillis);
+            responseMonitor = executorService.scheduleWithFixedDelay(failureAction, timeoutMillis, timeoutMillis);
         }
     }
 
@@ -400,7 +400,7 @@ protected void doLinkAttribute(AssetAttribute attribute, AssetAttribute protocol
             return;
         }
 
-        final String writeValue = Values.getMetaItemValueOrThrow(attribute, META_ATTRIBUTE_WRITE_VALUE, true, true)
+        final String writeValue = Values.getMetaItemValueOrThrow(attribute, META_ATTRIBUTE_WRITE_VALUE, false, true)
                 .map(Object::toString).orElse(null);
 
         final Integer pollingMillis = Values.getMetaItemValueOrThrow(attribute, META_POLLING_MILLIS, false, true)
@@ -529,7 +529,7 @@ protected Consumer<Value> createWriteConsumer(ClientAndQueue clientAndQueue, Att
             if (!TextUtil.isNullOrEmpty(writeValue)) {
                 if (str.isEmpty()) {
                     str = writeValue;
-                } else {
+                } else if (writeValue.contains(DYNAMIC_VALUE_PLACEHOLDER)) {
                     str = writeValue.replaceAll(DYNAMIC_VALUE_PLACEHOLDER_REGEXP, str);
                 }
             }