org.apache.qpid.server.queue
Class ConflationQueueList

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

public class ConflationQueueList
extends SimpleQueueEntryList


Nested Class Summary
(package private) static class ConflationQueueList.Factory
           
 
Nested classes/interfaces inherited from class org.apache.qpid.server.queue.SimpleQueueEntryList
SimpleQueueEntryList.QueueEntryIteratorImpl
 
Field Summary
 
Fields inherited from class org.apache.qpid.server.queue.SimpleQueueEntryList
_nextUpdater, _tailUpdater
 
Constructor Summary
ConflationQueueList(AMQQueue queue, String conflationKey)
           
 
Method Summary
 QueueEntry add(ServerMessage message)
           
protected  org.apache.qpid.server.queue.ConflationQueueList.ConflationQueueEntry createQueueEntry(ServerMessage message)
           
 String getConflationKey()
           
 
Methods inherited from class org.apache.qpid.server.queue.SimpleQueueEntryList
advanceHead, getHead, getQueue, iterator, next, scavenge
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ConflationQueueList

public ConflationQueueList(AMQQueue queue,
                           String conflationKey)
Method Detail

getConflationKey

public String getConflationKey()

createQueueEntry

protected org.apache.qpid.server.queue.ConflationQueueList.ConflationQueueEntry createQueueEntry(ServerMessage message)
Overrides:
createQueueEntry in class SimpleQueueEntryList

add

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


Licensed to the Apache Software Foundation