|
Project JXTA | ||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--net.jxta.impl.pipe.PipeService
This class implements the NetPipe interface.
Fields inherited from interface net.jxta.pipe.Pipe |
HandChecking,
NonBlocking,
Propagate |
Constructor Summary | |
PipeService()
Constructor: this constructor is only needed in order to create the listener thread of the NodePipe. |
Method Summary | |
void |
addAddresses(net.jxta.protocol.PipeAdvertisement adv,
java.util.Enumeration addrs)
|
net.jxta.pipe.InputPipe |
createInputPipe(net.jxta.protocol.PipeAdvertisement adv)
Creates an InputPipe of a NetPipe. |
net.jxta.endpoint.Message |
createMessage()
Creates a new Message |
net.jxta.pipe.OutputPipe |
createOutputPipe(net.jxta.protocol.PipeAdvertisement adv,
int type,
java.util.Enumeration peers,
long timeout)
create an OutputPipe from the pipe Advertisement giving a PeerId(s) where the corresponding InputPipe is supposed to be. |
net.jxta.pipe.OutputPipe |
createOutputPipe(net.jxta.protocol.PipeAdvertisement pipeAdv,
int type,
long timeout)
Creates an OutputPipe associated to a NetPipe. |
net.jxta.document.Advertisement |
getAdvertisement()
Returns the advertisement for that service. |
net.jxta.service.Service |
getInterface()
Service objects are not manipulated directly to protect usage of the service. |
void |
init(net.jxta.peergroup.PeerGroup g,
net.jxta.document.Advertisement sadv)
Init routine |
int |
startApp(java.lang.String[] arg)
Supply arguments and starts this service if it hadn't started by itself. |
void |
stopApp()
Ask this service to stop. |
Methods inherited from class java.lang.Object |
clone,
equals,
finalize,
getClass,
hashCode,
notify,
notifyAll,
toString,
wait,
wait,
wait |
Constructor Detail |
public PipeService()
Method Detail |
public int startApp(java.lang.String[] arg)
arg
- A table of strings arguments.public void stopApp()
public net.jxta.service.Service getInterface()
public net.jxta.document.Advertisement getAdvertisement()
public void init(net.jxta.peergroup.PeerGroup g, net.jxta.document.Advertisement sadv)
myGroup
- The Group associated with this servicepublic net.jxta.pipe.InputPipe createInputPipe(net.jxta.protocol.PipeAdvertisement adv) throws java.io.IOException
adv
- is the public advertisement of the NetPipe.public net.jxta.pipe.OutputPipe createOutputPipe(net.jxta.protocol.PipeAdvertisement pipeAdv, int type, long timeout) throws java.io.IOException
adv
- is the public advertisement of the destination NetPipe.type
- the type of the output pipe to createtimeout
- the number of milliseconds to wait during pipe creationpublic net.jxta.pipe.OutputPipe createOutputPipe(net.jxta.protocol.PipeAdvertisement adv, int type, java.util.Enumeration peers, long timeout) throws java.io.IOException
adv
- is the advertisement of the NetPipe.type
- is an int and contains the name of the diffusion mode for
this OutputPipe.peers
- is an enumeration of the PeerId of thepeers where to look
for the corresponding Pipestimeout
- the number of milliseconds to wait for during pipe creationpublic net.jxta.endpoint.Message createMessage()
public void addAddresses(net.jxta.protocol.PipeAdvertisement adv, java.util.Enumeration addrs)
|
Project JXTA | ||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |