fix code

dbsyncer-listener/src/main/java/org/dbsyncer/listener/AbstractExtractor.java

@@ -87,7 +87,7 @@ public abstract class AbstractExtractor implements Extractor {
         }
     }
 
-    protected void asynSendRowChangedEvent(RowChangedEvent event) {
+    protected void asyncSendRowChangedEvent(RowChangedEvent event) {
         taskExecutor.execute(() -> changedEvent(event));
     }
 

dbsyncer-listener/src/main/java/org/dbsyncer/listener/mysql/MysqlExtractor.java

@@ -238,7 +238,7 @@ public class MysqlExtractor extends AbstractExtractor {
                     data.getRows().forEach(m -> {
                         List<Object> before = Stream.of(m.getKey()).collect(Collectors.toList());
                         List<Object> after = Stream.of(m.getValue()).collect(Collectors.toList());
-                        asynSendRowChangedEvent(new RowChangedEvent(getTableName(data.getTableId()), ConnectorConstant.OPERTION_UPDATE, before, after));
+                        asyncSendRowChangedEvent(new RowChangedEvent(getTableName(data.getTableId()), ConnectorConstant.OPERTION_UPDATE, before, after));
                     });
                 }
                 refresh(header);
@@ -249,7 +249,7 @@ public class MysqlExtractor extends AbstractExtractor {
                 if (isFilterTable(data.getTableId(), ConnectorConstant.OPERTION_INSERT)) {
                     data.getRows().forEach(m -> {
                         List<Object> after = Stream.of(m).collect(Collectors.toList());
-                        asynSendRowChangedEvent(new RowChangedEvent(getTableName(data.getTableId()), ConnectorConstant.OPERTION_INSERT, Collections.EMPTY_LIST, after));
+                        asyncSendRowChangedEvent(new RowChangedEvent(getTableName(data.getTableId()), ConnectorConstant.OPERTION_INSERT, Collections.EMPTY_LIST, after));
                     });
                 }
                 refresh(header);
@@ -260,7 +260,7 @@ public class MysqlExtractor extends AbstractExtractor {
                 if (isFilterTable(data.getTableId(), ConnectorConstant.OPERTION_DELETE)) {
                     data.getRows().forEach(m -> {
                         List<Object> before = Stream.of(m).collect(Collectors.toList());
-                        asynSendRowChangedEvent(new RowChangedEvent(getTableName(data.getTableId()), ConnectorConstant.OPERTION_DELETE, before, Collections.EMPTY_LIST));
+                        asyncSendRowChangedEvent(new RowChangedEvent(getTableName(data.getTableId()), ConnectorConstant.OPERTION_DELETE, before, Collections.EMPTY_LIST));
                     });
                 }
                 refresh(header);

dbsyncer-listener/src/main/java/org/dbsyncer/listener/oracle/OracleExtractor.java

@@ -27,7 +27,7 @@ public class OracleExtractor extends AbstractExtractor {
             String url = config.getUrl();
             client = new DBChangeNotification(username, password, url);
             client.setFilterTable(filterTable);
-            client.addRowEventListener((e) -> asynSendRowChangedEvent(e));
+            client.addRowEventListener((e) -> asyncSendRowChangedEvent(e));
             client.start();
         } catch (Exception e) {
             logger.error("启动失败:{}", e.getMessage());

dbsyncer-listener/src/main/java/org/dbsyncer/listener/oracle/dcn/DBChangeNotification.java

@@ -76,7 +76,7 @@ public class DBChangeNotification {
             prop.setProperty(OracleConnection.DCN_NOTIFY_ROWIDS, "true");
             prop.setProperty(OracleConnection.DCN_IGNORE_UPDATEOP, "false");
             prop.setProperty(OracleConnection.DCN_IGNORE_INSERTOP, "false");
-            prop.setProperty(OracleConnection.DCN_IGNORE_INSERTOP, "false");
+            prop.setProperty(OracleConnection.DCN_IGNORE_DELETEOP, "false");
 
             // add the listener:NTFDCNRegistration
             dcr = conn.registerDatabaseChangeNotification(prop);

dbsyncer-manager/src/main/java/org/dbsyncer/manager/puller/Increment.java

@@ -1,9 +0,0 @@
-package org.dbsyncer.manager.puller;
-
-import org.dbsyncer.listener.Extractor;
-
-public interface Increment {
-
-    void execute(Extractor extractor);
-
-}