org.apache.activemq.store.kahadaptor
public class TopicSubContainer extends java.lang.Object
Constructor and Description |
---|
TopicSubContainer(MapContainer container) |
Modifier and Type | Method and Description |
---|---|
StoreEntry |
add(ConsumerMessageRef ref) |
void |
clear() |
ConsumerMessageRef |
get(StoreEntry entry) |
StoreEntry |
getBatchEntry() |
StoreEntry |
getEntry() |
StoreEntry |
getNextEntry(StoreEntry entry) |
boolean |
isEmpty() |
java.util.Iterator |
iterator() |
StoreEntry |
refreshEntry(StoreEntry entry) |
ConsumerMessageRef |
remove(MessageId id) |
void |
reset() |
void |
setBatchEntry(java.lang.String id,
StoreEntry batchEntry) |
int |
size() |
public TopicSubContainer(MapContainer container)
public StoreEntry getBatchEntry()
public void setBatchEntry(java.lang.String id, StoreEntry batchEntry)
id
- batchEntry
- the batchEntry to setpublic void reset()
public boolean isEmpty()
public StoreEntry add(ConsumerMessageRef ref)
public ConsumerMessageRef remove(MessageId id)
public ConsumerMessageRef get(StoreEntry entry)
public StoreEntry getEntry()
public StoreEntry refreshEntry(StoreEntry entry)
public StoreEntry getNextEntry(StoreEntry entry)
public java.util.Iterator iterator()
public int size()
public void clear()
Copyright © 2005-2014. All Rights Reserved.