Project JXTA

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.


Field Summary
 boolean debugFlag
           
 
Constructor Summary
NonBlockingOutputPipe(net.jxta.peergroup.PeerGroup g, PipeResolver r, net.jxta.pipe.PipeID opId, java.lang.String destPeer, long timeout)
           
 
Method Summary
 void close()
          close the the pipe
 void debug(java.lang.String str)
           
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
 

Field Detail

debugFlag

public boolean debugFlag
Constructor Detail

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
Method Detail

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

debug

public void debug(java.lang.String str)

Project JXTA