|
JXTA | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.jxta.impl.util.pipe.reliable.OutgoingPipeAdaptorSync
public class OutgoingPipeAdaptorSync
And ountgoing pipe adaptor which does not use a thread or queue. Additionally, the pipe does not need to be provided at construction time. The send() method blocks until the pipe is specified.
Constructor Summary | |
---|---|
OutgoingPipeAdaptorSync(OutputPipe pipe)
|
Method Summary | |
---|---|
void |
close()
Close the connection. |
long |
getIdleTimeout()
Amount of time after which a connection is considered idle and may be scavenged. |
long |
getLastAccessed()
Get the time when this connection was last used. |
long |
getMaxRetryAge()
Amount if time during which retries may remain queued for retransmission. |
long |
getMinIdleReconnectTime()
Amount of a connection must be idle before a reconnection attempt will be considered. |
boolean |
send(Message msg)
Send a message to the remote peer. |
boolean |
sendNb(Message msg)
|
void |
setLastAccessed(long time)
Set the time when this connection was last used. |
void |
setPipe(OutputPipe pipe)
|
void |
setTimeout(int timeout)
Sets the Timeout attribute. |
String |
toString()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public OutgoingPipeAdaptorSync(OutputPipe pipe)
Method Detail |
---|
public boolean sendNb(Message msg) throws IOException
IOException
public boolean send(Message msg) throws IOException
Outgoing
send
in interface Outgoing
msg
- the message
IOException
- if io error occurspublic void setPipe(OutputPipe pipe)
public void close()
close
in interface Outgoing
public long getMinIdleReconnectTime()
getMinIdleReconnectTime
in interface Outgoing
public long getIdleTimeout()
getIdleTimeout
in interface Outgoing
public void setTimeout(int timeout)
setTimeout
in interface Outgoing
timeout
- The new soTimeout valuepublic long getMaxRetryAge()
getMaxRetryAge
in interface Outgoing
public long getLastAccessed()
getLastAccessed
in interface Outgoing
public void setLastAccessed(long time)
setLastAccessed
in interface Outgoing
time
- in millispublic String toString()
toString
in class Object
|
JXSE | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |