Skip to content

Commit a3b312c

Browse files
authored
update DataChangeEventQueue: add log for onChange (#100)
1 parent 16221f3 commit a3b312c

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

server/server/data/src/main/java/com/alipay/sofa/registry/server/data/change/event/DataChangeEventQueue.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,12 @@ public DataChangeEventQueue(int queueIdx, DataServerConfig dataServerConfig,
123123
* @param event
124124
*/
125125
public void onChange(IDataChangeEvent event) {
126-
eventQueue.add(event);
126+
try {
127+
eventQueue.add(event);
128+
} catch (Throwable e) {
129+
LOGGER.error("Error onChange: " + e.getMessage(), e);
130+
throw e;
131+
}
127132
}
128133

129134
/**

0 commit comments

Comments
 (0)