net.jxta.impl.endpoint
Class EndpointRouter
java.lang.Object
|
+--net.jxta.impl.endpoint.EndpointRouter
- public class EndpointRouter
- extends java.lang.Object
- implements net.jxta.resolver.QueryHandler, java.lang.Runnable
Methods inherited from class java.lang.Object |
clone,
equals,
finalize,
getClass,
hashCode,
notify,
notifyAll,
toString,
wait,
wait,
wait |
localPeerId
protected java.lang.String localPeerId
EndpointRouter
public EndpointRouter(net.jxta.peergroup.PeerGroup g,
Endpoint e)
publishPeerAdv
public void publishPeerAdv(net.jxta.document.Advertisement adv)
getPeerAdv
public java.util.Enumeration getPeerAdv(java.lang.String pId)
getAddress
public net.jxta.endpoint.EndpointAddress getAddress(java.lang.String pId)
getBestLocalRoute
public net.jxta.endpoint.EndpointAddress getBestLocalRoute(java.lang.String peer,
java.util.Enumeration addrs)
isLocalRoute
public boolean isLocalRoute(java.lang.String pId)
getLocalRoute
public net.jxta.endpoint.EndpointAddress getLocalRoute(java.lang.String pId)
setLocalRoute
public void setLocalRoute(java.lang.String pId,
net.jxta.endpoint.EndpointAddress addr)
removeLocalRoute
public void removeLocalRoute(java.lang.String pId)
isRoute
public boolean isRoute(java.lang.String pId)
getRoute
public java.util.Vector getRoute(java.lang.String pId)
setRoute
public void setRoute(java.lang.String pId,
java.util.Vector v)
removeRoute
public void removeRoute(java.lang.String pId)
processIncomingMsg
public MessageImpl processIncomingMsg(MessageImpl msg)
processOutgoingPropagateMsg
public MessageImpl processOutgoingPropagateMsg(MessageImpl msg,
java.lang.String srcPeer,
int ttl)
checkPeer
public net.jxta.endpoint.EndpointAddress checkPeer(java.lang.String peer)
run
public void run()
- Specified by:
- run in interface java.lang.Runnable
pushResponse
public void pushResponse(net.jxta.protocol.ResolverResponseMsg response)
- Specified by:
- pushResponse in interface net.jxta.resolver.QueryHandler
processQuery
public net.jxta.protocol.ResolverResponseMsg processQuery(net.jxta.protocol.ResolverQueryMsg query)
throws net.jxta.exception.NoResponseException,
java.io.IOException,
net.jxta.exception.ResendQueryException,
net.jxta.exception.DiscardQueryException
- Process the Query, and genrate response
- Specified by:
- processQuery in interface net.jxta.resolver.QueryHandler
- Parameters:
GenericResolverMsg
- the query to process- Returns:
- ResolverResponseMsg "Response"
getMessenger
public EndpointMessenger getMessenger(java.lang.String dstPeer,
EndpointMessenger messenger,
Endpoint endp)