org.apache.activemq.artemis.core.io

Interface SequentialFileFactory

All Known Implementing Classes:

AbstractSequentialFileFactory, AIOSequentialFileFactory, JDBCSequentialFileFactory, MappedSequentialFileFactory, NIOSequentialFileFactory

public interface SequentialFileFactory

A SequentialFileFactory

Method Summary

Modifier and Type	Method and Description
void	activateBuffer(SequentialFile file)
ByteBuffer	allocateDirectBuffer(int size) used for cases where you need direct buffer outside of the journal context.
int	calculateBlockSize(int bytes)
void	clearBuffer(ByteBuffer buffer)
void	createDirs() Creates the directory if it does not exist yet.
SequentialFile	createSequentialFile(String fileName)
void	deactivateBuffer()
void	flush()
int	getAlignment()
long	getBufferSize()
default CriticalAnalyzer	getCriticalAnalyzer()
File	getDirectory()
int	getMaxIO()
boolean	isDatasync()
boolean	isSupportsCallbacks()
List<String>	listFiles(String extension) Lists files that end with the given extension.
ByteBuffer	newBuffer(int size) Note: You need to release the buffer if is used for reading operations.
void	onIOError(Exception exception, String message, SequentialFile file) The SequentialFile will call this method when a disk IO Error happens during the live phase.
void	releaseBuffer(ByteBuffer buffer)
void	releaseDirectBuffer(ByteBuffer buffer) used for cases where you need direct buffer outside of the journal context.
SequentialFileFactory	setAlignment(int alignment)
SequentialFileFactory	setDatasync(boolean enabled)
void	start()
void	stop()
ByteBuffer	wrapBuffer(byte[] bytes)

Method Detail

getCriticalAnalyzer

default CriticalAnalyzer getCriticalAnalyzer()

createSequentialFile

SequentialFile createSequentialFile(String fileName)

getMaxIO

int getMaxIO()

listFiles

List<String> listFiles(String extension)
                throws Exception

Lists files that end with the given extension.

This method inserts a ".' before the extension.

Parameters:

extension -

Returns:

Throws:

Exception

isSupportsCallbacks

boolean isSupportsCallbacks()

onIOError

void onIOError(Exception exception,
               String message,
               SequentialFile file)

The SequentialFile will call this method when a disk IO Error happens during the live phase.

allocateDirectBuffer

ByteBuffer allocateDirectBuffer(int size)

used for cases where you need direct buffer outside of the journal context. This is because the native layer has a method that can be reused in certain cases like paging

releaseDirectBuffer

void releaseDirectBuffer(ByteBuffer buffer)

used for cases where you need direct buffer outside of the journal context. This is because the native layer has a method that can be reused in certain cases like paging

newBuffer

ByteBuffer newBuffer(int size)

Note: You need to release the buffer if is used for reading operations. You don't need to do it if using writing operations (AIO Buffer Lister will take of writing operations)

Parameters:

size -

Returns:

the allocated ByteBuffer

releaseBuffer

void releaseBuffer(ByteBuffer buffer)

activateBuffer

void activateBuffer(SequentialFile file)

deactivateBuffer

void deactivateBuffer()

wrapBuffer

ByteBuffer wrapBuffer(byte[] bytes)

getAlignment

int getAlignment()

setAlignment

SequentialFileFactory setAlignment(int alignment)

calculateBlockSize

int calculateBlockSize(int bytes)

getDirectory

File getDirectory()

clearBuffer

void clearBuffer(ByteBuffer buffer)

start

void start()

stop

void stop()

createDirs

void createDirs()
         throws Exception

Creates the directory if it does not exist yet.

Throws:

Exception

flush

void flush()

setDatasync

SequentialFileFactory setDatasync(boolean enabled)

isDatasync

boolean isDatasync()

getBufferSize

long getBufferSize()