소스 검색

优化:只接收当前注册的监听事件

AE86 1 년 전
부모
커밋
4e4f215654
1개의 변경된 파일4개의 추가작업 그리고 0개의 파일을 삭제
  1. 4 0
      dbsyncer-listener/src/main/java/org/dbsyncer/listener/oracle/dcn/DBChangeNotification.java

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

@@ -324,6 +324,10 @@ public class DBChangeNotification {
 
 
         @Override
         @Override
         public void onDatabaseChangeNotification(DatabaseChangeEvent event) {
         public void onDatabaseChangeNotification(DatabaseChangeEvent event) {
+            // 只接收当前注册的监听
+            if (dcr.getRegId() != event.getRegId()) {
+                return;
+            }
             DatabaseChangeEvent.EventType eventType = event.getEventType();
             DatabaseChangeEvent.EventType eventType = event.getEventType();
             if(eventType == DatabaseChangeEvent.EventType.OBJCHANGE){
             if(eventType == DatabaseChangeEvent.EventType.OBJCHANGE){
                 for (TableChangeDescription td : event.getTableChangeDescription()) {
                 for (TableChangeDescription td : event.getTableChangeDescription()) {