Package org.apache.activemq.store.kahadb.plist

Class PListImpl

java.lang.Object

org.apache.activemq.store.kahadb.disk.index.ListIndex<String,Location>

org.apache.activemq.store.kahadb.plist.PListImpl

All Implemented Interfaces:

Index<String,Location>, org.apache.activemq.store.PList

public class PListImpl
extends ListIndex<String,Location>
implements org.apache.activemq.store.PList

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.activemq.store.PList

org.apache.activemq.store.PList.PListIterator

Field Summary

Fields inherited from class org.apache.activemq.store.kahadb.disk.index.ListIndex

headPageId, loaded, NOT_SET, pageFile, tailPageId

Method Summary

Modifier and Type	Method	Description
Location	add(Transaction tx, String key, Location value)
Object	addFirst(String id, org.apache.activemq.util.ByteSequence bs)
Location	addFirst(Transaction tx, String key, Location value)
Object	addLast(String id, org.apache.activemq.util.ByteSequence bs)
void	claimFileLocations(Set<Integer> candidates)
void	clear(Transaction tx)	clear the index
void	destroy()
org.apache.activemq.store.PListEntry	get(long position)
org.apache.activemq.store.PListEntry	getFirst()
org.apache.activemq.store.PListEntry	getLast()
String	getName()
boolean	isEmpty()
org.apache.activemq.store.PList.PListIterator	iterator()
long	messageSize()
protected void	onLoad(ListNode<String,Location> node, Transaction tx)
void	onRemove(Map.Entry<String,Location> removed)
boolean	remove(long position)
boolean	remove(Object l)
boolean	remove(String id)
void	setName(String name)
String	toString()
void	write(DataOutput out)

Methods inherited from class org.apache.activemq.store.kahadb.disk.index.ListIndex

containsKey, createNode, get, getFirst, getHead, getHeadPageId, getKeyMarshaller, getLast, getPageFile, getTail, getTailPageId, getValueMarshaller, isEmpty, isTransient, iterator, iterator, listNodeIterator, load, put, remove, setHeadPageId, setKeyMarshaller, setPageFile, setTailPageId, setValueMarshaller, size, storeNode, unload

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.store.PList

size

Method Details

setName

public void setName(String name)

getName

public String getName()

Specified by:

getName in interface org.apache.activemq.store.PList

write

public void write(DataOutput out)
           throws IOException

Throws:

IOException

destroy

public void destroy()
             throws IOException

Specified by:

destroy in interface org.apache.activemq.store.PList

Throws:

IOException

addLast

public Object addLast(String id,
 org.apache.activemq.util.ByteSequence bs)
               throws IOException

Specified by:

addLast in interface org.apache.activemq.store.PList

Throws:

IOException

addFirst

public Object addFirst(String id,
 org.apache.activemq.util.ByteSequence bs)
                throws IOException

Specified by:

addFirst in interface org.apache.activemq.store.PList

Throws:

IOException

remove

public boolean remove(Object l)
               throws IOException

Specified by:

remove in interface org.apache.activemq.store.PList

Throws:

IOException

remove

public boolean remove(String id)
               throws IOException

Throws:

IOException

remove

public boolean remove(long position)
               throws IOException

Throws:

IOException

get

public org.apache.activemq.store.PListEntry get(long position)
                                         throws IOException

Throws:

IOException

getFirst

public org.apache.activemq.store.PListEntry getFirst()
                                              throws IOException

Throws:

IOException

getLast

public org.apache.activemq.store.PListEntry getLast()
                                             throws IOException

Throws:

IOException

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface org.apache.activemq.store.PList

iterator

public org.apache.activemq.store.PList.PListIterator iterator()
                                                       throws IOException

Specified by:

iterator in interface org.apache.activemq.store.PList

Throws:

IOException

claimFileLocations

public void claimFileLocations(Set<Integer> candidates)
                        throws IOException

Throws:

IOException

messageSize

public long messageSize()

Specified by:

messageSize in interface org.apache.activemq.store.PList

add

public Location add(Transaction tx,
 String key,
 Location value)
             throws IOException

Overrides:

add in class ListIndex<String,Location>

Throws:

IOException

addFirst

public Location addFirst(Transaction tx,
 String key,
 Location value)
                  throws IOException

Overrides:

addFirst in class ListIndex<String,Location>

Throws:

IOException

clear

public void clear(Transaction tx)
           throws IOException

Description copied from interface: Index

clear the index

Specified by:

clear in interface Index<String,Location>

Overrides:

clear in class ListIndex<String,Location>

Throws:

IOException

onLoad

protected void onLoad(ListNode<String,Location> node,
 Transaction tx)

Overrides:

onLoad in class ListIndex<String,Location>

onRemove

public void onRemove(Map.Entry<String,Location> removed)

Overrides:

onRemove in class ListIndex<String,Location>

toString

public String toString()

Overrides:

toString in class Object