Pagopa 1695 sviluppo pa send rt long term reliability

pom.xml

@@ -237,6 +237,11 @@
             <version>2.1.2</version>
             <scope>compile</scope>
         </dependency>
+        <dependency>
+            <groupId>com.azure</groupId>
+            <artifactId>azure-storage-queue</artifactId>
+            <version>12.20.2</version>
+        </dependency>
     </dependencies>
 
     <dependencyManagement>

src/main/java/it/gov/pagopa/payments/config/QueueClientConfiguration.java

@@ -0,0 +1,33 @@
+package it.gov.pagopa.payments.config;
+
+import com.azure.storage.queue.QueueClient;
+import com.azure.storage.queue.QueueClientBuilder;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class QueueClientConfiguration {
+
+    private static String QUEUE_NAME;
+
+    private static String CONNECTION_STRING;
+
+    @Value("${azure.queue.connection.string}")
+    public void setConnectionStringStatic(String connectionString) {
+        QueueClientConfiguration.CONNECTION_STRING = connectionString;
+    }
+
+    @Value("${azure.queue.queueName}")
+    public void setTableNameStatic(String queueName) {
+        QueueClientConfiguration.QUEUE_NAME = queueName;
+    }
+
+    @Bean
+    public QueueClient queueClientConfig(){
+        return new QueueClientBuilder()
+                .queueName(QUEUE_NAME)
+                .connectionString(CONNECTION_STRING)
+                .buildClient();
+    }
+}

src/main/java/it/gov/pagopa/payments/scheduler/Scheduler.java

@@ -0,0 +1,36 @@
+package it.gov.pagopa.payments.scheduler;
+
+import it.gov.pagopa.payments.service.SchedulerService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+
+@Component
+@Slf4j
+@ConditionalOnProperty(name = "cron.job.schedule.retry.enabled", matchIfMissing = true)
+public class Scheduler {
+
+    private static final String LOG_BASE_HEADER_INFO = "[OperationType: %s] - [ClassMethod: %s] - [MethodParamsToLog: %s]";
+    private static final String CRON_JOB = "CRON JOB";
+    private Thread threadOfExecution;
+
+    @Autowired
+    SchedulerService schedulerService;
+
+    @Scheduled(cron = "${cron.job.schedule.expression.retry.status}")
+    @Async
+    @Transactional
+    public void changeDebtPositionStatusToValid() {
+        log.info(String.format(LOG_BASE_HEADER_INFO, CRON_JOB, "retry sendRT", "Running at " + DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss").format(LocalDateTime.now())));
+        schedulerService.getAllFailuresQueue();
+        this.threadOfExecution = Thread.currentThread();
+    }
+}
+