|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.io.util.SpooledBoundedActiveMQMessageQueue
Implements a controlled thread safe queue, with ActiveMQMessages being spooled to disk for reading asynchronously.
Constructor Summary | |
SpooledBoundedActiveMQMessageQueue(java.io.File dir,
java.lang.String name)
Constructor for SpooledBoundedActiveMQMessageQueue |
|
SpooledBoundedActiveMQMessageQueue(java.io.File dir,
java.lang.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 |
java.util.List |
getContents()
|
java.lang.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(java.io.File dir, java.lang.String name, long maxDataLength, int maxBlockSize) throws java.io.IOException
dir
- name
- maxDataLength
- maxBlockSize
-
java.io.IOException
public SpooledBoundedActiveMQMessageQueue(java.io.File dir, java.lang.String name) throws java.io.IOException
dir
- name
-
java.io.IOException
Method Detail |
public void enqueue(ActiveMQMessage packet) throws javax.jms.JMSException
packet
-
javax.jms.JMSException
public void enqueueNoBlock(ActiveMQMessage packet) throws javax.jms.JMSException
packet
-
javax.jms.JMSException
public ActiveMQMessage dequeue() throws javax.jms.JMSException, java.lang.InterruptedException
javax.jms.JMSException
java.lang.InterruptedException
public ActiveMQMessage dequeue(long timeInMillis) throws javax.jms.JMSException, java.lang.InterruptedException
timeInMillis
- maximum time to wait to dequeue a ActiveMQMessage
javax.jms.JMSException
java.lang.InterruptedException
public ActiveMQMessage dequeueNoWait() throws javax.jms.JMSException, java.lang.InterruptedException
javax.jms.JMSException
java.lang.InterruptedException
public boolean isFull()
public void close()
public java.lang.String getName()
public int size()
public boolean isStarted()
public void stop()
public void start()
public boolean isEmpty()
public void clear()
public java.util.List getContents()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |