org.mule.util.queue

Class QueueControlDataFile

java.lang.Object

org.mule.util.queue.QueueControlDataFile

public class QueueControlDataFile
extends Object

Control information for queues.

Provides information about the current write and read file that were used at the moment of the shutdown.

Field Summary

Fields

Modifier and Type	Field and Description
static int	INTEGER_SIZE_IN_BYTES

Constructor Summary

Constructors

Constructor and Description
QueueControlDataFile(QueueFileProvider queueFileProvider, File firstFile, File secondFile) Creates a QueueControlDataFile for storing / retrieving information

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	delete() Deletes the underlying file.
File	getCurrentReadFile()
File	getCurrentWriteFile()
void	writeControlData(File writeFile, File readFile) Updates the control data

Methods inherited from class java.lang.Object

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

Field Detail

INTEGER_SIZE_IN_BYTES

public static final int INTEGER_SIZE_IN_BYTES

See Also:

Constant Field Values

Constructor Detail

QueueControlDataFile

public QueueControlDataFile(QueueFileProvider queueFileProvider,
                    File firstFile,
                    File secondFile)

Creates a QueueControlDataFile for storing / retrieving information

Parameters:

queueFileProvider - file provider to use to store control data

firstFile - first queue file. Used for write and read in case there is no control data yet.

secondFile - second queue file.

Method Detail

writeControlData

public void writeControlData(File writeFile,
                    File readFile)

Updates the control data

Parameters:

writeFile - file that is used for writing

readFile - file that is used for reading

getCurrentReadFile

public File getCurrentReadFile()

Returns:

path of the current file that is used for reading

getCurrentWriteFile

public File getCurrentWriteFile()

Returns:

path of the current file that is used for writing

close

public void close()

delete

public void delete()

Deletes the underlying file. This method must only be invoked after close() has been executed on this instance