JXTA

net.jxta.impl.pipe
Class SecureInputPipeImpl

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

public class SecureInputPipeImpl
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
SecureInputPipeImpl(PipeResolver pipeResolver, 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)
          This method is invoked by the EndpointService for each incoming message which is addressed to this listener.
 
Methods inherited from class net.jxta.impl.pipe.InputPipeImpl
close, 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 pipeResolver,
                    PipeAdvertisement adv)
              throws IOException
Constructor for the SecureInputPipeImpl object

Parameters:
pipeResolver - pipe resolver
adv - pipe advertisement
Throws:
IOException - if an io error occurs

SecureInputPipeImpl

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

Parameters:
r - pipe resolver
adv - the pipe advertisement
listener - the message listener
Throws:
IOException - if an io error occurs
Method Detail

processIncomingMessage

public void processIncomingMessage(Message msg,
                                   EndpointAddress srcAddr,
                                   EndpointAddress dstAddr)
This method is invoked by the EndpointService for each incoming message which is addressed to this listener.

Specified by:
processIncomingMessage in interface EndpointListener
Overrides:
processIncomingMessage in class InputPipeImpl
Parameters:
msg - Incoming message
srcAddr - Endpoint Address of the source of the message.
dstAddr - Endpoint Address of the destination of the message.

JXSE