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.
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 |
InputPipeImpl
public InputPipeImpl(net.jxta.peergroup.PeerGroup g,
PipeResolver r,
net.jxta.pipe.PipeID ipId)
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