diff --git a/ems-core/src/main/java/it/integry/ems/sync/MultiDBTransaction/MultiDBTransactionManager.java b/ems-core/src/main/java/it/integry/ems/sync/MultiDBTransaction/MultiDBTransactionManager.java
index 6f780fa1d3..5a67ab6f11 100644
--- a/ems-core/src/main/java/it/integry/ems/sync/MultiDBTransaction/MultiDBTransactionManager.java
+++ b/ems-core/src/main/java/it/integry/ems/sync/MultiDBTransaction/MultiDBTransactionManager.java
@@ -181,12 +181,6 @@ public class MultiDBTransactionManager implements AutoCloseable {
         return connection.prepareStatement(sql);
     }
 
-    public PreparedStatement prepareStatementOnDistributore(String sql) throws Exception {
-        try (Connection connection = getDistributoreConnection()) {
-            return connection.prepareStatement(sql);
-        }
-    }
-
     public List<Connection> getActiveConnections() throws SQLException {
         return allConnections;
     }
diff --git a/ems-core/src/main/java/it/integry/ems/sync/SyncManager.java b/ems-core/src/main/java/it/integry/ems/sync/SyncManager.java
index 9dd16a96ab..6b3728c7c9 100644
--- a/ems-core/src/main/java/it/integry/ems/sync/SyncManager.java
+++ b/ems-core/src/main/java/it/integry/ems/sync/SyncManager.java
@@ -81,6 +81,7 @@ public class SyncManager {
 
                 proceedSyncronization(entitySource, entityCloned, lastProfileUsed, multiDBTransactionManager);
 
+                distributoreConnection.commit();
             } catch (Exception e) {
 
                 String subscriptor = null;
@@ -104,6 +105,9 @@ public class SyncManager {
 
                     e = new SyncException(e, profileDb);
                 }
+
+                distributoreConnection.rollback();
+
                 throw e;
             }
         }