|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.io.util.MemoryBoundedQueue
org.activemq.io.util.MemoryBoundedPrioritizedQueue
Field Summary |
Fields inherited from class org.activemq.io.util.MemoryBoundedQueue |
closed, inLock, outLock, stopped, WAIT_TIMEOUT |
Constructor Summary | |
MemoryBoundedPrioritizedQueue(MemoryBoundedQueueManager manager,
String name)
Constructor |
Method Summary | |
void |
clear()
remove any MemoryManageables in the queue |
MemoryManageable |
dequeue()
|
MemoryManageable |
dequeueNoWait()
dequeues a MemoryManageable from the head of the queue |
void |
enqueueAllFirstNoBlock(List packets)
Enqueue an array of packets to the head of the queue with total disregard for memory constraints |
void |
enqueueFirstNoBlock(MemoryManageable packet)
Enqueue a packet to the head of the queue with total disregard for memory constraints |
void |
enqueueNoBlock(MemoryManageable packet)
Enqueue a MemoryManageable without checking memory usage limits |
MemoryManageable |
get(int index)
retrieve a MemoryManageable at an indexed position in the queue |
List |
getContents()
Retrieve a shallow copy of the contents as a list |
boolean |
isEmpty()
|
boolean |
remove(MemoryManageable packet)
Remove a packet from the queue |
MemoryManageable |
remove(Object id)
Remove a MemoryManageable by it's id |
int |
size()
|
Methods inherited from class org.activemq.io.util.MemoryBoundedQueue |
close, decrementMemoryUsed, dequeue, enqueue, enqueueFirst, getLocalMemoryUsedByThisQueue, getName, incrementMemoryUsed, isStarted, start, stop, toString |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
public MemoryBoundedPrioritizedQueue(MemoryBoundedQueueManager manager, String name)
name
- manager
- Method Detail |
public int size()
size
in class MemoryBoundedQueue
public void enqueueNoBlock(MemoryManageable packet)
enqueueNoBlock
in class MemoryBoundedQueue
packet
- public final void enqueueFirstNoBlock(MemoryManageable packet)
enqueueFirstNoBlock
in class MemoryBoundedQueue
packet
- public void enqueueAllFirstNoBlock(List packets)
enqueueAllFirstNoBlock
in class MemoryBoundedQueue
packets
- public MemoryManageable dequeue() throws InterruptedException
dequeue
in class MemoryBoundedQueue
InterruptedException
public MemoryManageable dequeueNoWait() throws InterruptedException
dequeueNoWait
in class MemoryBoundedQueue
InterruptedException
public boolean remove(MemoryManageable packet)
remove
in class MemoryBoundedQueue
packet
-
public MemoryManageable remove(Object id)
remove
in class MemoryBoundedQueue
id
-
public void clear()
clear
in class MemoryBoundedQueue
public boolean isEmpty()
isEmpty
in class MemoryBoundedQueue
public MemoryManageable get(int index)
get
in class MemoryBoundedQueue
index
-
public List getContents()
getContents
in class MemoryBoundedQueue
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |