|
synchronized
T
|
get(long timeout)
Wait for a value, and when one arrives, return it (without clearing it).
|
|
synchronized
T
|
get()
Wait for a value, and when one arrives, return it (without clearing it).
|
|
synchronized
void
|
set(T newValue)
Store a value in this BlockingCell, throwing AssertionError if the cell already has a value.
|
|
synchronized
boolean
|
setIfUnset(T newValue)
Store a value in this BlockingCell if it doesn't already have a value.
|
|
synchronized
T
|
uninterruptibleGet()
As get(), but catches and ignores InterruptedException, retrying until a value appears.
|
|
synchronized
T
|
uninterruptibleGet(int timeout)
As get(long timeout), but catches and ignores InterruptedException, retrying until
a value appears or until specified timeout is reached.
|
From class
com.rabbitmq.utility.BlockingCell