net.jxta.impl.pipe
Class SecureInputPipeImpl
java.lang.Object
net.jxta.impl.pipe.InputPipeImpl
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.
SecureInputPipeImpl
SecureInputPipeImpl(PipeResolver pipeResolver,
PipeAdvertisement adv)
throws IOException
- Constructor for the SecureInputPipeImpl object
- Parameters:
pipeResolver
- pipe resolveradv
- 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 resolveradv
- the pipe advertisementlistener
- the message listener
- Throws:
IOException
- if an io error occurs
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 messagesrcAddr
- Endpoint Address of the source of the message.dstAddr
- Endpoint Address of the destination of the message.