net.jxta.impl.pipe
Class SecureOutputPipe
java.lang.Object
net.jxta.impl.pipe.NonBlockingOutputPipe
net.jxta.impl.pipe.SecureOutputPipe
- All Implemented Interfaces:
- Runnable, EventListener, PipeResolver.Listener, OutputPipe
class SecureOutputPipe
- extends NonBlockingOutputPipe
This class implements the Secure non blocking Output Pipe
Method Summary |
protected EndpointAddress |
mkAddress(ID destPeer,
ID pipeID)
Convenience method for constructing a peer endpoint address from its
peer id |
boolean |
send(Message msg)
We can't fail to send a message. |
SecureOutputPipe
public SecureOutputPipe(PeerGroup group,
PipeResolver resolver,
PipeAdvertisement pipeAdv,
PeerID destPeer,
Set peers)
throws IOException
- Throws:
IOException
send
public boolean send(Message msg)
throws IOException
-
We can't fail to send a message. Secure pipes are expected to be
reliable and ordered.
- Specified by:
send
in interface OutputPipe
- Overrides:
send
in class NonBlockingOutputPipe
- Throws:
IOException
mkAddress
protected EndpointAddress mkAddress(ID destPeer,
ID pipeID)
- Convenience method for constructing a peer endpoint address from its
peer id
- Overrides:
mkAddress
in class NonBlockingOutputPipe
- Parameters:
destPeer
- the desitnation peerpipeID
- the pipe to put in the param field.
- Returns:
- the pipe endpoint address.