Project JXTA

net.jxta.impl.pipe
Class SecureInputPipeImpl

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

public class SecureInputPipeImpl
extends UnicastInputPipeImpl

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
SecureInputPipeImpl(PipeResolver r, PipeAdvertisement adv)
          Constructor for the SecureInputPipeImpl object
SecureInputPipeImpl(PipeResolver r, PipeAdvertisement adv, PipeMsgListener listener)
          Constructor for the SecureInputPipeImpl object
 
Method Summary
 void processIncomingMessage(Message msg, EndpointAddress srcAddr, EndpointAddress dstAddr)
          
 
Methods inherited from class net.jxta.impl.pipe.UnicastInputPipeImpl
close
 
Methods inherited from class net.jxta.impl.pipe.InputPipeImpl
finalize, getAdvertisement, getName, getPipeID, getType, poll, waitForMessage
 
Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SecureInputPipeImpl

SecureInputPipeImpl(PipeResolver r,
                    PipeAdvertisement adv)
              throws IOException
Constructor for the SecureInputPipeImpl object

Parameters:
r - pipe resolver
adv - pipe advertisement
Throws:
IOException

SecureInputPipeImpl

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

Parameters:
r - pipe resolver
adv - pipe advertisement
Throws:
IOException
Method Detail

processIncomingMessage

public void processIncomingMessage(Message msg,
                                   EndpointAddress srcAddr,
                                   EndpointAddress dstAddr)

Specified by:
processIncomingMessage in interface EndpointListener
Overrides:
processIncomingMessage in class InputPipeImpl

JXTA J2SE