Project JXTA

net.jxta.impl.pipe
Class InputPipeImpl

java.lang.Object
  |
  +--net.jxta.impl.pipe.InputPipeImpl

public class InputPipeImpl
extends java.lang.Object
implements net.jxta.pipe.InputPipe, EndpointHandler

This class implements the Input PipeService.


Constructor Summary
InputPipeImpl(net.jxta.peergroup.PeerGroup g, PipeResolver r, net.jxta.pipe.PipeID ipId)
           
 
Method Summary
 void close()
          close the the pipe
 void demux(MessageImpl msg)
           
protected  void finalize()
           
 net.jxta.endpoint.Message poll(int timeout)
          Poll for a message from the pipe
 net.jxta.endpoint.Message waitForMessage()
          wait for a message
 
Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

InputPipeImpl

public InputPipeImpl(net.jxta.peergroup.PeerGroup g,
                     PipeResolver r,
                     net.jxta.pipe.PipeID ipId)
Method Detail

waitForMessage

public net.jxta.endpoint.Message waitForMessage()
                                         throws java.io.IOException
wait for a message
Specified by:
waitForMessage in interface net.jxta.pipe.InputPipe
Returns:
Message message received

poll

public net.jxta.endpoint.Message poll(int timeout)
                               throws java.io.IOException
Poll for a message from the pipe
Specified by:
poll in interface net.jxta.pipe.InputPipe
Returns:
Message message received

close

public void close()
close the the pipe
Specified by:
close in interface net.jxta.pipe.InputPipe

finalize

protected void finalize()
                 throws java.lang.Throwable
Overrides:
finalize in class java.lang.Object

demux

public void demux(MessageImpl msg)
Specified by:
demux in interface EndpointHandler

Project JXTA