diff --git a/application/src/main/java/org/thingsboard/server/service/ttl/EventsCleanUpService.java b/application/src/main/java/org/thingsboard/server/service/ttl/EventsCleanUpService.java
index e2d6842241..34cb2e1320 100644
--- a/application/src/main/java/org/thingsboard/server/service/ttl/EventsCleanUpService.java
+++ b/application/src/main/java/org/thingsboard/server/service/ttl/EventsCleanUpService.java
@@ -29,6 +29,9 @@ import org.thingsboard.server.service.ttl.AbstractCleanUpService;
 @Service
 public class EventsCleanUpService extends AbstractCleanUpService {
 
+    public static final String RANDOM_DELAY_INTERVAL_MS_EXPRESSION =
+            "#{T(org.apache.commons.lang3.RandomUtils).nextLong(0, ${sql.ttl.events.execution_interval_ms})}";
+
     @Value("${sql.ttl.events.events_ttl}")
     private long ttl;
 
@@ -45,7 +48,7 @@ public class EventsCleanUpService extends AbstractCleanUpService {
         this.eventService = eventService;
     }
 
-    @Scheduled(initialDelayString = "#{T(org.apache.commons.lang3.RandomUtils).nextLong(0, ${sql.ttl.events.execution_interval_ms})}", fixedDelayString = "${sql.ttl.events.execution_interval_ms}")
+    @Scheduled(initialDelayString = RANDOM_DELAY_INTERVAL_MS_EXPRESSION, fixedDelayString = "${sql.ttl.events.execution_interval_ms}")
     public void cleanUp() {
         if (ttlTaskExecutionEnabled && isSystemTenantPartitionMine()) {
             eventService.cleanupEvents(ttl, debugTtl);
diff --git a/application/src/test/java/org/thingsboard/server/service/ttl/EventsCleanUpServiceTest.java b/application/src/test/java/org/thingsboard/server/service/ttl/EventsCleanUpServiceTest.java
index b2eb9f39f1..422d5ef358 100644
--- a/application/src/test/java/org/thingsboard/server/service/ttl/EventsCleanUpServiceTest.java
+++ b/application/src/test/java/org/thingsboard/server/service/ttl/EventsCleanUpServiceTest.java
@@ -17,20 +17,34 @@ package org.thingsboard.server.service.ttl;
 
 import lombok.extern.slf4j.Slf4j;
 import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
 
 import static org.hamcrest.MatcherAssert.assertThat;
 import static org.hamcrest.Matchers.greaterThanOrEqualTo;
+import static org.hamcrest.Matchers.is;
 import static org.hamcrest.Matchers.lessThanOrEqualTo;
+import static org.thingsboard.server.service.ttl.EventsCleanUpService.RANDOM_DELAY_INTERVAL_MS_EXPRESSION;
 
+@RunWith(SpringRunner.class)
+@SpringBootTest(classes = EventsCleanUpServiceTest.class)
 @Slf4j
 public class EventsCleanUpServiceTest {
 
+    @Value(RANDOM_DELAY_INTERVAL_MS_EXPRESSION)
+    long randomDelayMs;
+    @Value("${sql.ttl.events.execution_interval_ms}")
+    long executionIntervalMs;
+
     @Test
     public void givenInterval_whenRandomDelay_ThenDelayInInterval() {
-        final long executionIntervalMs = 2220000; //37min
-        final long randomDelay = org.apache.commons.lang3.RandomUtils.nextLong(0, executionIntervalMs); //same as @Scheduled(initialDelayString = ...
-        log.info("randomDelay {}", randomDelay);
-        assertThat(randomDelay, greaterThanOrEqualTo(0L));
-        assertThat(randomDelay, lessThanOrEqualTo(executionIntervalMs));
+        log.info("randomDelay {}", randomDelayMs);
+        log.info("executionIntervalMs {}", executionIntervalMs);
+        assertThat(executionIntervalMs, is(2220000L));
+        assertThat(randomDelayMs, greaterThanOrEqualTo(0L));
+        assertThat(randomDelayMs, lessThanOrEqualTo(executionIntervalMs));
     }
+
 }