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

Class PageReader

java.lang.Object

org.apache.activemq.artemis.core.paging.cursor.impl.PageReader

All Implemented Interfaces:

AutoCloseable, PageCache, SoftValueLongObjectHashMap.ValueCache

public class PageReader
extends Object
implements PageCache

Constructor Summary

Constructors

Constructor	Description
PageReader(Page page, int numberOfMessages)

Method Summary

Modifier and Type	Method	Description
void	close()
PagedMessage	getMessage(PagePosition pagePosition)
PagedMessage	getMessage(PagePosition pagePosition, boolean throwException, boolean keepOpen)
int	getNumberOfMessages()
long	getPageId()
boolean	isLive()
protected PagedMessage[]	readMessages()	Used just for testing purposes.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

PageReader

public PageReader(Page page,
                  int numberOfMessages)

Method Detail

getPageId

public long getPageId()

Specified by:

getPageId in interface PageCache

getNumberOfMessages

public int getNumberOfMessages()

Specified by:

getNumberOfMessages in interface PageCache

readMessages

protected PagedMessage[] readMessages()

Used just for testing purposes.

isLive

public boolean isLive()

Specified by:

isLive in interface SoftValueLongObjectHashMap.ValueCache

getMessage

public PagedMessage getMessage(PagePosition pagePosition,
                               boolean throwException,
                               boolean keepOpen)

Parameters:

pagePosition - page position

throwException - if true exception will be thrown when message number is beyond the page

keepOpen - if true page file would keep open after reading message

Returns:

the paged message

getMessage

public PagedMessage getMessage(PagePosition pagePosition)

Specified by:

getMessage in interface PageCache

Parameters:

pagePosition - page position

Returns:

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface PageCache

toString

public String toString()

Overrides:

toString in class Object