diff --git a/helm/values-dev.yaml b/helm/values-dev.yaml
index 4af44d8d..c64089db 100644
--- a/helm/values-dev.yaml
+++ b/helm/values-dev.yaml
@@ -27,8 +27,8 @@ microservice-chart:
     ADAPTER_API_CONFIG_CACHE_URL: "https://api.dev.platform.pagopa.it/api-config-cache/o/v1"
     QUEUE_CONVERSION_NAME: "flowidsendqueue"
     EVENT_HUB_RE_NAME: "fdr-re"
-    EVENT_HUB_FLUSSIRENDICONTAZIONE_NAME: "FLUSSI_RENDICONTAZIONE"
-    EVENT_HUB_IUVRENDICONTATI_NAME: "IUV_RENDICONTATI"
+    EVENT_HUB_FLOWTX_NAME: "FLUSSI_RENDICONTAZIONE"
+    EVENT_HUB_REPORTEDIUV_NAME: "IUV_RENDICONTATI"
     BLOB_RE_CONTAINER_NAME: "payload"
     BLOB_HISTORY_CONTAINER_NAME: "fdrhistory"
     TABLE_HISTORY_FDR_PUBLISH_TABLE: "fdrpublish"
@@ -44,8 +44,8 @@ microservice-chart:
       MONGODB_CONNECTION_STRING: "mongodb-connection-string"
       QUEUE_CONVERSION_CONNECTION_STRING: "fdr-sa-connection-string"
       EVENT_HUB_RE_CONNECTION_STRING: "azure-event-hub-re-connection-string"
-      EVENT_HUB_IUVRENDICONTATI_CONNECTION_STRING: "azure-event-hub-re-connection-string"
-      EVENT_HUB_FLUSSIRENDICONTAZIONE_CONNECTION_STRING: "azure-event-hub-re-connection-string"
+      EVENT_HUB_REPORTEDIUV_CONNECTION_STRING: "fdr-qi-reported-iuv-tx-connection-string"
+      EVENT_HUB_FLOWTX_CONNECTION_STRING: "fdr-qi-flows-tx-connection-string"
       BLOB_RE_CONNECTION_STRING: "fdr-re-sa-connection-string"
       BLOB_HISTORY_CONNECTION_STRING: "fdr-history-sa-connection-string"
       TABLE_HISTORY_CONNECTION_STRING: "fdr-history-sa-connection-string"
diff --git a/helm/values-uat.yaml b/helm/values-uat.yaml
index d3119b30..c58eefe7 100644
--- a/helm/values-uat.yaml
+++ b/helm/values-uat.yaml
@@ -27,8 +27,8 @@ microservice-chart:
     ADAPTER_API_CONFIG_CACHE_URL: "https://api.uat.platform.pagopa.it/api-config-cache/o/v1"
     QUEUE_CONVERSION_NAME: "flowidsendqueue"
     EVENT_HUB_RE_NAME: "fdr-re"
-    EVENT_HUB_FLUSSIRENDICONTAZIONE_NAME: "FLUSSI_RENDICONTAZIONE"
-    EVENT_HUB_IUVRENDICONTATI_NAME: "IUV_RENDICONTATI"
+    EVENT_HUB_FLOWTX_NAME: "FLUSSI_RENDICONTAZIONE"
+    EVENT_HUB_REPORTEDIUV_NAME: "IUV_RENDICONTATI"
     BLOB_RE_CONTAINER_NAME: "payload"
     BLOB_HISTORY_CONTAINER_NAME: "fdrhistory"
     TABLE_HISTORY_FDR_PUBLISH_TABLE: "fdrpublish"
@@ -44,8 +44,8 @@ microservice-chart:
       MONGODB_CONNECTION_STRING: "mongodb-connection-string"
       QUEUE_CONVERSION_CONNECTION_STRING: "fdr-sa-connection-string"
       EVENT_HUB_RE_CONNECTION_STRING: "azure-event-hub-re-connection-string"
-      EVENT_HUB_IUVRENDICONTATI_CONNECTION_STRING: "azure-event-hub-re-connection-string"
-      EVENT_HUB_FLUSSIRENDICONTAZIONE_CONNECTION_STRING: "azure-event-hub-re-connection-string"
+      EVENT_HUB_REPORTEDIUV_CONNECTION_STRING: "fdr-qi-reported-iuv-tx-connection-string"
+      EVENT_HUB_FLOWTX_CONNECTION_STRING: "fdr-qi-flows-tx-connection-string"
       BLOB_RE_CONNECTION_STRING: "fdr-re-sa-connection-string"
       BLOB_HISTORY_CONNECTION_STRING: "fdr-history-sa-connection-string"
       TABLE_HISTORY_CONNECTION_STRING: "fdr-history-sa-connection-string"
diff --git a/src/main/java/it/gov/pagopa/fdr/AppStartup.java b/src/main/java/it/gov/pagopa/fdr/AppStartup.java
index f776a90a..dba01a39 100644
--- a/src/main/java/it/gov/pagopa/fdr/AppStartup.java
+++ b/src/main/java/it/gov/pagopa/fdr/AppStartup.java
@@ -2,8 +2,10 @@
 
 import io.quarkus.runtime.Startup;
 import it.gov.pagopa.fdr.service.conversion.ConversionService;
+import it.gov.pagopa.fdr.service.flowTx.FlowTxService;
 import it.gov.pagopa.fdr.service.history.HistoryService;
 import it.gov.pagopa.fdr.service.re.ReService;
+import it.gov.pagopa.fdr.service.reportedIuv.ReportedIuvService;
 import jakarta.annotation.PostConstruct;
 import jakarta.enterprise.context.ApplicationScoped;
 import org.eclipse.microprofile.config.inject.ConfigProperty;
@@ -25,6 +27,12 @@ public class AppStartup {
   @ConfigProperty(name = "history.enabled")
   boolean historyEnabled;
 
+  @ConfigProperty(name = "eHub.reportediuv.enabled")
+  boolean eHubReportedIuvEnabled;
+
+  @ConfigProperty(name = "eHub.flowtx.enabled")
+  boolean eHubFlowTxEnabled;
+
   private final Logger log;
 
   private final Config config;
@@ -34,17 +42,24 @@ public class AppStartup {
   private final ReService reService;
   private final HistoryService historyService;
 
+  private final ReportedIuvService reportedIuvService;
+  private final FlowTxService flowTxService;
+
   public AppStartup(
       Logger log,
       Config config,
       ConversionService conversionQueue,
       ReService reService,
-      HistoryService historyService) {
+      HistoryService historyService,
+      ReportedIuvService reportedIuvService,
+      FlowTxService flowTxService) {
     this.log = log;
     this.config = config;
     this.conversionQueue = conversionQueue;
     this.reService = reService;
     this.historyService = historyService;
+    this.reportedIuvService = reportedIuvService;
+    this.flowTxService = flowTxService;
   }
 
   @PostConstruct
@@ -76,5 +91,19 @@ public void init() {
     } else {
       log.info("History DISABLED");
     }
+
+    if (eHubReportedIuvEnabled) {
+      log.info("Start EventHub ReportedIUV");
+      reportedIuvService.init();
+    } else {
+      log.info("Start EventHub ReportedIUV");
+    }
+
+    if (eHubFlowTxEnabled) {
+      log.info("Start EventHub FlowTx");
+      flowTxService.init();
+    } else {
+      log.info("Start EventHub FlowTx");
+    }
   }
 }
diff --git a/src/main/java/it/gov/pagopa/fdr/exception/AppErrorCodeMessageEnum.java b/src/main/java/it/gov/pagopa/fdr/exception/AppErrorCodeMessageEnum.java
index 876fdb05..ad39175b 100644
--- a/src/main/java/it/gov/pagopa/fdr/exception/AppErrorCodeMessageEnum.java
+++ b/src/main/java/it/gov/pagopa/fdr/exception/AppErrorCodeMessageEnum.java
@@ -62,14 +62,11 @@ public enum AppErrorCodeMessageEnum implements AppErrorCodeMessageInterface {
   FILE_UTILS_FILE_NOT_FOUND("0730", "fdr.fileUtilsFileNotFound", Status.INTERNAL_SERVER_ERROR),
   COMPRESS_JSON("0731", "compress.json.error", Status.INTERNAL_SERVER_ERROR),
 
-  EVENT_HUB_IUVRENDICONTATI_PARSE_JSON(
-      "0732", "eHub.iuvrendicontati.parse", Status.INTERNAL_SERVER_ERROR),
-  EVENT_HUB_IUVRENDICONTATI_TOO_LARGE(
-      "0733", "eHub.iuvrendicontati.tooLarge", Status.INTERNAL_SERVER_ERROR),
-  EVENT_HUB_FLUSSIRENDICONTAZIONE_PARSE_JSON(
-      "0734", "eHub.flussirendicontazione.parse", Status.INTERNAL_SERVER_ERROR),
-  EVENT_HUB_FLUSSIRENDICONTAZIONE_TOO_LARGE(
-      "0735", "eHub.flussirendicontazione.tooLarge", Status.INTERNAL_SERVER_ERROR);
+  EVENT_HUB_REPORTEDIUV_PARSE_JSON("0732", "eHub.reportediuv.parse", Status.INTERNAL_SERVER_ERROR),
+  EVENT_HUB_REPORTEDIUV_TOO_LARGE(
+      "0733", "eHub.reportediuv.tooLarge", Status.INTERNAL_SERVER_ERROR),
+  EVENT_HUB_FLOWTX_PARSE_JSON("0734", "eHub.flowtx.parse", Status.INTERNAL_SERVER_ERROR),
+  EVENT_HUB_FLOWTX_TOO_LARGE("0735", "eHub.flowtx.tooLarge", Status.INTERNAL_SERVER_ERROR);
 
   private final String errorCode;
   private final String errorMessageKey;
diff --git a/src/main/java/it/gov/pagopa/fdr/service/flussiRendicontazione/FlussiRendicontazioneService.java b/src/main/java/it/gov/pagopa/fdr/service/flowTx/FlowTxService.java
similarity index 77%
rename from src/main/java/it/gov/pagopa/fdr/service/flussiRendicontazione/FlussiRendicontazioneService.java
rename to src/main/java/it/gov/pagopa/fdr/service/flowTx/FlowTxService.java
index 3cf1a902..92c15d74 100644
--- a/src/main/java/it/gov/pagopa/fdr/service/flussiRendicontazione/FlussiRendicontazioneService.java
+++ b/src/main/java/it/gov/pagopa/fdr/service/flowTx/FlowTxService.java
@@ -1,4 +1,4 @@
-package it.gov.pagopa.fdr.service.flussiRendicontazione;
+package it.gov.pagopa.fdr.service.flowTx;
 
 import com.azure.messaging.eventhubs.EventData;
 import com.azure.messaging.eventhubs.EventDataBatch;
@@ -8,7 +8,7 @@
 import com.fasterxml.jackson.databind.ObjectMapper;
 import it.gov.pagopa.fdr.exception.AppErrorCodeMessageEnum;
 import it.gov.pagopa.fdr.exception.AppException;
-import it.gov.pagopa.fdr.service.flussiRendicontazione.model.FlussiRendicontazione;
+import it.gov.pagopa.fdr.service.flowTx.model.FlowTx;
 import jakarta.enterprise.context.ApplicationScoped;
 import java.util.Arrays;
 import java.util.List;
@@ -17,27 +17,27 @@
 import org.jboss.logging.Logger;
 
 @ApplicationScoped
-public class FlussiRendicontazioneService {
+public class FlowTxService {
 
   private final Logger log;
 
-  @ConfigProperty(name = "ehub.flussirendicontazione.connect-str")
+  @ConfigProperty(name = "ehub.flowtx.connect-str")
   String eHubConnectStr;
 
-  @ConfigProperty(name = "ehub.flussirendicontazione.name")
+  @ConfigProperty(name = "ehub.flowtx.name")
   String eHubName;
 
   private EventHubProducerClient producer;
 
   private final ObjectMapper objectMapper;
 
-  public FlussiRendicontazioneService(Logger log, ObjectMapper objectMapper) {
+  public FlowTxService(Logger log, ObjectMapper objectMapper) {
     this.log = log;
     this.objectMapper = objectMapper;
   }
 
   public void init() {
-    log.infof("EventHub flussirendicontazione init. EventHub name [%s]", eHubName);
+    log.infof("EventHub flowtx init. EventHub name [%s]", eHubName);
 
     this.producer =
         new EventHubClientBuilder()
@@ -45,7 +45,7 @@ public void init() {
             .buildProducerClient();
   }
 
-  public final void sendEvent(FlussiRendicontazione... list) {
+  public final void sendEvent(FlowTx... list) {
     if (this.producer == null) {
       log.debugf("EventHub re [%s] NOT INITIALIZED", eHubName);
     } else {
@@ -59,8 +59,7 @@ public final void sendEvent(FlussiRendicontazione... list) {
                       return new EventData(objectMapper.writeValueAsString(l));
                     } catch (JsonProcessingException e) {
                       log.errorf("Producer SDK Azure RE event error", e);
-                      throw new AppException(
-                          AppErrorCodeMessageEnum.EVENT_HUB_FLUSSIRENDICONTAZIONE_PARSE_JSON);
+                      throw new AppException(AppErrorCodeMessageEnum.EVENT_HUB_FLOWTX_PARSE_JSON);
                     }
                   })
               .toList();
@@ -84,7 +83,7 @@ public void publishEvents(List<EventData> allEvents) {
         // Try to add that event that couldn't fit before.
         if (!eventDataBatch.tryAdd(eventData)) {
           throw new AppException(
-              AppErrorCodeMessageEnum.EVENT_HUB_FLUSSIRENDICONTAZIONE_TOO_LARGE,
+              AppErrorCodeMessageEnum.EVENT_HUB_FLOWTX_TOO_LARGE,
               eventDataBatch.getMaxSizeInBytes());
         }
       }
diff --git a/src/main/java/it/gov/pagopa/fdr/service/flussiRendicontazione/model/FlussiRendicontazione.java b/src/main/java/it/gov/pagopa/fdr/service/flowTx/model/FlowTx.java
similarity index 90%
rename from src/main/java/it/gov/pagopa/fdr/service/flussiRendicontazione/model/FlussiRendicontazione.java
rename to src/main/java/it/gov/pagopa/fdr/service/flowTx/model/FlowTx.java
index dd3cb8b7..2bd31b37 100644
--- a/src/main/java/it/gov/pagopa/fdr/service/flussiRendicontazione/model/FlussiRendicontazione.java
+++ b/src/main/java/it/gov/pagopa/fdr/service/flowTx/model/FlowTx.java
@@ -1,4 +1,4 @@
-package it.gov.pagopa.fdr.service.flussiRendicontazione.model;
+package it.gov.pagopa.fdr.service.flowTx.model;
 
 import com.fasterxml.jackson.annotation.JsonProperty;
 import java.math.BigDecimal;
@@ -9,7 +9,7 @@
 
 @Data
 @Builder
-public class FlussiRendicontazione {
+public class FlowTx {
 
   @JsonProperty("ID_FLUSSO")
   private String idFlusso;
diff --git a/src/main/java/it/gov/pagopa/fdr/service/psps/PspsService.java b/src/main/java/it/gov/pagopa/fdr/service/psps/PspsService.java
index 40d60aa0..ccde550c 100644
--- a/src/main/java/it/gov/pagopa/fdr/service/psps/PspsService.java
+++ b/src/main/java/it/gov/pagopa/fdr/service/psps/PspsService.java
@@ -21,15 +21,15 @@
 import it.gov.pagopa.fdr.service.conversion.ConversionService;
 import it.gov.pagopa.fdr.service.conversion.message.FdrMessage;
 import it.gov.pagopa.fdr.service.dto.*;
-import it.gov.pagopa.fdr.service.flussiRendicontazione.FlussiRendicontazioneService;
-import it.gov.pagopa.fdr.service.flussiRendicontazione.model.FlussiRendicontazione;
+import it.gov.pagopa.fdr.service.flowTx.FlowTxService;
+import it.gov.pagopa.fdr.service.flowTx.model.FlowTx;
 import it.gov.pagopa.fdr.service.history.HistoryService;
 import it.gov.pagopa.fdr.service.history.model.HistoryBlobBody;
-import it.gov.pagopa.fdr.service.iuvRendicontati.IUVRendicontatiService;
-import it.gov.pagopa.fdr.service.iuvRendicontati.model.IUVRendicontati;
 import it.gov.pagopa.fdr.service.psps.mapper.PspsServiceServiceMapper;
 import it.gov.pagopa.fdr.service.re.ReService;
 import it.gov.pagopa.fdr.service.re.model.*;
+import it.gov.pagopa.fdr.service.reportedIuv.ReportedIuvService;
+import it.gov.pagopa.fdr.service.reportedIuv.model.ReportedIuv;
 import it.gov.pagopa.fdr.util.AppDBUtil;
 import it.gov.pagopa.fdr.util.AppMessageUtil;
 import jakarta.enterprise.context.ApplicationScoped;
@@ -54,9 +54,9 @@ public class PspsService {
 
   private final ReService reService;
 
-  private final FlussiRendicontazioneService flussiRendicontazioneService;
+  private final FlowTxService flowTxService;
 
-  private final IUVRendicontatiService iuvRendicontatiService;
+  private final ReportedIuvService reportedIuvService;
 
   private final HistoryService historyService;
 
@@ -66,15 +66,15 @@ public PspsService(
       ConversionService conversionQueue,
       ReService reService,
       HistoryService historyService,
-      FlussiRendicontazioneService flussiRendicontazioneService,
-      IUVRendicontatiService iuvRendicontatiService) {
+      FlowTxService flowTxService,
+      ReportedIuvService reportedIuvService) {
     this.mapper = mapper;
     this.log = log;
     this.conversionQueue = conversionQueue;
     this.reService = reService;
     this.historyService = historyService;
-    this.flussiRendicontazioneService = flussiRendicontazioneService;
-    this.iuvRendicontatiService = iuvRendicontatiService;
+    this.flowTxService = flowTxService;
+    this.reportedIuvService = reportedIuvService;
   }
 
   @WithSpan(kind = SERVER)
@@ -378,10 +378,9 @@ public void publishByFdr(String action, String pspId, String fdr, boolean intern
             .fdrAction(FdrActionEnum.PUBLISH)
             .build());
 
-    flussiRendicontazioneService.sendEvent(
-        FlussiRendicontazione.builder().build()); // FIXME popolare campi
+    flowTxService.sendEvent(FlowTx.builder().build()); // FIXME popolare campi
 
-    iuvRendicontatiService.sendEvent(IUVRendicontati.builder().build()); // FIXME popolare campi
+    reportedIuvService.sendEvent(ReportedIuv.builder().build()); // FIXME popolare campi
   }
 
   @WithSpan(kind = SERVER)
diff --git a/src/main/java/it/gov/pagopa/fdr/service/iuvRendicontati/IUVRendicontatiService.java b/src/main/java/it/gov/pagopa/fdr/service/reportedIuv/ReportedIuvService.java
similarity index 80%
rename from src/main/java/it/gov/pagopa/fdr/service/iuvRendicontati/IUVRendicontatiService.java
rename to src/main/java/it/gov/pagopa/fdr/service/reportedIuv/ReportedIuvService.java
index 1e09abf1..8d63e4cc 100644
--- a/src/main/java/it/gov/pagopa/fdr/service/iuvRendicontati/IUVRendicontatiService.java
+++ b/src/main/java/it/gov/pagopa/fdr/service/reportedIuv/ReportedIuvService.java
@@ -1,4 +1,4 @@
-package it.gov.pagopa.fdr.service.iuvRendicontati;
+package it.gov.pagopa.fdr.service.reportedIuv;
 
 import com.azure.messaging.eventhubs.EventData;
 import com.azure.messaging.eventhubs.EventDataBatch;
@@ -8,7 +8,7 @@
 import com.fasterxml.jackson.databind.ObjectMapper;
 import it.gov.pagopa.fdr.exception.AppErrorCodeMessageEnum;
 import it.gov.pagopa.fdr.exception.AppException;
-import it.gov.pagopa.fdr.service.iuvRendicontati.model.IUVRendicontati;
+import it.gov.pagopa.fdr.service.reportedIuv.model.ReportedIuv;
 import jakarta.enterprise.context.ApplicationScoped;
 import java.util.Arrays;
 import java.util.List;
@@ -17,27 +17,27 @@
 import org.jboss.logging.Logger;
 
 @ApplicationScoped
-public class IUVRendicontatiService {
+public class ReportedIuvService {
 
   private final Logger log;
 
-  @ConfigProperty(name = "ehub.iuvrendicontati.connect-str")
+  @ConfigProperty(name = "ehub.reportediuv.connect-str")
   String eHubConnectStr;
 
-  @ConfigProperty(name = "ehub.iuvrendicontati.name")
+  @ConfigProperty(name = "ehub.reportediuv.name")
   String eHubName;
 
   private EventHubProducerClient producer;
 
   private final ObjectMapper objectMapper;
 
-  public IUVRendicontatiService(Logger log, ObjectMapper objectMapper) {
+  public ReportedIuvService(Logger log, ObjectMapper objectMapper) {
     this.log = log;
     this.objectMapper = objectMapper;
   }
 
   public void init() {
-    log.infof("EventHub iuvrendicontati init. EventHub name [%s]", eHubName);
+    log.infof("EventHub reportediuv init. EventHub name [%s]", eHubName);
 
     this.producer =
         new EventHubClientBuilder()
@@ -45,7 +45,7 @@ public void init() {
             .buildProducerClient();
   }
 
-  public final void sendEvent(IUVRendicontati... list) {
+  public final void sendEvent(ReportedIuv... list) {
     if (this.producer == null) {
       log.debugf("EventHub re [%s] NOT INITIALIZED", eHubName);
     } else {
@@ -60,7 +60,7 @@ public final void sendEvent(IUVRendicontati... list) {
                     } catch (JsonProcessingException e) {
                       log.errorf("Producer SDK Azure RE event error", e);
                       throw new AppException(
-                          AppErrorCodeMessageEnum.EVENT_HUB_IUVRENDICONTATI_PARSE_JSON);
+                          AppErrorCodeMessageEnum.EVENT_HUB_REPORTEDIUV_PARSE_JSON);
                     }
                   })
               .toList();
@@ -84,7 +84,7 @@ public void publishEvents(List<EventData> allEvents) {
         // Try to add that event that couldn't fit before.
         if (!eventDataBatch.tryAdd(eventData)) {
           throw new AppException(
-              AppErrorCodeMessageEnum.EVENT_HUB_IUVRENDICONTATI_TOO_LARGE,
+              AppErrorCodeMessageEnum.EVENT_HUB_REPORTEDIUV_TOO_LARGE,
               eventDataBatch.getMaxSizeInBytes());
         }
       }
diff --git a/src/main/java/it/gov/pagopa/fdr/service/iuvRendicontati/model/IUVRendicontati.java b/src/main/java/it/gov/pagopa/fdr/service/reportedIuv/model/ReportedIuv.java
similarity index 92%
rename from src/main/java/it/gov/pagopa/fdr/service/iuvRendicontati/model/IUVRendicontati.java
rename to src/main/java/it/gov/pagopa/fdr/service/reportedIuv/model/ReportedIuv.java
index cf3790c8..0716d6b1 100644
--- a/src/main/java/it/gov/pagopa/fdr/service/iuvRendicontati/model/IUVRendicontati.java
+++ b/src/main/java/it/gov/pagopa/fdr/service/reportedIuv/model/ReportedIuv.java
@@ -1,4 +1,4 @@
-package it.gov.pagopa.fdr.service.iuvRendicontati.model;
+package it.gov.pagopa.fdr.service.reportedIuv.model;
 
 import com.fasterxml.jackson.annotation.JsonProperty;
 import java.math.BigDecimal;
@@ -8,7 +8,7 @@
 
 @Data
 @Builder
-public class IUVRendicontati {
+public class ReportedIuv {
 
   @JsonProperty("IUV")
   private String identificativoUnivocoVersamento;
diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties
index 9ceb4f7c..5eb0b3d9 100644
--- a/src/main/resources/application.properties
+++ b/src/main/resources/application.properties
@@ -151,34 +151,50 @@ ehub.re.name=${EVENT_HUB_RE_NAME:fdr-re}
 %openapi_organization.ehub.re.name=na
 
 #per il run inserire l'env nel proprio profilo
-ehub.flussirendicontazione.connect-str=${EVENT_HUB_FLUSSIRENDICONTAZIONE_CONNECTION_STRING:na}
-%test.ehub.flussirendicontazione.connect-str=na
-#%openapi.ehub.flussirendicontazione.connect-str=na
-%openapi_internal.ehub.flussirendicontazione.connect-str=na
-%openapi_psp.ehub.flussirendicontazione.connect-str=na
-%openapi_organization.ehub.flussirendicontazione.connect-str=na
-
-ehub.flussirendicontazione.name=${EVENT_HUB_FLUSSIRENDICONTAZIONE_NAME:FLUSSI_RENDICONTAZIONE}
-%dev.ehub.flussirendicontazione.name=fdr-re
-#%openapi.ehub.flussirendicontazione.name=na
-%openapi_internal.ehub.flussirendicontazione.name=na
-%openapi_psp.ehub.flussirendicontazione.name=na
-%openapi_organization.ehub.flussirendicontazione.name=na
+eHub.flowtx.enabled=true
+%dev.eHub.flowtx.enabled=true
+%test.eHub.flowtx.enabled=false
+#%openapi.eHub.flowtx.enabled=false
+%openapi_internal.eHub.flowtx.enabled=false
+%openapi_psp.eHub.flowtx.enabled=false
+%openapi_organization.eHub.flowtx.enabled=false
+
+ehub.flowtx.connect-str=${EVENT_HUB_FLOWTX_CONNECTION_STRING:na}
+%test.ehub.flowtx.connect-str=na
+#%openapi.ehub.flowtx.connect-str=na
+%openapi_internal.ehub.flowtx.connect-str=na
+%openapi_psp.ehub.flowtx.connect-str=na
+%openapi_organization.ehub.flowtx.connect-str=na
+
+ehub.flowtx.name=${EVENT_HUB_FLOWTX_NAME:FLUSSI_RENDICONTAZIONE}
+%dev.ehub.flowtx.name=fdr-re
+#%openapi.ehub.flowtx.name=na
+%openapi_internal.ehub.flowtx.name=na
+%openapi_psp.ehub.flowtx.name=na
+%openapi_organization.ehub.flowtx.name=na
 
 #per il run inserire l'env nel proprio profilo
-ehub.iuvrendicontati.connect-str=${EVENT_HUB_IUVRENDICONTATI_CONNECTION_STRING:na}
-%test.ehub.iuvrendicontati.connect-str=na
-#%openapi.ehub.iuvrendicontati.connect-str=na
-%openapi_internal.ehub.iuvrendicontati.connect-str=na
-%openapi_psp.ehub.iuvrendicontati.connect-str=na
-%openapi_organization.ehub.iuvrendicontati.connect-str=na
-
-ehub.iuvrendicontati.name=${EVENT_HUB_IUVRENDICONTATI_NAME:IUV_RENDICONTATI}
-%dev.ehub.iuvrendicontati.name=fdr-re
-#%openapi.ehub.iuvrendicontati.name=na
-%openapi_internal.ehub.iuvrendicontati.name=na
-%openapi_psp.ehub.iuvrendicontati.name=na
-%openapi_organization.ehub.iuvrendicontati.name=na
+eHub.reportediuv.enabled=true
+%dev.eHub.reportediuv.enabled=true
+%test.eHub.reportediuv.enabled=false
+#%openapi.eHub.reportediuv.enabled=false
+%openapi_internal.eHub.reportediuv.enabled=false
+%openapi_psp.eHub.reportediuv.enabled=false
+%openapi_organization.eHub.reportediuv.enabled=false
+
+ehub.reportediuv.connect-str=${EVENT_HUB_REPORTEDIUV_CONNECTION_STRING:na}
+%test.ehub.reportediuv.connect-str=na
+#%openapi.ehub.reportediuv.connect-str=na
+%openapi_internal.ehub.reportediuv.connect-str=na
+%openapi_psp.ehub.reportediuv.connect-str=na
+%openapi_organization.ehub.reportediuv.connect-str=na
+
+ehub.reportediuv.name=${EVENT_HUB_REPORTEDIUV_NAME:IUV_RENDICONTATI}
+%dev.ehub.reportediuv.name=fdr-re
+#%openapi.ehub.reportediuv.name=na
+%openapi_internal.ehub.reportediuv.name=na
+%openapi_psp.ehub.reportediuv.name=na
+%openapi_organization.ehub.reportediuv.name=na
 
 blob.re.connect-str=${BLOB_RE_CONNECTION_STRING:${mockserver.azurite.connection-string}}
 %dev.blob.re.connect-str=DefaultEndpointsProtocol=http;AccountName=devstoreaccount1;AccountKey=Eby8vdM02xNOcqFlqUwJPLlmEtlCDXJ1OUzFT50uSRZ6IFsuFq2UVErCz4I6tq/K1SZFPTOtr/KBHBeksoGMGw==;BlobEndpoint=http://127.0.0.1:10000/devstoreaccount1;QueueEndpoint=http://127.0.0.1:10001/devstoreaccount1;TableEndpoint=http://127.0.0.1:10002/devstoreaccount1;
diff --git a/src/main/resources/messages.properties b/src/main/resources/messages.properties
index 65297536..64609e08 100644
--- a/src/main/resources/messages.properties
+++ b/src/main/resources/messages.properties
@@ -46,8 +46,8 @@ eHub.re.tooLarge=EventHub RE: Event is too large for an empty batch. Max size: [
 compress.json.error=Json compression error
 
 
-eHub.iuvrendicontati.parse=EventHub IUV_RENDICONTATI: Error when write object to json
-eHub.iuvrendicontati.tooLarge=EventHub IUV_RENDICONTATI: Event is too large for an empty batch. Max size: [{0}]
+eHub.reportediuv.parse=EventHub IUV_RENDICONTATI: Error when write object to json
+eHub.reportediuv.tooLarge=EventHub IUV_RENDICONTATI: Event is too large for an empty batch. Max size: [{0}]
 
-eHub.flussirendicontazione.parse=EventHub FLUSSI_RENDICONTAZIONE: Error when write object to json
-eHub.flussirendicontazione.tooLarge=EventHub FLUSSI_RENDICONTAZIONE: Event is too large for an empty batch. Max size: [{0}]
\ No newline at end of file
+eHub.flowtx.parse=EventHub FLUSSI_RENDICONTAZIONE: Error when write object to json
+eHub.flowtx.tooLarge=EventHub FLUSSI_RENDICONTAZIONE: Event is too large for an empty batch. Max size: [{0}]
\ No newline at end of file