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:

PageCache, SoftValueLongObjectHashMap.ValueCache

public class PageReader
extends Object
implements PageCache

Constructor Summary

Constructors

Constructor and Description
PageReader(Page page, int numberOfMessages)

Method Summary

Modifier and Type	Method and Description
void	close()
PagedMessage	getMessage(PagePosition pagePosition)
PagedMessage	getMessage(PagePosition pagePosition, boolean throwException, boolean keepOpen)
PagedMessage[]	getMessages()
int	getNumberOfMessages()
long	getPageId()
boolean	isLive()
void	setMessages(PagedMessage[] messages)
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

setMessages

public void setMessages(PagedMessage[] messages)

Specified by:

setMessages in interface PageCache

getMessages

public PagedMessage[] getMessages()

Specified by:

getMessages in interface PageCache

isLive

public boolean isLive()

Specified by:

isLive in interface PageCache

Specified by:

isLive in interface SoftValueLongObjectHashMap.ValueCache

Returns:

whether this cache is still being updated

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 PageCache

toString

public String toString()

Overrides:

toString in class Object