public void shutdown() {
public void shutdown(long txnId) { if (!BrokerPool.FORCE_CORRUPTION) { try { writeToLog(new Checkpoint(txnId)); } catch (TransactionException e) { LOG.error("An error occurred while closing the journal file: " + e.getMessage(), e); } flushBuffer(); }
    public void shutdown() {        syncThread.shutdown();        try {			syncThread.join();		} catch (InterruptedException e) {		}    }