Skip to content

Commit c025f1e

Browse files
committed
Made BinaryLogClient.notifyEventListeners protected for subclasses to override (if necessary)
1 parent a283f8f commit c025f1e

File tree

1 file changed

+10
-10
lines changed

1 file changed

+10
-10
lines changed

src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java

+10-10
Original file line numberDiff line numberDiff line change
@@ -462,7 +462,9 @@ private void listenForEventPackets() throws IOException {
462462
continue;
463463
}
464464
if (isConnected()) {
465-
notifyEventListeners(event);
465+
synchronized (eventListeners) {
466+
notifyEventListeners(eventListeners, event);
467+
}
466468
updateClientBinlogFilenameAndPosition(event);
467469
}
468470
}
@@ -549,15 +551,13 @@ public void unregisterEventListener(EventListener eventListener) {
549551
}
550552
}
551553

552-
private void notifyEventListeners(Event event) {
553-
synchronized (eventListeners) {
554-
for (EventListener eventListener : eventListeners) {
555-
try {
556-
eventListener.onEvent(event);
557-
} catch (Exception e) {
558-
if (logger.isLoggable(Level.WARNING)) {
559-
logger.log(Level.WARNING, eventListener + " choked on " + event, e);
560-
}
554+
protected void notifyEventListeners(List<EventListener> eventListeners, Event event) {
555+
for (EventListener eventListener : eventListeners) {
556+
try {
557+
eventListener.onEvent(event);
558+
} catch (Exception e) {
559+
if (logger.isLoggable(Level.WARNING)) {
560+
logger.log(Level.WARNING, eventListener + " choked on " + event, e);
561561
}
562562
}
563563
}

0 commit comments

Comments
 (0)