org.hornetq.core.paging.cursor.impl

Class PageCacheImpl

java.lang.Object

org.hornetq.core.paging.cursor.impl.PageCacheImpl

All Implemented Interfaces:

PageCache, SoftValueHashMap.ValueCache

public class PageCacheImpl
extends Object
implements PageCache

The caching associated to a single page.

Author:

Clebert Suconic

Constructor Summary

Constructors

Constructor and Description
PageCacheImpl(Page page)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
PagedMessage	getMessage(int messageNumber)
PagedMessage[]	getMessages()
int	getNumberOfMessages()
Page	getPage()
long	getPageId()
boolean	isLive() If this cache is still being updated
void	lock() When the cache is being created, We need to first read the files before other threads can get messages from this.
void	setMessages(PagedMessage[] messages)
String	toString()
void	unlock() You have to call this method within the same thread you called lock

Methods inherited from class java.lang.Object

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

Constructor Detail

PageCacheImpl

public PageCacheImpl(Page page)

Method Detail

getPage

public Page getPage()

Specified by:

getPage 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:

getPageId

public long getPageId()

Specified by:

getPageId in interface PageCache

lock

public void lock()

Description copied from interface: PageCache

When the cache is being created, We need to first read the files before other threads can get messages from this.

Specified by:

lock in interface PageCache

unlock

public void unlock()

Description copied from interface: PageCache

You have to call this method within the same thread you called lock

Specified by:

unlock in interface PageCache

setMessages

public void setMessages(PagedMessage[] messages)

Specified by:

setMessages in interface PageCache

getNumberOfMessages

public int getNumberOfMessages()

Specified by:

getNumberOfMessages in interface PageCache

close

public void close()

Specified by:

close in interface PageCache

isLive

public boolean isLive()

Description copied from interface: PageCache

If this cache is still being updated

Specified by:

isLive in interface PageCache

Specified by:

isLive in interface SoftValueHashMap.ValueCache

toString

public String toString()

Overrides:

toString in class Object

getMessages

public PagedMessage[] getMessages()

Specified by:

getMessages in interface PageCache