Package org.objectweb.howl.log.xa

Class XALogger.XAReplayListener

  • All Implemented Interfaces:
    ReplayListener
    Enclosing class:
    XALogger
    private static class XALogger.XAReplayListener
extends java.lang.Object
implements ReplayListener
    private class used by XALogger.replay() methods. Used by replay(ReplayListener) and replay(ReplayListener, long) wrapper methods to intercept XACOMMIT and XACOMMITMOVED records so they can be passed to caller. During TM invoked replay, log records are returned to the caller, but the activeTx table is not updated.

    • Field Summary

      Fields 
      Modifier and Type Field Description
      (package private) LogRecord lr  
      (package private) ReplayListener tmListener
      ReplayListener registered by TM that instantiated this XALogger.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      LogRecord getLogRecord()
      Called by Logger when ReplayListener is registered for replay.
      void onError​(LogException e)
      Called by Logger when an exception is encountered during replay.
      void onRecord​(LogRecord lr)
      Called by Logger for each record retrieved from the log.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Field Detail

      • tmListener

        final ReplayListener tmListener
        ReplayListener registered by TM that instantiated this XALogger.

        During replay, non-CTRL records are returned to the TM's replayListener.

    • Constructor Detail

    • Method Detail

      • onRecord

        public void onRecord​(LogRecord lr)
        Description copied from interface: ReplayListener
        Called by Logger for each record retrieved from the log.

        when the entire log has been processed, lr.type is set to LogRecordType.END_OF_LOG.

        Specified by:
        onRecord in interface ReplayListener
        Parameters:
        lr - LogRecord to be processed

      • onError

        public void onError​(LogException e)
        Description copied from interface: ReplayListener
        Called by Logger when an exception is encountered during replay.
        Specified by:
        onError in interface ReplayListener
        Parameters:
        e - LogException object that was thrown when the error occurred.

      • getLogRecord

        public LogRecord getLogRecord()
        Description copied from interface: ReplayListener
        Called by Logger when ReplayListener is registered for replay.

        The Logger calls getLogRecord to obtain a LogRecord instance to be used to process log records.

        The same LogRecord instance is used to return all log records to the ReplayListener.

        Specified by:
        getLogRecord in interface ReplayListener
        Returns:
        LogRecord object to be used when calling onRecord()