org.apache.qpid.server.queue
Class SimpleQueueEntryList

java.lang.Object
  extended by org.apache.qpid.server.queue.SimpleQueueEntryList
All Implemented Interfaces:
QueueEntryList
Direct Known Subclasses:
ConflationQueueList

public class SimpleQueueEntryList
extends Object
implements QueueEntryList


Nested Class Summary
(package private) static class SimpleQueueEntryList.Factory
           
static class SimpleQueueEntryList.QueueEntryIteratorImpl
           
 
Field Summary
(package private) static AtomicReferenceFieldUpdater<QueueEntryImpl,QueueEntryImpl> _nextUpdater
           
(package private) static AtomicReferenceFieldUpdater<SimpleQueueEntryList,QueueEntryImpl> _tailUpdater
           
 
Constructor Summary
SimpleQueueEntryList(AMQQueue queue)
           
 
Method Summary
 QueueEntry add(ServerMessage message)
           
(package private)  void advanceHead()
           
protected  QueueEntryImpl createQueueEntry(ServerMessage message)
           
 QueueEntry getHead()
           
 AMQQueue getQueue()
           
 QueueEntryIterator iterator()
           
 QueueEntry next(QueueEntry node)
           
(package private)  void scavenge()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

_tailUpdater

static final AtomicReferenceFieldUpdater<SimpleQueueEntryList,QueueEntryImpl> _tailUpdater

_nextUpdater

static final AtomicReferenceFieldUpdater<QueueEntryImpl,QueueEntryImpl> _nextUpdater
Constructor Detail

SimpleQueueEntryList

public SimpleQueueEntryList(AMQQueue queue)
Method Detail

advanceHead

void advanceHead()

scavenge

void scavenge()

getQueue

public AMQQueue getQueue()
Specified by:
getQueue in interface QueueEntryList

add

public QueueEntry add(ServerMessage message)
Specified by:
add in interface QueueEntryList

createQueueEntry

protected QueueEntryImpl createQueueEntry(ServerMessage message)

next

public QueueEntry next(QueueEntry node)
Specified by:
next in interface QueueEntryList

iterator

public QueueEntryIterator iterator()
Specified by:
iterator in interface QueueEntryList

getHead

public QueueEntry getHead()
Specified by:
getHead in interface QueueEntryList


Licensed to the Apache Software Foundation