|
JXTA | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.jxta.impl.pipe.WirePipeImpl
public class WirePipeImpl
The Wire (Propagated) Pipe Service.
Field Summary | |
---|---|
(package private) static String |
WIRE_HEADER_ELEMENT_NAME
The Message Element name we use for passing the wire header. |
(package private) static String |
WIRE_HEADER_ELEMENT_NAMESPACE
The Message namespace we use for passing the wire header. |
(package private) static String |
WIRE_SERVICE_NAME
Service name we register our listener with. |
Constructor Summary | |
---|---|
WirePipeImpl(PeerGroup group,
PipeResolver pipeResolver)
|
Method Summary | |
---|---|
(package private) InputPipe |
createInputPipe(PipeAdvertisement adv,
PipeMsgListener listener)
create an InputPipe from a pipe Advertisement |
(package private) NonBlockingWireOutputPipe |
createOutputPipe(PipeAdvertisement adv,
Set<? extends ID> peers)
create an OutputPipe from the pipe Advertisement giving a PeerId(s) where the corresponding InputPipe is supposed to be. |
(package private) boolean |
forgetWirePipe(ID pipeID)
Remove a wire pipe from our collection of wire pipes. |
String |
getServiceParameter()
To support WirePipe.send(Message, Enumeration) |
void |
processIncomingMessage(Message message,
EndpointAddress srcAddr,
EndpointAddress dstAddr)
This method is invoked by the EndpointService for each incoming message which is addressed to this listener. |
int |
startApp(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 |
Field Detail |
---|
static final String WIRE_SERVICE_NAME
static final String WIRE_HEADER_ELEMENT_NAMESPACE
static final String WIRE_HEADER_ELEMENT_NAME
Constructor Detail |
---|
WirePipeImpl(PeerGroup group, PipeResolver pipeResolver)
group
- Description of the ParameterpipeResolver
- Description of the ParameterMethod Detail |
---|
public String getServiceParameter()
public int startApp(String[] arg)
arg
- A table of strings arguments.
public void stopApp()
InputPipe createInputPipe(PipeAdvertisement adv, PipeMsgListener listener) throws IOException
adv
- is the advertisement of the PipeServiceImpl.listener
- PipeMsgListener to receive msgs.
IOException
- error creating input pipeNonBlockingWireOutputPipe createOutputPipe(PipeAdvertisement adv, Set<? extends ID> peers)
adv
- is the advertisement of the NetPipe.peers
- is a set of the PeerId of the peers where to look
for the corresponding Pipes
boolean forgetWirePipe(ID pipeID)
pipeID
- The ID of the wire pipe to forget.
true
if the wire pipe had been registered otherwise
false
.public void processIncomingMessage(Message message, EndpointAddress srcAddr, EndpointAddress dstAddr)
processIncomingMessage
in interface EndpointListener
message
- Incoming messagesrcAddr
- Endpoint Address of the source of the message.dstAddr
- Endpoint Address of the destination of the message.
|
JXSE | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |