diff --git a/common/data/src/main/java/org/thingsboard/server/common/data/DataConstants.java b/common/data/src/main/java/org/thingsboard/server/common/data/DataConstants.java index 45aa39e8f2..d8c0599993 100644 --- a/common/data/src/main/java/org/thingsboard/server/common/data/DataConstants.java +++ b/common/data/src/main/java/org/thingsboard/server/common/data/DataConstants.java @@ -20,7 +20,6 @@ package org.thingsboard.server.common.data; */ public class DataConstants { - public static final String SYSTEM = "SYSTEM"; public static final String TENANT = "TENANT"; public static final String CUSTOMER = "CUSTOMER"; public static final String DEVICE = "DEVICE"; @@ -40,9 +39,6 @@ public class DataConstants { public static final String DEBUG_RULE_NODE = "DEBUG_RULE_NODE"; public static final String DEBUG_RULE_CHAIN = "DEBUG_RULE_CHAIN"; - public static final String ONEWAY = "ONEWAY"; - public static final String TWOWAY = "TWOWAY"; - public static final String IN = "IN"; public static final String OUT = "OUT"; diff --git a/dao/src/main/java/org/thingsboard/server/dao/event/CassandraBaseEventDao.java b/dao/src/main/java/org/thingsboard/server/dao/event/CassandraBaseEventDao.java index b2682ab2e2..590050f974 100644 --- a/dao/src/main/java/org/thingsboard/server/dao/event/CassandraBaseEventDao.java +++ b/dao/src/main/java/org/thingsboard/server/dao/event/CassandraBaseEventDao.java @@ -70,7 +70,7 @@ public class CassandraBaseEventDao extends CassandraAbstractSearchTimeDao 0){ + if (selectedTtl > 0) { insert.using(ttl(selectedTtl)); } ResultSetFuture resultSetFuture = executeAsyncWrite(tenantId, insert);