Commit 71f94358c4744060482695dae7a49cd0c2415238

Authored by Andrii Shvaika
1 parent f07d7441

Fix typos and added break statement

@@ -240,11 +240,11 @@ sql: @@ -240,11 +240,11 @@ sql:
240 ttl: 240 ttl:
241 ts: 241 ts:
242 enabled: "${SQL_TTL_TS_ENABLED:true}" 242 enabled: "${SQL_TTL_TS_ENABLED:true}"
243 - execution_interval_ms: "${SQL_TTL_TS_EXECUTION_INTERVAL:86400000}" # Number of miliseconds. The current value corresponds to one day 243 + execution_interval_ms: "${SQL_TTL_TS_EXECUTION_INTERVAL:86400000}" # Number of milliseconds. The current value corresponds to one day
244 ts_key_value_ttl: "${SQL_TTL_TS_TS_KEY_VALUE_TTL:0}" # Number of seconds 244 ts_key_value_ttl: "${SQL_TTL_TS_TS_KEY_VALUE_TTL:0}" # Number of seconds
245 events: 245 events:
246 enabled: "${SQL_TTL_EVENTS_ENABLED:true}" 246 enabled: "${SQL_TTL_EVENTS_ENABLED:true}"
247 - execution_interval_ms: "${SQL_TTL_EVENTS_EXECUTION_INTERVAL:86400000}" # Number of miliseconds. The current value corresponds to one day 247 + execution_interval_ms: "${SQL_TTL_EVENTS_EXECUTION_INTERVAL:86400000}" # Number of milliseconds. The current value corresponds to one day
248 events_ttl: "${SQL_TTL_EVENTS_EVENTS_TTL:0}" # Number of seconds 248 events_ttl: "${SQL_TTL_EVENTS_EVENTS_TTL:0}" # Number of seconds
249 debug_events_ttl: "${SQL_TTL_EVENTS_DEBUG_EVENTS_TTL:604800}" # Number of seconds. The current value corresponds to one week 249 debug_events_ttl: "${SQL_TTL_EVENTS_DEBUG_EVENTS_TTL:604800}" # Number of seconds. The current value corresponds to one week
250 250
@@ -391,6 +391,7 @@ public class JsonConverter { @@ -391,6 +391,7 @@ public class JsonConverter {
391 break; 391 break;
392 case JSON_V: 392 case JSON_V:
393 result.add(de.getKv().getKey(), JSON_PARSER.parse(de.getKv().getJsonV())); 393 result.add(de.getKv().getKey(), JSON_PARSER.parse(de.getKv().getJsonV()));
  394 + break;
394 default: 395 default:
395 throw new IllegalArgumentException("Unsupported data type: " + de.getKv().getType()); 396 throw new IllegalArgumentException("Unsupported data type: " + de.getKv().getType());
396 } 397 }
@@ -177,6 +177,7 @@ public abstract class TbAbstractGetAttributesNode<C extends TbGetAttributesNodeC @@ -177,6 +177,7 @@ public abstract class TbAbstractGetAttributesNode<C extends TbGetAttributesNodeC
177 } catch (IOException e) { 177 } catch (IOException e) {
178 throw new JsonParseException("Can't parse jsonValue: " + r.getJsonValue().get(), e); 178 throw new JsonParseException("Can't parse jsonValue: " + r.getJsonValue().get(), e);
179 } 179 }
  180 + break;
180 } 181 }
181 msg.getMetaData().putValue(r.getKey(), value.toString()); 182 msg.getMetaData().putValue(r.getKey(), value.toString());
182 } 183 }