|
Project JXTA | ||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.jxta.impl.pipe.PipeServiceImpl
A JXTA PipeService
implementation which implements the
standard JXTA Pipe Resolver Protocol (PRP).
PipeService
,
InputPipe
,
OutputPipe
,
Message
,
PipeAdvertisement
,
PipeResolverMessage
,
JXTA Protocols Specification : Pipe Binding ProtocolField Summary | |
(package private) static long |
VERIFYINTERVAL
the interval at which we verify that a pipe is still resolved at a remote peer. |
Fields inherited from interface net.jxta.pipe.PipeService |
PropagateType, UnicastSecureType, UnicastType |
Fields inherited from interface net.jxta.platform.Module |
START_AGAIN_PROGRESS, START_AGAIN_STALLED, START_OK |
Constructor Summary | |
PipeServiceImpl()
Default Constructor (don't delete) |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
static final long VERIFYINTERVAL
Constructor Detail |
public PipeServiceImpl()
Method Detail |
public Service getInterface()
getInterface
in interface Service
public Advertisement getImplAdvertisement()
getImplAdvertisement
in interface Service
public void init(PeerGroup pg, ID assignedID, Advertisement impl)
init
in interface Module
public int startApp(String[] args)
startApp
in interface Module
public void stopApp()
stopApp
in interface Module
public InputPipe createInputPipe(PipeAdvertisement adv) throws IOException
createInputPipe
in interface PipeService
IOException
public InputPipe createInputPipe(PipeAdvertisement adv, PipeMsgListener listener) throws IOException
createInputPipe
in interface PipeService
IOException
public OutputPipe createOutputPipe(PipeAdvertisement pipeAdv, long timeout) throws IOException
createOutputPipe
in interface PipeService
IOException
public OutputPipe createOutputPipe(PipeAdvertisement pipeAdv, PeerID peerid, long timeout) throws IOException
createOutputPipe
in interface PipeService
IOException
public OutputPipe createOutputPipe(PipeAdvertisement adv, Enumeration resolvablePeers, long timeout) throws IOException
createOutputPipe
in interface PipeService
IOException
public OutputPipe createOutputPipe(PipeAdvertisement adv, Set resolvablePeers, long timeout) throws IOException
createOutputPipe
in interface PipeService
IOException
public void createOutputPipe(PipeAdvertisement pipeAdv, OutputPipeListener listener) throws IOException
createOutputPipe
in interface PipeService
IOException
public void createOutputPipe(PipeAdvertisement pipeAdv, PeerID peerid, OutputPipeListener listener) throws IOException
createOutputPipe
in interface PipeService
IOException
public void createOutputPipe(PipeAdvertisement pipeAdv, Set resolvablePeers, OutputPipeListener listener) throws IOException
createOutputPipe
in interface PipeService
IOException
public Message createMessage()
createMessage
in interface PipeService
public OutputPipeListener removeOutputPipeListener(String opID, OutputPipeListener listener)
removeOutputPipeListener
in interface PipeService
public boolean pipeResolveEvent(PipeResolver.Event e)
pipeResolveEvent
in interface PipeResolver.Listener
public boolean pipeNAKEvent(PipeResolver.Event e)
pipeNAKEvent
in interface PipeResolver.Listener
|
JXTA J2SE | ||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |