Class SimpleWaitIOCallback

java.lang.Object
org.apache.activemq.artemis.core.journal.impl.SyncIOCompletion
org.apache.activemq.artemis.core.journal.impl.SimpleWaitIOCallback
All Implemented Interfaces:
IOCallback, IOCompletion
public final class SimpleWaitIOCallback extends SyncIOCompletion

  • Constructor Details

    • SimpleWaitIOCallback

      public SimpleWaitIOCallback()

  • Method Details

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • done

      public void done()
      Description copied from interface: IOCallback
      Method for sync notifications. When this callback method is called, there is a guarantee the data is written on the disk.

      Note:Leave this method as soon as possible, or you would be blocking the whole notification thread

    • onError

      public void onError(int errorCode1, String errorMessage1)
      Description copied from interface: IOCallback
      Method for error notifications. Observation: The whole file will be probably failing if this happens. Like, if you delete the file, you will start to get errors for these operations

    • waitCompletion

      public void waitCompletion() throws InterruptedException, org.apache.activemq.artemis.api.core.ActiveMQException
      Specified by:
      waitCompletion in class SyncIOCompletion
      Throws:
      InterruptedException
      org.apache.activemq.artemis.api.core.ActiveMQException

    • waitCompletion

      public boolean waitCompletion(long timeout) throws InterruptedException, org.apache.activemq.artemis.api.core.ActiveMQException
      Throws:
      InterruptedException
      org.apache.activemq.artemis.api.core.ActiveMQException

    • storeLineUp

      public void storeLineUp()