org.hornetq.core.paging.cursor.impl

Class LivePageCacheImpl

java.lang.Object

org.hornetq.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.

Author:

clebertsuconic

Constructor Summary

Constructors

Constructor and Description
LivePageCacheImpl(Page page)

Method Summary

Methods

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

LivePageCacheImpl

public LivePageCacheImpl(Page page)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

getPage

public Page getPage()

Specified by:

getPage in interface PageCache

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:

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

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

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