org.apache.activemq.artemis.core.journal.impl

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 Summary

Constructors

Constructor and Description
SimpleWaitIOCallback()

Method Summary

Modifier and Type	Method and Description
void	done() Method for sync notifications.
void	onError(int errorCode1, String errorMessage1) Method for error notifications.
void	storeLineUp()
String	toString()
void	waitCompletion()
boolean	waitCompletion(long timeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleWaitIOCallback

public SimpleWaitIOCallback()

Method Detail

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,
                           ActiveMQException

Specified by:

waitCompletion in class SyncIOCompletion

Throws:

InterruptedException

ActiveMQException

waitCompletion

public boolean waitCompletion(long timeout)
                       throws InterruptedException,
                              ActiveMQException

Throws:

InterruptedException

ActiveMQException

storeLineUp

public void storeLineUp()