Package | Description |
---|---|
org.apache.activemq.store.kahadb | |
org.apache.activemq.store.kahadb.data |
Modifier and Type | Field and Description |
---|---|
protected KahaDestination |
TempKahaDBStore.KahaDBMessageStore.dest |
protected KahaDestination |
KahaDBStore.KahaDBMessageStore.dest |
Modifier and Type | Method and Description |
---|---|
protected void |
MessageDatabase.clearStoreStats(KahaDestination kahaDestination)
Clear the counter for the destination, if one exists.
|
protected void |
MessageDatabase.decrementAndSubSizeToStoreStat(KahaDestination kahaDestination,
long size) |
protected void |
MessageDatabase.decrementAndSubSizeToStoreStat(KahaDestination kahaDestination,
String subKey,
long size) |
protected org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination |
MessageDatabase.getExistingStoredDestination(KahaDestination destination,
Transaction tx) |
protected org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination |
MessageDatabase.getStoredDestination(KahaDestination destination,
Transaction tx) |
protected org.apache.activemq.store.kahadb.TempMessageDatabase.StoredDestination |
TempMessageDatabase.getStoredDestination(KahaDestination destination,
Transaction tx) |
protected void |
MessageDatabase.incrementAndAddSizeToStoreStat(KahaDestination kahaDestination,
long size)
Update MessageStoreStatistics
|
protected void |
MessageDatabase.incrementAndAddSizeToStoreStat(KahaDestination kahaDestination,
String subKey,
long size) |
protected String |
MessageDatabase.key(KahaDestination destination) |
Modifier and Type | Method and Description |
---|---|
KahaDestination |
KahaDestination.clone() |
KahaDestination |
KahaDestination.mergeFrom(KahaDestination other) |
KahaDestination |
KahaDestination.mergeUnframed(org.apache.activemq.protobuf.CodedInputStream input) |
static KahaDestination |
KahaDestination.parseFramed(org.apache.activemq.protobuf.Buffer data) |
static KahaDestination |
KahaDestination.parseFramed(byte[] data) |
static KahaDestination |
KahaDestination.parseFramed(org.apache.activemq.protobuf.CodedInputStream data) |
static KahaDestination |
KahaDestination.parseFramed(InputStream data) |
static KahaDestination |
KahaDestination.parseUnframed(org.apache.activemq.protobuf.Buffer data) |
static KahaDestination |
KahaDestination.parseUnframed(byte[] data) |
static KahaDestination |
KahaDestination.parseUnframed(org.apache.activemq.protobuf.CodedInputStream data) |
static KahaDestination |
KahaDestination.parseUnframed(InputStream data) |
Modifier and Type | Method and Description |
---|---|
boolean |
KahaDestination.equals(KahaDestination obj) |
KahaDestination |
KahaDestination.mergeFrom(KahaDestination other) |
Copyright © 2005–2016 The Apache Software Foundation. All rights reserved.