|
@@ -77,7 +77,7 @@ func (h *EdbEventHandler) Insert(e *canal.RowsEvent) error {
|
|
|
return err
|
|
|
}
|
|
|
} else {
|
|
|
- ok, err := utils.Rc.SIsMember(edbmonitorSvr.EDB_MONITOR_ID_SET_CACHE, newEdbInfo)
|
|
|
+ ok, err := utils.Rc.SIsMember(edbmonitorSvr.EDB_MONITOR_ID_SET_CACHE, newEdbInfo.EdbInfoId)
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
@@ -114,7 +114,7 @@ func (h *EdbEventHandler) Update(e *canal.RowsEvent) error {
|
|
|
return err
|
|
|
}
|
|
|
} else {
|
|
|
- ok, err := utils.Rc.SIsMember(edbmonitorSvr.EDB_MONITOR_ID_SET_CACHE, newEdbInfo)
|
|
|
+ ok, err := utils.Rc.SIsMember(edbmonitorSvr.EDB_MONITOR_ID_SET_CACHE, newEdbInfo.EdbInfoId)
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|