org.apache.catalina.tribes.transport.bio.util
public class FastQueue extends Object
Version: $Revision: 500684 $ $Date: 2007-01-28 00:27:18 +0100 (Sun, 28 Jan 2007) $
Constructor Summary | |
---|---|
FastQueue()
Generate Queue SingleRemoveSynchronizedAddLock and set add and wait
Timeouts |
Method Summary | |
---|---|
boolean | add(ChannelMessage msg, Member[] destination, InterceptorPayload payload)
Add new data to the queue |
long | getAddWaitTimeout()
get current add wait timeout
|
SingleRemoveSynchronizedAddLock | getLock() |
int | getMaxQueueLength()
get Max Queue length
|
int | getMaxSize() |
long | getRemoveWaitTimeout()
get current remove wait timeout
|
int | getSize() |
boolean | isCheckLock() |
boolean | isEnabled() |
LinkObject | remove()
remove the complete queued object list |
void | setAddWaitTimeout(long timeout)
Set add wait timeout (default 10000 msec)
|
void | setCheckLock(boolean checkLock) |
void | setEnabled(boolean enable) |
void | setMaxQueueLength(int length) |
void | setMaxSize(int size) |
void | setRemoveWaitTimeout(long timeout)
set remove wait timeout ( default 30000 msec)
|
void | start()
start queuing |
void | stop()
start queuing |
void | unlockAdd()
unlock queue for next add |
void | unlockRemove()
unlock queue for next remove |
See Also: org.apache.catalina.tribes.util.IQueue#add(java.lang.String, java.lang.Object)
FIXME extract some method
Returns: current wait timeout
See Also: org.apache.catalina.tribes.util.IQueue#getMaxQueueLength()
Returns: The max size
Returns: The timeout
Returns: Returns the checkLock.
See Also: org.apache.catalina.tribes.util.IQueue#remove()
FIXME extract some method
Parameters: timeout
Parameters: checkLock The checkLock to set.
Parameters: size
Parameters: timeout