org.hornetq.core.paging.cursor

Interface PageCache

All Superinterfaces:

SoftValueHashMap.ValueCache

All Known Subinterfaces:

LivePageCache

All Known Implementing Classes:

LivePageCacheImpl, PageCacheImpl

public interface PageCache
extends SoftValueHashMap.ValueCache

A PageCache

Author:

Clebert Suconic

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)
void	unlock() You have to call this method within the same thread you called lock

Method Detail

getPage

Page getPage()

getPageId

long getPageId()

getNumberOfMessages

int getNumberOfMessages()

setMessages

void setMessages(PagedMessage[] messages)

getMessages

PagedMessage[] getMessages()

isLive

boolean isLive()

If this cache is still being updated

Specified by:

isLive in interface SoftValueHashMap.ValueCache

Returns:

getMessage

PagedMessage getMessage(int messageNumber)

Parameters:

messageNumber - The order of the message on the page

Returns:

lock

void lock()

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

unlock

void unlock()

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

close

void close()