Package | Description |
---|---|
org.apache.activemq.kaha |
fast message persistence implementation
|
org.apache.activemq.kaha.impl |
Kaha implementation classes
|
org.apache.activemq.kaha.impl.async |
journal based data storage - scalable and fast
|
org.apache.activemq.kaha.impl.container |
Map and List container implementations for Kaha
|
org.apache.activemq.kaha.impl.data |
Data containers 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 | Class and Description |
---|---|
class |
BytesMarshaller
Implementation of a Marshaller for byte arrays
|
class |
CommandMarshaller
Marshall a Message or a MessageReference
|
class |
MessageIdMarshaller
Implementation of a Marshaller for MessageIds
|
class |
MessageMarshaller
Implementation of a Marshaller for MessageIds
|
class |
ObjectMarshaller
Implementation of a Marshaller for Objects
|
class |
StringMarshaller
Implementation of a Marshaller for Strings
|
Modifier and Type | Field and Description |
---|---|
static Marshaller |
Store.BYTES_MARSHALLER
Byte Marshaller
|
static Marshaller |
Store.COMMAND_MARSHALLER
Command Marshaller
|
static Marshaller |
Store.MESSAGEID_MARSHALLER
MessageId marshaller
|
static Marshaller |
Store.OBJECT_MARSHALLER
Object Marshaller
|
static Marshaller |
Store.STRING_MARSHALLER
String Marshaller
|
Modifier and Type | Method and Description |
---|---|
void |
MapContainer.setKeyMarshaller(Marshaller<K> keyMarshaller)
For homogenous containers can set a custom marshaller for loading keys
The default uses Object serialization
|
void |
ListContainer.setMarshaller(Marshaller marshaller)
For homogenous containers can set a custom marshaller for loading values
The default uses Object serialization
|
void |
MapContainer.setValueMarshaller(Marshaller<V> valueMarshaller)
For homogenous containers can set a custom marshaller for loading values
The default uses Object serialization
|
Modifier and Type | Method and Description |
---|---|
Marshaller |
DataManager.getRedoMarshaller() |
Modifier and Type | Method and Description |
---|---|
Object |
DataManager.readItem(Marshaller marshaller,
StoreLocation item) |
void |
DataManager.setRedoMarshaller(Marshaller redoMarshaller) |
StoreLocation |
DataManager.storeDataItem(Marshaller marshaller,
Object payload) |
void |
DataManager.updateItem(StoreLocation location,
Marshaller marshaller,
Object payload) |
Modifier and Type | Method and Description |
---|---|
Marshaller |
DataManagerFacade.getRedoMarshaller() |
Modifier and Type | Method and Description |
---|---|
Object |
DataManagerFacade.readItem(Marshaller marshaller,
StoreLocation location) |
void |
DataManagerFacade.setRedoMarshaller(Marshaller redoMarshaller) |
StoreLocation |
DataManagerFacade.storeDataItem(Marshaller marshaller,
Object payload) |
void |
DataManagerFacade.updateItem(StoreLocation location,
Marshaller marshaller,
Object payload) |
Modifier and Type | Field and Description |
---|---|
protected Marshaller |
MapContainerImpl.keyMarshaller |
protected Marshaller |
ListContainerImpl.marshaller |
protected Marshaller |
MapContainerImpl.valueMarshaller |
Modifier and Type | Method and Description |
---|---|
void |
MapContainerImpl.setKeyMarshaller(Marshaller keyMarshaller) |
void |
ListContainerImpl.setMarshaller(Marshaller marshaller) |
void |
MapContainerImpl.setValueMarshaller(Marshaller valueMarshaller) |
Modifier and Type | Method and Description |
---|---|
Marshaller |
DataManagerImpl.getRedoMarshaller() |
Modifier and Type | Method and Description |
---|---|
Object |
SyncDataFileReader.readItem(Marshaller marshaller,
StoreLocation item) |
Object |
DataManagerImpl.readItem(Marshaller marshaller,
StoreLocation item) |
void |
DataManagerImpl.setRedoMarshaller(Marshaller redoMarshaller) |
StoreLocation |
DataManagerImpl.storeDataItem(Marshaller marshaller,
Object payload) |
DataItem |
SyncDataFileWriter.storeItem(Marshaller marshaller,
Object payload,
byte type) |
void |
SyncDataFileWriter.updateItem(DataItem item,
Marshaller marshaller,
Object payload,
byte type) |
void |
DataManagerImpl.updateItem(StoreLocation location,
Marshaller marshaller,
Object payload) |
Modifier and Type | Field and Description |
---|---|
static Marshaller |
RedoStoreIndexItem.MARSHALLER |
Modifier and Type | Method and Description |
---|---|
void |
Index.setKeyMarshaller(Marshaller marshaller)
Set the marshaller for key objects
|
void |
VMIndex.setKeyMarshaller(Marshaller marshaller) |
Modifier and Type | Method and Description |
---|---|
void |
HashIndex.setKeyMarshaller(Marshaller marshaller)
Set the marshaller for key objects
|
Modifier and Type | Method and Description |
---|---|
void |
TreeIndex.setKeyMarshaller(Marshaller marshaller)
Set the marshaller for key objects
|
Modifier and Type | Class and Description |
---|---|
class |
AMQTxMarshaller
Marshall an AMQTx
|
class |
AtomicIntegerMarshaller
Marshall an AtomicInteger
|
class |
ConsumerMessageRefMarshaller
Marshall a TopicSubAck
|
class |
IntegerMarshaller
Marshall an Integer
|
class |
ReferenceRecordMarshaller |
class |
StoreEntryMarshaller
Marshall a TopicSubAck
|
class |
TopicSubAckMarshaller
Marshall a TopicSubAck
|
class |
TransactionMarshaller
Marshall a Transaction
|
Modifier and Type | Method and Description |
---|---|
protected Marshaller<Object> |
KahaPersistenceAdapter.createMessageMarshaller() |
Copyright © 2005-2012 Apache Software Foundation. All Rights Reserved.