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

Class LivePageCacheImpl

java.lang.Object

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

All Implemented Interfaces:

LivePageCache, PageCache, SoftValueHashMap.ValueCache

public class LivePageCacheImpl
extends Object
implements LivePageCache

This is the same as PageCache, however this is for the page that's being currently written.

Constructor Summary

Constructors

Constructor and Description
LivePageCacheImpl(Page page)

Method Summary

Modifier and Type	Method and Description
void	addLiveMessage(PagedMessage message)
void	close()
PagedMessage	getMessage(int messageNumber)
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

LivePageCacheImpl

public LivePageCacheImpl(Page page)

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

getMessage

public PagedMessage getMessage(int messageNumber)

Specified by:

getMessage in interface PageCache

Parameters:

messageNumber - The order of the message on the page

Returns:

isLive

public boolean isLive()

Specified by:

isLive in interface PageCache

Specified by:

isLive in interface SoftValueHashMap.ValueCache

Returns:

whether this cache is still being updated

addLiveMessage

public void addLiveMessage(PagedMessage message)

Specified by:

addLiveMessage in interface LivePageCache

close

public void close()

Specified by:

close in interface PageCache

getMessages

public PagedMessage[] getMessages()

Specified by:

getMessages in interface PageCache

toString

public String toString()

Overrides:

toString in class Object