Package | Description |
---|---|
org.apache.activemq.kaha |
fast message persistence implementation
|
org.apache.activemq.kaha.impl.container |
Map and List container implementations for Kaha
|
org.apache.activemq.kaha.impl.index |
Kaha index - type classes for the Map Container - including VM implementation
|
org.apache.activemq.kaha.impl.index.hash |
disk based Hash implementation of an index for a Map
|
org.apache.activemq.kaha.impl.index.tree |
BTree implementation of an index for a Map
|
org.apache.activemq.store.kahadaptor |
kaha implementation of message persistence for the broker
|
Modifier and Type | Method and Description |
---|---|
StoreEntry |
MapContainer.getEntry(K key)
Get the StoreEntry associated with the key
|
StoreEntry |
ListContainer.getFirst()
Get the StoreEntry for the first item of the list
|
StoreEntry |
MapContainer.getFirst()
Get the StoreEntry for the first value in the Map
|
StoreEntry |
ListContainer.getLast()
Get the StoreEntry for the last item of the list
|
StoreEntry |
MapContainer.getLast()
Get the StoreEntry for the last value item of the Map
|
StoreEntry |
ListContainer.getNext(StoreEntry entry)
Get the next StoreEntry from the list
|
StoreEntry |
MapContainer.getNext(StoreEntry entry)
Get the next StoreEntry value from the map
|
StoreEntry |
ListContainer.getPrevious(StoreEntry entry)
Get the previous StoreEntry from the list
|
StoreEntry |
MapContainer.getPrevious(StoreEntry entry)
Get the previous StoreEntry from the map
|
StoreEntry |
MapContainer.place(K key,
V value)
Add an entry to the Store Map
|
StoreEntry |
ListContainer.placeFirst(V object)
insert an Object in first position int the list but get a StoreEntry of
its position
|
StoreEntry |
ListContainer.placeLast(V object)
add an Object to the list but get a StoreEntry of its position
|
StoreEntry |
ListContainer.refresh(StoreEntry entry)
It's possible that a StoreEntry could be come stale this will return an
upto date entry for the StoreEntry position
|
StoreEntry |
MapContainer.refresh(StoreEntry entry)
It's possible that a StoreEntry could be come stale this will return an
upto date entry for the StoreEntry position
|
Modifier and Type | Method and Description |
---|---|
V |
ListContainer.get(StoreEntry entry)
Retrieve an Object from the Store by its location
|
K |
MapContainer.getKey(StoreEntry keyLocation)
Get the Key object from it's location
|
StoreEntry |
ListContainer.getNext(StoreEntry entry)
Get the next StoreEntry from the list
|
StoreEntry |
MapContainer.getNext(StoreEntry entry)
Get the next StoreEntry value from the map
|
StoreEntry |
ListContainer.getPrevious(StoreEntry entry)
Get the previous StoreEntry from the list
|
StoreEntry |
MapContainer.getPrevious(StoreEntry entry)
Get the previous StoreEntry from the map
|
V |
MapContainer.getValue(StoreEntry valueLocation)
Get the value from it's location
|
StoreEntry |
ListContainer.refresh(StoreEntry entry)
It's possible that a StoreEntry could be come stale this will return an
upto date entry for the StoreEntry position
|
StoreEntry |
MapContainer.refresh(StoreEntry entry)
It's possible that a StoreEntry could be come stale this will return an
upto date entry for the StoreEntry position
|
boolean |
ListContainer.remove(StoreEntry entry)
remove the Object at the StoreEntry
|
void |
MapContainer.remove(StoreEntry entry)
Remove an Entry from ther Map
|
void |
ListContainer.update(StoreEntry entry,
V object)
Advanced feature = must ensure the object written doesn't overwrite other
objects in the container
|
Modifier and Type | Method and Description |
---|---|
StoreEntry |
MapContainerImpl.getEntry(java.lang.Object key)
Get the StoreEntry associated with the key
|
StoreEntry |
ListContainerImpl.getFirst()
Get the StoreEntry for the first item of the list
|
StoreEntry |
MapContainerImpl.getFirst() |
StoreEntry |
ListContainerImpl.getLast()
Get the StoreEntry for the last item of the list
|
StoreEntry |
MapContainerImpl.getLast() |
StoreEntry |
ListContainerImpl.getNext(StoreEntry entry)
Get the next StoreEntry from the list
|
StoreEntry |
MapContainerImpl.getNext(StoreEntry entry) |
StoreEntry |
ListContainerImpl.getPrevious(StoreEntry entry)
Get the previous StoreEntry from the list
|
StoreEntry |
MapContainerImpl.getPrevious(StoreEntry entry) |
protected StoreEntry |
ListContainerImpl.internalAddFirst(java.lang.Object o) |
protected StoreEntry |
ListContainerImpl.internalAddLast(java.lang.Object o) |
protected StoreEntry |
ListContainerImpl.internalGet(int index) |
StoreEntry |
MapContainerImpl.place(java.lang.Object key,
java.lang.Object value)
Add an entry to the Store Map
|
StoreEntry |
ListContainerImpl.placeFirst(java.lang.Object object)
insert an Object in first position int the list but get a StoreEntry of
its position
|
StoreEntry |
ListContainerImpl.placeLast(java.lang.Object object)
add an Object to the list but get a StoreEntry of its position
|
StoreEntry |
ListContainerImpl.refresh(StoreEntry entry)
It's possible that a StoreEntry could be come stale this will return an
upto date entry for the StoreEntry position
|
StoreEntry |
MapContainerImpl.refresh(StoreEntry entry) |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
ListContainerImpl.get(StoreEntry entry)
Retrieve an Object from the Store by its location
|
java.lang.Object |
MapContainerImpl.getKey(StoreEntry item)
Get the Key object from it's location
|
StoreEntry |
ListContainerImpl.getNext(StoreEntry entry)
Get the next StoreEntry from the list
|
StoreEntry |
MapContainerImpl.getNext(StoreEntry entry) |
StoreEntry |
ListContainerImpl.getPrevious(StoreEntry entry)
Get the previous StoreEntry from the list
|
StoreEntry |
MapContainerImpl.getPrevious(StoreEntry entry) |
protected abstract java.lang.Object |
BaseContainerImpl.getValue(StoreEntry currentItem) |
protected java.lang.Object |
ListContainerImpl.getValue(StoreEntry item) |
java.lang.Object |
MapContainerImpl.getValue(StoreEntry item)
Get the value from it's location
|
protected boolean |
BaseContainerImpl.isRoot(StoreEntry item) |
StoreEntry |
ListContainerImpl.refresh(StoreEntry entry)
It's possible that a StoreEntry could be come stale this will return an
upto date entry for the StoreEntry position
|
StoreEntry |
MapContainerImpl.refresh(StoreEntry entry) |
boolean |
ListContainerImpl.remove(StoreEntry entry)
remove the Object at the StoreEntry
|
void |
MapContainerImpl.remove(StoreEntry entry)
Remove an Entry from ther Map
|
void |
ListContainerImpl.update(StoreEntry entry,
java.lang.Object object) |
Modifier and Type | Class and Description |
---|---|
class |
IndexItem
A an Item with a relative position and location to other Items in the Store
|
Modifier and Type | Method and Description |
---|---|
StoreEntry |
VMIndex.get(java.lang.Object key) |
StoreEntry |
Index.get(java.lang.Object key) |
StoreEntry |
VMIndexLinkedList.getEntry(StoreEntry current) |
StoreEntry |
DiskIndexLinkedList.getEntry(StoreEntry current) |
StoreEntry |
IndexLinkedList.getEntry(StoreEntry entry)
Ensure we have the up to date entry
|
StoreEntry |
VMIndexLinkedList.refreshEntry(StoreEntry current)
Update the indexes of a StoreEntry
|
StoreEntry |
DiskIndexLinkedList.refreshEntry(StoreEntry current)
Update the indexes of a StoreEntry
|
StoreEntry |
IndexLinkedList.refreshEntry(StoreEntry current)
Update the indexes of a StoreEntry
|
StoreEntry |
VMIndex.remove(java.lang.Object key) |
StoreEntry |
Index.remove(java.lang.Object key)
remove the index key
|
StoreEntry |
VMIndexLinkedList.removeFirst() |
StoreEntry |
DiskIndexLinkedList.removeFirst()
Removes and returns the first element from this list.
|
StoreEntry |
IndexLinkedList.removeFirst()
Removes and returns the first element from this list.
|
Modifier and Type | Method and Description |
---|---|
StoreEntry |
VMIndexLinkedList.getEntry(StoreEntry current) |
StoreEntry |
DiskIndexLinkedList.getEntry(StoreEntry current) |
StoreEntry |
IndexLinkedList.getEntry(StoreEntry entry)
Ensure we have the up to date entry
|
int |
VMIndexLinkedList.indexOf(StoreEntry o) |
int |
DiskIndexLinkedList.indexOf(StoreEntry o)
Returns the index in this list of the first occurrence of the specified
element, or -1 if the List does not contain this element.
|
int |
IndexLinkedList.indexOf(StoreEntry o)
Returns the index in this list of the first occurrence of the specified
element, or -1 if the List does not contain this element.
|
StoreEntry |
VMIndexLinkedList.refreshEntry(StoreEntry current)
Update the indexes of a StoreEntry
|
StoreEntry |
DiskIndexLinkedList.refreshEntry(StoreEntry current)
Update the indexes of a StoreEntry
|
StoreEntry |
IndexLinkedList.refreshEntry(StoreEntry current)
Update the indexes of a StoreEntry
|
void |
VMIndex.store(java.lang.Object key,
StoreEntry entry) |
void |
Index.store(java.lang.Object key,
StoreEntry entry)
store the key, item
|
Modifier and Type | Method and Description |
---|---|
StoreEntry |
HashIndex.get(java.lang.Object key) |
StoreEntry |
HashIndex.remove(java.lang.Object key) |
Modifier and Type | Method and Description |
---|---|
void |
HashIndex.store(java.lang.Object key,
StoreEntry value) |
Modifier and Type | Method and Description |
---|---|
StoreEntry |
TreeIndex.get(java.lang.Object key) |
StoreEntry |
TreeIndex.remove(java.lang.Object key) |
Modifier and Type | Method and Description |
---|---|
void |
TreeIndex.store(java.lang.Object key,
StoreEntry value) |
Modifier and Type | Field and Description |
---|---|
protected StoreEntry |
KahaMessageStore.batchEntry |
Modifier and Type | Method and Description |
---|---|
StoreEntry |
TopicSubContainer.add(ConsumerMessageRef ref) |
StoreEntry |
ConsumerMessageRef.getAckEntry() |
StoreEntry |
TopicSubContainer.getBatchEntry() |
StoreEntry |
TopicSubContainer.getEntry() |
StoreEntry |
ConsumerMessageRef.getMessageEntry() |
StoreEntry |
TopicSubAck.getMessageEntry() |
StoreEntry |
TopicSubContainer.getNextEntry(StoreEntry entry) |
StoreEntry |
TopicSubContainer.refreshEntry(StoreEntry entry) |
Modifier and Type | Method and Description |
---|---|
ConsumerMessageRef |
TopicSubContainer.get(StoreEntry entry) |
StoreEntry |
TopicSubContainer.getNextEntry(StoreEntry entry) |
StoreEntry |
TopicSubContainer.refreshEntry(StoreEntry entry) |
void |
ConsumerMessageRef.setAckEntry(StoreEntry ackEntry) |
void |
TopicSubContainer.setBatchEntry(java.lang.String id,
StoreEntry batchEntry) |
void |
ConsumerMessageRef.setMessageEntry(StoreEntry messageEntry) |
void |
TopicSubAck.setMessageEntry(StoreEntry storeEntry) |
Copyright © 2005-2014. All Rights Reserved.