docs: @Subscribe
      public void error(ReplicationErrored re) {
          Log.e(LOG_TAG, "Replication error:", re.errorInfo);
          mHandler.post(new Runnable() {
              @Override
              public void run() {
                  if (mListener != null) {
                      mListener.replicationError();
                  }
              }
          });
      }