Configuration parameter for default notification TTL

server/common/dao/src/main/java/org/kaaproject/kaa/server/common/dao/service/NotificationServiceImpl.java

@@ -34,6 +34,7 @@
 import java.util.List;
 import java.util.TimeZone;
 
+import javax.annotation.Resource;
 import org.apache.avro.generic.GenericRecord;
 import org.apache.commons.lang.StringUtils;
 import org.kaaproject.kaa.common.avro.GenericAvroConverter;
@@ -71,6 +72,10 @@ public class NotificationServiceImpl implements NotificationService {
 
     @Value("#{sql_dao[dao_max_wait_time]}")
     private int waitSeconds;
+
+    @Autowired(required = false)
+    private int ttl = 7 * 24 * 3600;
+
     @Autowired
     private TopicDao<Topic> topicDao;
     @Autowired
@@ -80,9 +85,6 @@ public class NotificationServiceImpl implements NotificationService {
     private NotificationDao<Notification> notificationDao;
     private EndpointNotificationDao<EndpointNotification> unicastNotificationDao;
 
-    @Value("#{properties[default_ttl]}")
-    private int TTL;
-
     @Override
     public NotificationSchemaDto saveNotificationSchema(NotificationSchemaDto notificationSchemaDto) {
         validateNotificationSchemaObject(notificationSchemaDto);
@@ -141,7 +143,7 @@ public UpdateNotificationDto<NotificationDto> saveNotification(NotificationDto d
 
             long currentTime = new GregorianCalendar(TimeZone.getTimeZone("UTC")).getTimeInMillis();
             Date expiredAt = dto.getExpiredAt();
-            dto.setExpiredAt(expiredAt != null ? expiredAt : new Date(currentTime + TTL));
+            dto.setExpiredAt(expiredAt != null ? expiredAt : new Date(currentTime + ttl));
             dto.setLastTimeModify(new Date(currentTime));
             NotificationDto notificationDto = saveNotificationAndIncTopicSecNum(dto);
             if (notificationDto != null) {
@@ -305,7 +307,7 @@ public UpdateNotificationDto<EndpointNotificationDto> saveUnicastNotification(En
             }
             long currentTime = new GregorianCalendar(TimeZone.getTimeZone("UTC")).getTimeInMillis();
             Date expiredAt = notificationDto.getExpiredAt();
-            notificationDto.setExpiredAt(expiredAt != null ? expiredAt : new Date(currentTime + TTL));
+            notificationDto.setExpiredAt(expiredAt != null ? expiredAt : new Date(currentTime + ttl));
             notificationDto.setLastTimeModify(new Date(currentTime));
 
             EndpointNotificationDto unicast = getDto(unicastNotificationDao.save(dto));

server/common/dao/src/test/resources/dao_test.properties

@@ -34,4 +34,5 @@ jdbc_port=9092
 # Path to logs root directory
 logs_root_dir=logs_root
 
-jdbc_url_db_name=h2
+jdbc_url_db_name=h2
+

server/node/src/main/resources/kaaNodeContext.xml

@@ -44,6 +44,10 @@
     <util:properties id="properties"
         location="classpath:/kaa-node.properties" />
 
+    <bean id="ttl" class="java.lang.Integer">
+        <constructor-arg value="#{properties[default_ttl]}" />
+    </bean>
+
     <!-- Node configuration from properties file -->
 
     <bean id="kaaNodeServerConfig" class="org.kaaproject.kaa.server.node.service.config.KaaNodeServerConfig">
@@ -59,7 +63,6 @@
         <property name="zkSleepTime" value="#{properties[zk_sleep_time]}" />
         <property name="zkIgnoreErrors" value="#{properties[zk_ignore_errors]}" />
     </bean>
-
     <!--Zookeeper client configuration-->
 
     <bean id="zkRetryPolicy" class="org.apache.curator.retry.RetryUntilElapsed">

server/node/src/test/resources/common-test-context.xml

@@ -41,6 +41,7 @@
     <util:properties id="properties"
         location="classpath:/kaa-node-test.properties" />
 
+
     <!-- Node configuration from properties file -->
 
     <bean id="kaaNodeServerConfig" class="org.kaaproject.kaa.server.node.service.config.KaaNodeServerConfig">