private synchronized void assertRelayLogsEnabled() throws ReplicatorException, InterruptedException {
  if (useRelayLogs) {
    if (relayLogTask == null) {
      startRelayLogs(binlogPosition.getFileName(),binlogPosition.getPosition());
    }
 else     if (relayLogTask.isFinished())     throw new ExtractorException("Relay log task has unexpectedly terminated; logs may not be accessible");
  }
}

private synchronized void assertRelayLogsEnabled ( ) throws ReplicatorException , InterruptedException { if ( useRelayLogs ) { if ( relayLogTask == null ) { startRelayLogs ( binlogPosition . getFileName ( ) , binlogPosition . getPosition ( ) ) ; } else if ( relayLogTask . isFinished ( ) ) throw new ExtractorException ( "Relay log task has unexpectedly terminated; logs may not be accessible" ) ; } }
starts relay logs and ensures they are running .
