|
JXTA | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.jxta.impl.rendezvous.RendezVousServiceProvider
net.jxta.impl.rendezvous.adhoc.AdhocPeerRdvService
public class AdhocPeerRdvService
A JXTA RendezVousService
implementation which
implements the ad hoc portion of the standard JXTA Rendezvous Protocol (RVP).
RendezVousService
,
JXTA Protocols Specification : Rendezvous ProtocolField Summary |
---|
Fields inherited from class net.jxta.impl.rendezvous.RendezVousServiceProvider |
---|
closed, group, MAX_TTL, PROP_HDR_ELEMENT_NAME, PropPName, PropSName, RDV_MSG_NAMESPACE_NAME, rdvService, rendezvousMeter, rendezvousServiceMonitor |
Constructor Summary | |
---|---|
AdhocPeerRdvService(PeerGroup g,
RendezVousServiceImpl rdvService)
Constructor |
Method Summary | |
---|---|
void |
challengeRendezVous(ID peer,
long delay)
Resets the local idea of the lease to the specified value. |
void |
connectToRendezVous(EndpointAddress addr,
Object hint)
Attempt to connect to the specified rendezvous peer. |
void |
disconnectFromRendezVous(ID peerId)
Remove a RendezVousService point. |
Vector<ID> |
getConnectedPeerIDs()
Returns the peers that are currently connected to this peer. |
boolean |
isConnectedToRendezVous()
Return true if connected to a rendezvous. |
void |
propagate(Enumeration<? extends ID> destPeerIDs,
Message msg,
String serviceName,
String serviceParam,
int ttl)
Propagates a message onto as many peers on the local network as possible. |
void |
propagate(Message msg,
String serviceName,
String serviceParam,
int ttl)
Propagates a message onto as many peers on the local network as possible. |
void |
propagateInGroup(Message msg,
String serviceName,
String serviceParam,
int ttl)
|
void |
propagateToNeighbors(Message msg,
String serviceName,
String serviceParam,
int ttl)
Propagates a message onto as many peers on the local network as possible. |
protected void |
repropagate(Message msg,
RendezVousPropagateMessage propHdr,
String serviceName,
String serviceParam)
Responsible for forwarding received messages to the rest of the network as appropriate. |
protected int |
startApp(String[] arg)
Supply arguments and starts this service if it hadn't started by itself. |
void |
stopApp()
Ask this service to stop. |
void |
walk(Message msg,
String serviceName,
String serviceParam,
int ttl)
Walk a message through the rendezvous peers of the network: only rendezvous peers will receive the message. |
void |
walk(Vector<? extends ID> destPeerIDs,
Message msg,
String serviceName,
String serviceParam,
int ttl)
Walk a message through the rendezvous peers of the network: only rendezvous peers will receive the message. |
Methods inherited from class net.jxta.impl.rendezvous.RendezVousServiceProvider |
---|
checkPropHeader, getPeerAdvertisementDoc, getPropHeader, mkAddress, mkAddress, processIncomingMessage, processReceivedMessage, sendToNetwork, setRendezvousServiceMonitor, updatePropHeader |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public AdhocPeerRdvService(PeerGroup g, RendezVousServiceImpl rdvService)
g
- the peergrouprdvService
- the rendezvous serviceMethod Detail |
---|
protected int startApp(String[] arg)
startApp
in class RendezVousServiceProvider
arg
- argument params
public void stopApp()
stopApp
in class RendezVousServiceProvider
public Vector<ID> getConnectedPeerIDs()
getConnectedPeerIDs
in class RendezVousServiceProvider
public boolean isConnectedToRendezVous()
isConnectedToRendezVous
in class RendezVousServiceProvider
public void connectToRendezVous(EndpointAddress addr, Object hint) throws IOException
connectToRendezVous
in class RendezVousServiceProvider
addr
- The endpoint address of the rendezvous peer.hint
- An optional hint which may be null
.
IOException
- If no connection could be made to the specified peer.public void challengeRendezVous(ID peer, long delay)
challengeRendezVous
in class RendezVousServiceProvider
peer
- The peer to be challengeddelay
- The delaypublic void disconnectFromRendezVous(ID peerId)
disconnectFromRendezVous
in class RendezVousServiceProvider
peerId
- the PeerId of the RendezVous to disconnect from.public void propagate(Message msg, String serviceName, String serviceParam, int ttl) throws IOException
propagate
in class RendezVousServiceProvider
msg
- is the message to propagate.serviceName
- is the name of the serviceserviceParam
- is the parameter of the servicettl
- is the maximum TTL of the message (note that the Rendezvous
Service implementation is free to decrease that value.
IOException
- if an io error occurspublic void propagateInGroup(Message msg, String serviceName, String serviceParam, int ttl) throws IOException
propagateInGroup
in class RendezVousServiceProvider
IOException
public void propagate(Enumeration<? extends ID> destPeerIDs, Message msg, String serviceName, String serviceParam, int ttl)
propagate
in class RendezVousServiceProvider
destPeerIDs
- An enumeration of the peers that are recipients of the
propagated message.msg
- is the message to propagate.serviceName
- is the name of the serviceserviceParam
- is the parameter of the servicettl
- is the maximum TTL of the message (note that the Rendezvous
Service implementation is free to decrease that value.public void propagateToNeighbors(Message msg, String serviceName, String serviceParam, int ttl) throws IOException
propagateToNeighbors
in class RendezVousServiceProvider
msg
- is the message to propagate.serviceName
- is the name of the serviceserviceParam
- is the parameter of the servicettl
- is the maximum TTL of the message (note that the Rendezvous
Service implementation is free to decrease that value.
IOException
- if an io error occurspublic void walk(Message msg, String serviceName, String serviceParam, int ttl) throws IOException
walk
in class RendezVousServiceProvider
msg
- is the message to walk.serviceName
- is the name of the serviceserviceParam
- is the parameter of the servicettl
- is the maximum TTL of the message (note that the Rendezvous
Service implementation is free to decrease that value.
IOException
- when walking the message is impossible (network failure)public void walk(Vector<? extends ID> destPeerIDs, Message msg, String serviceName, String serviceParam, int ttl) throws IOException
walk
in class RendezVousServiceProvider
destPeerIDs
- is a Vector of PeerID of the peers which are receiving
first the walker. Note that each entry in the Vector will create its own
walker.msg
- is the message to walk.serviceName
- is the name of the serviceserviceParam
- is the parameter of the servicettl
- is the maximum TTL of the message (note that the Rendezvous
Service implementation is free to decrease that value.
IOException
- when walking the message is impossible (network failure)protected void repropagate(Message msg, RendezVousPropagateMessage propHdr, String serviceName, String serviceParam)
repropagate
in class RendezVousServiceProvider
msg
- the message to be repropagated.propHdr
- It's current propagation header.serviceName
- The destination service.serviceParam
- The destination service parameter.
|
JXSE | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |