org.apache.activemq.store.kahadaptor
Class TopicSubContainer

java.lang.Object
  extended by org.apache.activemq.store.kahadaptor.TopicSubContainer

public class TopicSubContainer
extends Object

Holds information for the subscriber


Constructor Summary
TopicSubContainer(MapContainer container)
           
 
Method Summary
 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()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TopicSubContainer

public TopicSubContainer(MapContainer container)
Method Detail

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-2013 The Apache Software Foundation. All Rights Reserved.