remove schedule

src/main/java/it/pagopa/interop/signalhub/history/cleanup/SignalHubHistoryCleanupApplication.java

@@ -1,19 +1,15 @@
 package it.pagopa.interop.signalhub.history.cleanup;
 
-import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.data.r2dbc.config.EnableR2dbcAuditing;
 import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
 @EnableR2dbcAuditing
-@EnableScheduling
 public class SignalHubHistoryCleanupApplication {
 
 	public static void main(String[] args) {
-
-
 		SpringApplication.run(SignalHubHistoryCleanupApplication.class, args);
 	}
 

src/main/java/it/pagopa/interop/signalhub/history/cleanup/entities/SignalEntity.java

@@ -11,7 +11,6 @@
 import java.io.Serializable;
 import java.time.Instant;
 
-
 @Getter
 @Setter
 @Table("SIGNAL")

src/main/java/it/pagopa/interop/signalhub/history/cleanup/repository/SignalRepository.java

@@ -11,7 +11,7 @@
 @Repository
 public interface SignalRepository extends ReactiveCrudRepository<SignalEntity, Long> {
 
-    @Query("delete from signal s where  s.tmst_Insert < :date")
+    @Query("delete from signal s where s.tmst_Insert < :date")
     Mono<Void> deleteByDateBefore(LocalDate date );
 
 }

src/main/java/it/pagopa/interop/signalhub/history/cleanup/service/SignalService.java

@@ -1,11 +1,5 @@
 package it.pagopa.interop.signalhub.history.cleanup.service;
 
-import reactor.core.publisher.Mono;
-import reactor.core.publisher.Signal;
-
-import java.io.FileNotFoundException;
-import java.time.LocalDate;
-
 public interface SignalService {
 
     void deleteSignal();

src/main/java/it/pagopa/interop/signalhub/history/cleanup/service/impl/SignalServiceImpl.java

@@ -6,12 +6,10 @@
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.scheduling.annotation.Scheduled;
 
 import java.time.LocalDate;
 import java.time.temporal.ChronoUnit;
 
-
 @Slf4j
 @AllArgsConstructor
 public class SignalServiceImpl implements SignalService {
@@ -21,18 +19,14 @@ public class SignalServiceImpl implements SignalService {
 
     @Autowired
     private AppConfig appConfig;
-    @Scheduled(cron =  "${pdnd.history-cleanup.scheduled-delay}")
-    public void deleteSignal() {
 
-        String delaydays = appConfig.getDelayDays();
-        long numeroGiorni = Long.parseLong(delaydays);
-        LocalDate pastDate = LocalDate.now().minus(numeroGiorni, ChronoUnit.DAYS);
+    public void deleteSignal() {
+        LocalDate pastDate = LocalDate.now().minus(Long.parseLong(appConfig.getDelayDays()), ChronoUnit.DAYS);
 
         signalRepository.deleteByDateBefore(pastDate)
                 .doOnSuccess(x -> log.info("record success"))
                 .doOnError(x ->   log.error("Find an error {}",x.getMessage()))
                 .subscribe();
-
     }
 
 }

src/main/resources/application.properties

@@ -15,5 +15,4 @@ spring.r2dbc.pool.initial-size=5
 spring.r2dbc.pool.enabled=true
 spring.data.r2dbc.repositories.enabled=true
 
-pdnd.history-cleanup.scheduled-delay=0 59 */08 * * *
 pdnd.history-cleanup.delay-days=30