Project JXTA

net.jxta.impl.pipe
Class UnicastInputPipeImpl

java.lang.Object
  extended by net.jxta.impl.pipe.InputPipeImpl
      extended by net.jxta.impl.pipe.UnicastInputPipeImpl
All Implemented Interfaces:
EndpointListener, InputPipe
Direct Known Subclasses:
SecureInputPipeImpl

 class UnicastInputPipeImpl
extends InputPipeImpl

Implements the InputPipe interface by listening on the endpoint for messages to service "PipeService" and a param of the Pipe ID.


Field Summary
 
Fields inherited from class net.jxta.impl.pipe.InputPipeImpl
closed, listener, pipeAdv, pipeID, queue, QUEUESIZE, registrar
 
Constructor Summary
UnicastInputPipeImpl(PipeResolver r, PipeAdvertisement adv, PipeMsgListener listener)
          Constructor for the InputPipeImpl object
 
Method Summary
 void close()
          
 
Methods inherited from class net.jxta.impl.pipe.InputPipeImpl
finalize, getAdvertisement, getName, getPipeID, getType, poll, processIncomingMessage, waitForMessage
 
Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

UnicastInputPipeImpl

UnicastInputPipeImpl(PipeResolver r,
                     PipeAdvertisement adv,
                     PipeMsgListener listener)
               throws IOException
Constructor for the InputPipeImpl object

Parameters:
r - pipe resolver
adv - pipe advertisement
listener - listener to receive messages
Throws:
IOException
Method Detail

close

public void close()

Specified by:
close in interface InputPipe
Overrides:
close in class InputPipeImpl

JXTA J2SE