File tree Expand file tree Collapse file tree 1 file changed +3
-9
lines changed
Expand file tree Collapse file tree 1 file changed +3
-9
lines changed Original file line number Diff line number Diff line change @@ -62,11 +62,7 @@ public class MySQLListener implements SQLExecuteListener {
6262}
6363
6464// 在应用启动后注册(例如 @PostConstruct、测试用 @BeforeEach 等)
65- DBStreamContext .
66-
67- getInstance().
68-
69- addListener(new MySQLListener ());
65+ DBStreamContext . getInstance(). addListener(new MySQLListener ());
7066```
7167
72684 ) 订阅数据库事件推送(INSERT/UPDATE/DELETE 的行级事件)
@@ -78,11 +74,9 @@ import com.codingapi.dbstream.DBStreamContext;
7874import com.codingapi.dbstream.stream.DBEvent ;
7975import com.codingapi.dbstream.stream.DBEventPusher ;
8076
81- DBStreamContext . getInstance().
82-
83- addEventPusher(new DBEventPusher () {
77+ DBStreamContext . getInstance(). addEventPusher(new DBEventPusher () {
8478 @Override
85- public void push ( java.util . List < DBEvent > events ) {
79+ public void push ( List< DBEvent > events ) {
8680 System . out. println(events);
8781 }
8882});
You can’t perform that action at this time.
0 commit comments