public class TopicSubContainer extends 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() |
Iterator |
iterator() |
StoreEntry |
refreshEntry(StoreEntry entry) |
ConsumerMessageRef |
remove(MessageId id) |
void |
reset() |
void |
setBatchEntry(String id,
StoreEntry batchEntry) |
int |
size() |
public TopicSubContainer(MapContainer container)
public StoreEntry getBatchEntry()
public void setBatchEntry(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 Iterator iterator()
public int size()
public void clear()
Copyright © 2005–2016 The Apache Software Foundation. All rights reserved.