org.apache.activemq.store.kahadaptor
Class TopicSubContainer
java.lang.Object
org.apache.activemq.store.kahadaptor.TopicSubContainer
public class TopicSubContainer
- extends Object
Holds information for the subscriber
- Version:
- $Revision: 1.10 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TopicSubContainer
public TopicSubContainer(MapContainer container)
getBatchEntry
public StoreEntry getBatchEntry()
- Returns:
- the batchEntry
setBatchEntry
public void setBatchEntry(String id,
StoreEntry batchEntry)
- Parameters:
id
- batchEntry
- the batchEntry to set
reset
public void reset()
isEmpty
public boolean isEmpty()
add
public StoreEntry add(ConsumerMessageRef ref)
remove
public ConsumerMessageRef remove(MessageId id)
get
public ConsumerMessageRef get(StoreEntry entry)
getEntry
public StoreEntry getEntry()
refreshEntry
public StoreEntry refreshEntry(StoreEntry entry)
getNextEntry
public StoreEntry getNextEntry(StoreEntry entry)
iterator
public Iterator iterator()
size
public int size()
clear
public void clear()
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.