Package | Description |
---|---|
org.apache.activemq.kaha |
fast message persistence implementation
|
org.apache.activemq.kaha.impl |
Kaha implementation classes
|
org.apache.activemq.store.kahadaptor |
kaha implementation of message persistence for the broker
|
Modifier and Type | Method and Description |
---|---|
static Store |
StoreFactory.open(java.io.File directory,
java.lang.String mode)
Open or create a Store
|
static Store |
StoreFactory.open(java.io.File directory,
java.lang.String mode,
java.util.concurrent.atomic.AtomicLong size)
Open or create a Store
|
static Store |
StoreFactory.open(java.lang.String name,
java.lang.String mode)
open or create a Store
|
static Store |
StoreFactory.open(java.lang.String name,
java.lang.String mode,
java.util.concurrent.atomic.AtomicLong size)
open or create a Store
|
Modifier and Type | Class and Description |
---|---|
class |
KahaStore
Store Implementation
|
Modifier and Type | Method and Description |
---|---|
protected Store |
KahaPersistenceAdapter.createStore() |
protected Store |
KahaReferenceStoreAdapter.getStateStore() |
protected Store |
KahaPersistenceAdapter.getStore() |
Constructor and Description |
---|
KahaTopicMessageStore(Store store,
MapContainer<MessageId,Message> messageContainer,
ListContainer<TopicSubAck> ackContainer,
MapContainer<java.lang.String,SubscriptionInfo> subsContainer,
ActiveMQDestination destination) |
KahaTopicReferenceStore(Store store,
KahaReferenceStoreAdapter adapter,
MapContainer<MessageId,ReferenceRecord> messageContainer,
ListContainer<TopicSubAck> ackContainer,
MapContainer<java.lang.String,SubscriptionInfo> subsContainer,
ActiveMQDestination destination) |
Copyright © 2005-2012. All Rights Reserved.