java.lang .Object org.apache.catalina.tribes.transport.bio.util .FastQueue FastQueue public class FastQueue (Code) A fast queue that remover thread lock the adder thread. Limit the queue
length when you have strange producer thread problemes.
FIXME add i18n support to log messages
author: Rainer Jungauthor: Peter Rossbachversion: $Revision: 500684 $ $Date: 2007-01-28 00:27:18 +0100 (dim., 28 janv. 2007) $
FastQueue public FastQueue()(Code) Generate Queue SingleRemoveSynchronizedAddLock and set add and wait
Timeouts
add public boolean add(ChannelMessage msg, Member [] destination, InterceptorPayload payload)(Code) Add new data to the queue
See Also: org.apache.catalina.tribes.util.IQueue.add(java.lang.Stringjava.lang.Object)See Also: FIXME extract some method
getAddWaitTimeout public long getAddWaitTimeout()(Code) get current add wait timeout
current wait timeout
getMaxQueueLength public int getMaxQueueLength()(Code) get Max Queue length
See Also: org.apache.catalina.tribes.util.IQueue.getMaxQueueLength
getMaxSize public int getMaxSize()(Code) The max size
getRemoveWaitTimeout public long getRemoveWaitTimeout()(Code) get current remove wait timeout
The timeout
getSize public int getSize()(Code)
isCheckLock public boolean isCheckLock()(Code) Returns the checkLock.
isEnabled public boolean isEnabled()(Code)
remove public LinkObject remove()(Code) remove the complete queued object list
See Also: org.apache.catalina.tribes.util.IQueue.removeSee Also: FIXME extract some method
setAddWaitTimeout public void setAddWaitTimeout(long timeout)(Code) Set add wait timeout (default 10000 msec)
Parameters: timeout -
setCheckLock public void setCheckLock(boolean checkLock)(Code) Parameters: checkLock - The checkLock to set.
setEnabled public void setEnabled(boolean enable)(Code)
setMaxQueueLength public void setMaxQueueLength(int length)(Code)
setMaxSize public void setMaxSize(int size)(Code) Parameters: size -
setRemoveWaitTimeout public void setRemoveWaitTimeout(long timeout)(Code) set remove wait timeout ( default 30000 msec)
Parameters: timeout -
start public void start()(Code) start queuing
stop public void stop()(Code) start queuing
unlockAdd public void unlockAdd()(Code) unlock queue for next add
unlockRemove public void unlockRemove()(Code) unlock queue for next remove