diff --git a/src/test/java/it/gov/pagopa/wispconverter/consumer/ConsumerTest.java b/src/test/java/it/gov/pagopa/wispconverter/consumer/ConsumerTest.java
index 8e61d25b..bef54512 100644
--- a/src/test/java/it/gov/pagopa/wispconverter/consumer/ConsumerTest.java
+++ b/src/test/java/it/gov/pagopa/wispconverter/consumer/ConsumerTest.java
@@ -11,6 +11,7 @@
 import it.gov.pagopa.wispconverter.repository.model.IdempotencyKeyEntity;
 import it.gov.pagopa.wispconverter.repository.model.RTRequestEntity;
 import it.gov.pagopa.wispconverter.repository.model.enumz.IdempotencyStatusEnum;
+import it.gov.pagopa.wispconverter.repository.model.enumz.ReceiptStatusEnum;
 import it.gov.pagopa.wispconverter.repository.model.enumz.ReceiptTypeEnum;
 import it.gov.pagopa.wispconverter.service.*;
 import it.gov.pagopa.wispconverter.servicebus.RTConsumer;
@@ -45,7 +46,7 @@ private RTRequestEntity getStoredReceipt(int retries, String rawtype, String url
                 .receiptType(type)
                 .url(url)
                 .headers(List.of("soapaction:paaInviaRT"))
-                .idempotencyKey("idpa_uuid_nav")
+                .idempotencyKey("uuid_nav_idDominio")
                 .build();
     }
 
@@ -81,6 +82,9 @@ void sendToPa_sent(String receiptType) {
         RtRetryComosService rtRetryComosService = new RtRetryComosService(reService, rtRetryRepository);
         ReflectionTestUtils.setField(rtRetryComosService, "isTracingOnREEnabled", true);
 
+        RtReceiptCosmosService rtReceiptCosmosService = mock(RtReceiptCosmosService.class);
+        when(rtReceiptCosmosService.updateReceiptStatus(anyString(), anyString(), anyString(), any(ReceiptStatusEnum.class))).thenReturn(true);
+
         ServiceBusService serviceBusService = new ServiceBusService();
         ServiceBusSenderClient serviceBusSenderClient = mock(ServiceBusSenderClient.class);
         doNothing().when(serviceBusSenderClient).sendMessage(any());
@@ -93,6 +97,7 @@ void sendToPa_sent(String receiptType) {
         PaaInviaRTSenderService paaInviaRTSenderService = mock(PaaInviaRTSenderService.class);
 
         ReflectionTestUtils.setField(rtConsumer, "rtRetryComosService", rtRetryComosService);
+        ReflectionTestUtils.setField(rtConsumer, "rtReceiptCosmosService", rtReceiptCosmosService);
         ReflectionTestUtils.setField(rtConsumer, "paaInviaRTSenderService", paaInviaRTSenderService);
         ReflectionTestUtils.setField(rtConsumer, "serviceBusService", serviceBusService);
         ReflectionTestUtils.setField(rtConsumer, "reService", reService);
@@ -143,6 +148,9 @@ void sendToPa_locked(String receiptType, String rawIsCompleted) {
         RtRetryComosService rtRetryComosService = new RtRetryComosService(reService, rtRetryRepository);
         ReflectionTestUtils.setField(rtRetryComosService, "isTracingOnREEnabled", true);
 
+        RtReceiptCosmosService rtReceiptCosmosService = mock(RtReceiptCosmosService.class);
+        when(rtReceiptCosmosService.updateReceiptStatus(anyString(), anyString(), anyString(), any(ReceiptStatusEnum.class))).thenReturn(true);
+
         ServiceBusService serviceBusService = new ServiceBusService();
         ServiceBusSenderClient serviceBusSenderClient = mock(ServiceBusSenderClient.class);
         doNothing().when(serviceBusSenderClient).sendMessage(any());
@@ -155,6 +163,7 @@ void sendToPa_locked(String receiptType, String rawIsCompleted) {
         PaaInviaRTSenderService paaInviaRTSenderService = mock(PaaInviaRTSenderService.class);
 
         ReflectionTestUtils.setField(rtConsumer, "rtRetryComosService", rtRetryComosService);
+        ReflectionTestUtils.setField(rtConsumer, "rtReceiptCosmosService", rtReceiptCosmosService);
         ReflectionTestUtils.setField(rtConsumer, "paaInviaRTSenderService", paaInviaRTSenderService);
         ReflectionTestUtils.setField(rtConsumer, "serviceBusService", serviceBusService);
         ReflectionTestUtils.setField(rtConsumer, "reService", reService);
@@ -201,6 +210,9 @@ void sendToPa_onError_reschedulable(String receiptType) {
         doNothing().when(serviceBusSenderClient).sendMessage(any());
         ReflectionTestUtils.setField(serviceBusService, "serviceBusSenderClient", serviceBusSenderClient);
 
+        RtReceiptCosmosService rtReceiptCosmosService = mock(RtReceiptCosmosService.class);
+        when(rtReceiptCosmosService.updateReceiptStatus(anyString(), anyString(), anyString(), any(ReceiptStatusEnum.class))).thenReturn(true);
+
         RTConsumer rtConsumer = new RTConsumer();
         ConfigCacheService ccs = mock(ConfigCacheService.class);
         when(ccs.getConfigData()).thenReturn(TestUtils.configData("mystation"));
@@ -209,6 +221,7 @@ void sendToPa_onError_reschedulable(String receiptType) {
         doThrow(new AppException(AppErrorCodeMessageEnum.PARSING_GENERIC_ERROR)).when(paaInviaRTSenderService).sendToCreditorInstitution(any(), any(), any(), any());
 
         ReflectionTestUtils.setField(rtConsumer, "rtRetryComosService", rtRetryComosService);
+        ReflectionTestUtils.setField(rtConsumer, "rtReceiptCosmosService", rtReceiptCosmosService);
         ReflectionTestUtils.setField(rtConsumer, "paaInviaRTSenderService", paaInviaRTSenderService);
         ReflectionTestUtils.setField(rtConsumer, "serviceBusService", serviceBusService);
         ReflectionTestUtils.setField(rtConsumer, "reService", reService);