|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.io.util.SpooledBoundedActiveMQMessageQueue
public class SpooledBoundedActiveMQMessageQueue
Implements a controlled thread safe queue, with ActiveMQMessages being spooled to disk for reading asynchronously.
Constructor Summary | |
---|---|
SpooledBoundedActiveMQMessageQueue(File dir,
String name)
Constructor for SpooledBoundedActiveMQMessageQueue |
|
SpooledBoundedActiveMQMessageQueue(File dir,
String name,
long maxDataLength,
int maxBlockSize)
Constructor for SpooledBoundedActiveMQMessageQueue |
Method Summary | |
---|---|
void |
clear()
clear the queue |
void |
close()
close this queue |
ActiveMQMessage |
dequeue()
|
ActiveMQMessage |
dequeue(long timeInMillis)
|
ActiveMQMessage |
dequeueNoWait()
|
void |
enqueue(ActiveMQMessage packet)
Place a ActiveMQMessage at the head of the Queue |
void |
enqueueNoBlock(ActiveMQMessage packet)
Enqueue a ActiveMQMessage without checking usage limits |
List |
getContents()
|
String |
getName()
|
boolean |
isEmpty()
|
boolean |
isFull()
|
boolean |
isStarted()
|
int |
size()
|
void |
start()
enable dequeueing |
void |
stop()
disable dequeueing |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public SpooledBoundedActiveMQMessageQueue(File dir, String name, long maxDataLength, int maxBlockSize) throws IOException
dir
- name
- maxDataLength
- maxBlockSize
-
IOException
public SpooledBoundedActiveMQMessageQueue(File dir, String name) throws IOException
dir
- name
-
IOException
Method Detail |
---|
public void enqueue(ActiveMQMessage packet) throws JMSException
packet
-
JMSException
public void enqueueNoBlock(ActiveMQMessage packet) throws JMSException
packet
-
JMSException
public ActiveMQMessage dequeue() throws JMSException, InterruptedException
JMSException
InterruptedException
public ActiveMQMessage dequeue(long timeInMillis) throws JMSException, InterruptedException
timeInMillis
- maximum time to wait to dequeue a ActiveMQMessage
JMSException
InterruptedException
public ActiveMQMessage dequeueNoWait() throws JMSException, InterruptedException
JMSException
InterruptedException
public boolean isFull()
public void close()
public String getName()
public int size()
public boolean isStarted()
public void stop()
public void start()
public boolean isEmpty()
public void clear()
public List getContents()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |