|
Project JXTA | ||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--net.jxta.impl.shell.ShellMessageQueue
Shell message queue for the Shell Input and Output PipeService
Field Summary | |
static int |
Max_Messages
|
Constructor Summary | |
ShellMessageQueue()
Default constructor |
Method Summary | |
void |
close()
close it |
int |
getMaxNbOfMessages()
how many messages will fit in this queue |
boolean |
isClosed()
Atomically return whether or not this queue has been closed. |
net.jxta.endpoint.Message |
next()
Return next message in the queue if there is one. |
net.jxta.endpoint.Message |
poll(long timeOut)
Gets a Message from the queue. |
void |
push(net.jxta.endpoint.Message message)
Push a TransportMessage onto the queue. |
void |
setMaxNbOfMessages(int maxMsgs)
Set how many messages this queue may store. |
net.jxta.endpoint.Message |
waitForMessage()
Wait until there is a Message in the queue, and return it. |
Methods inherited from class java.lang.Object |
clone,
equals,
finalize,
getClass,
hashCode,
notify,
notifyAll,
toString,
wait,
wait,
wait |
Field Detail |
public static final int Max_Messages
Constructor Detail |
public ShellMessageQueue()
Method Detail |
public void push(net.jxta.endpoint.Message message)
message
- TransportMessage to be pushed onto the queuepublic net.jxta.endpoint.Message next()
public net.jxta.endpoint.Message poll(long timeOut)
timeOut
- in mspublic net.jxta.endpoint.Message waitForMessage()
public boolean isClosed()
public void close()
public int getMaxNbOfMessages()
public void setMaxNbOfMessages(int maxMsgs)
maxMsgs
- The number of messages which the queue must be able to
store.
|
Project JXTA | ||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |