A two-way unbounded-length message queue useful for communication between threads. Messages written on one side become readable on the other in first-in, first-out order. This is an interface to one of two "sides" of an underlying backend, for example, the MessageQueueBackend.
| Modifier and Type | Method and Description |
|---|---|
| public Object | |
| public Object | readMessageWithTimeout(long millis)
This blocks for up to |
| public void |
| readMessage | back to summary |
|---|---|
| public Object readMessage() This blocks until a message is available. Even if the thread is interrupted while it is waiting, this will not return until a message is written by the entity on the other side of the queue. | |
| readMessageWithTimeout | back to summary |
|---|---|
| public Object readMessageWithTimeout(long millis) This blocks for up to | |
| writeMessage | back to summary |
|---|---|
| public void writeMessage(Object obj) Write a message to the queue | |