Project JXTA

net.jxta.impl.util.pipe.reliable
Class OutgoingPipeAdaptorSync

java.lang.Object
  extended bynet.jxta.impl.util.pipe.reliable.OutgoingPipeAdaptorSync
All Implemented Interfaces:
Outgoing

public class OutgoingPipeAdaptorSync
extends Object
implements Outgoing


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)
           
 String toString()
          Return a human-friendly description of this connection.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

OutgoingPipeAdaptorSync

public OutgoingPipeAdaptorSync(OutputPipe pipe)
Method Detail

sendNb

public boolean sendNb(Message msg)
               throws IOException
Throws:
IOException

send

public boolean send(Message msg)
             throws IOException
Description copied from interface: Outgoing
Send a message to the remote peer.

Specified by:
send in interface Outgoing
Throws:
IOException

setPipe

public void setPipe(OutputPipe pipe)

close

public void close()
           throws IOException
Description copied from interface: Outgoing
Close the connection.

Specified by:
close in interface Outgoing
Throws:
IOException

getMinIdleReconnectTime

public long getMinIdleReconnectTime()
Description copied from interface: Outgoing
Amount of a connection must be idle before a reconnection attempt will be considered.

Specified by:
getMinIdleReconnectTime in interface Outgoing

getIdleTimeout

public long getIdleTimeout()
Description copied from interface: Outgoing
Amount of time after which a connection is considered idle and may be scavenged.

Specified by:
getIdleTimeout in interface Outgoing

getMaxRetryAge

public long getMaxRetryAge()
Description copied from interface: Outgoing
Amount if time during which retries may remain queued for retransmission. If still unACKed after this amount of time then the connection is considered dead.

Specified by:
getMaxRetryAge in interface Outgoing

getLastAccessed

public long getLastAccessed()
Description copied from interface: Outgoing
Get the time when this connection was last used.

Specified by:
getLastAccessed in interface Outgoing

setLastAccessed

public void setLastAccessed(long time)
Description copied from interface: Outgoing
Set the time when this connection was last used.

Specified by:
setLastAccessed in interface Outgoing

toString

public String toString()
Description copied from interface: Outgoing
Return a human-friendly description of this connection.

Specified by:
toString in interface Outgoing

JXTA J2SE