net.jxta.impl.pipe
Class NonBlockingOutputPipe
java.lang.Object
|
+--net.jxta.impl.pipe.NonBlockingOutputPipe
- public class NonBlockingOutputPipe
- extends java.lang.Object
- implements net.jxta.pipe.OutputPipe
This class implements the non blocking Output PipeService.
Method Summary |
void |
close()
close the the pipe |
protected void |
finalize()
|
void |
send(net.jxta.endpoint.Message msg)
send a message |
Methods inherited from class java.lang.Object |
clone,
equals,
getClass,
hashCode,
notify,
notifyAll,
toString,
wait,
wait,
wait |
NonBlockingOutputPipe
public NonBlockingOutputPipe(net.jxta.peergroup.PeerGroup g,
PipeResolver r,
net.jxta.pipe.PipeID opId,
java.lang.String destPeer,
long timeout)
throws java.io.IOException
send
public void send(net.jxta.endpoint.Message msg)
throws java.io.IOException
- send a message
- Specified by:
- send in interface net.jxta.pipe.OutputPipe
- Parameters:
msg
- is the PipeMessage to be sent.
close
public void close()
- close the the pipe
- Specified by:
- close in interface net.jxta.pipe.OutputPipe
finalize
protected void finalize()
throws java.lang.Throwable
- Overrides:
- finalize in class java.lang.Object