code: private void notifyChangeListeners(final Replication.ChangeEvent changeEvent) {
          if (changeListenerNotifyStyle == ChangeListenerNotifyStyle.SYNC) {
              for (ChangeListener changeListener : changeListeners) {
                  try {
                      changeListener.changed(changeEvent);
                  } catch (Exception e) {
                      Log.e(Log.TAG_SYNC, "Unknown Error in changeListener.changed(changeEvent)", e);
                  }
              }
          } else {
              // ASYNC
              synchronized (executor) {
                  if (!executor.isShutdown()) {
                      executor.submit(new Runnable() {
                          @Override
                          public void run() {
                              try {
                                  for (ChangeListener changeListener : changeListeners)
                                      changeListener.changed(changeEvent);
                              } catch (Exception e) {
                                  Log.e(Log.TAG_SYNC, "Exception notifying replication listener: %s", e, this);
                                  throw new RuntimeException(e);
                              }
                          }
                      });
                  }
              }
          }
      }
docs: Notify all change listeners of a ChangeEvent