Project JXTA

net.jxta.impl.pipe
Class SecureOutputPipe

java.lang.Object
  extended by net.jxta.impl.pipe.NonBlockingOutputPipe
      extended by 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


Nested Class Summary
 
Nested classes/interfaces inherited from class net.jxta.impl.pipe.NonBlockingOutputPipe
NonBlockingOutputPipe.workerState
 
Constructor Summary
SecureOutputPipe(PeerGroup group, PipeResolver resolver, PipeAdvertisement pipeAdv, PeerID destPeer, Set peers)
           
 
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.

 
Methods inherited from class net.jxta.impl.pipe.NonBlockingOutputPipe
close, finalize, getAdvertisement, getName, getPipeID, getType, isClosed, pipeNAKEvent, pipeResolveEvent, run
 
Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SecureOutputPipe

public SecureOutputPipe(PeerGroup group,
                        PipeResolver resolver,
                        PipeAdvertisement pipeAdv,
                        PeerID destPeer,
                        Set peers)
                 throws IOException
Throws:
IOException
Method Detail

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 peer
pipeID - the pipe to put in the param field.
Returns:
the pipe endpoint address.

JXTA J2SE