Package org.apache.activemq.artemis.core.paging.impl

Class PageReadWriter

java.lang.Object

org.apache.activemq.artemis.core.paging.impl.PageReadWriter

public class PageReadWriter
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	PageReadWriter.PageRecordFilter
static interface	PageReadWriter.ReadCallback
static interface	PageReadWriter.SuspectFileCallback

Field Summary

Fields

Modifier and Type	Field	Description
static final PageReadWriter.PageRecordFilter	NO_SKIP
static final PageReadWriter.PageRecordFilter	ONLY_LARGE
static final int	SIZE_RECORD
static final PageReadWriter.PageRecordFilter	SKIP_ALL

Constructor Summary

Constructors

Constructor	Description
PageReadWriter()

Method Summary

Modifier and Type	Method	Description
static int	readFromSequentialFile(StorageManager storage, SimpleString storeName, SequentialFileFactory fileFactory, SequentialFile file, long pageId, Consumer<PagedMessage> messages, PageReadWriter.PageRecordFilter skipRecord, PageReadWriter.SuspectFileCallback suspectFileCallback, PageReadWriter.ReadCallback readCallback)
static int	writeMessage(PagedMessage message, SequentialFileFactory fileFactory, SequentialFile file)

Methods inherited from class java.lang.Object

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

Field Details

SIZE_RECORD

public static final int SIZE_RECORD

See Also:

• Constant Field Values

ONLY_LARGE

public static final PageReadWriter.PageRecordFilter ONLY_LARGE

NO_SKIP

public static final PageReadWriter.PageRecordFilter NO_SKIP

SKIP_ALL

public static final PageReadWriter.PageRecordFilter SKIP_ALL

Constructor Details

PageReadWriter

public PageReadWriter()

Method Details

writeMessage

public static int writeMessage(PagedMessage message,
 SequentialFileFactory fileFactory,
 SequentialFile file)
                        throws Exception

Throws:

Exception

readFromSequentialFile

public static int readFromSequentialFile(StorageManager storage,
 SimpleString storeName,
 SequentialFileFactory fileFactory,
 SequentialFile file,
 long pageId,
 Consumer<PagedMessage> messages,
 PageReadWriter.PageRecordFilter skipRecord,
 PageReadWriter.SuspectFileCallback suspectFileCallback,
 PageReadWriter.ReadCallback readCallback)
                                  throws Exception

Throws:

Exception