Project JXTA

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


Inner Class Summary
protected  class EndpointRouter.PendingQuery
           
 class EndpointRouter.RouterMessanger
           
 
Field Summary
protected  java.lang.String localPeerId
           
 
Constructor Summary
EndpointRouter(net.jxta.peergroup.PeerGroup g, Endpoint e)
           
 
Method Summary
 net.jxta.endpoint.EndpointAddress checkPeer(java.lang.String peer)
           
 net.jxta.endpoint.EndpointAddress getAddress(java.lang.String pId)
           
 net.jxta.endpoint.EndpointAddress getBestLocalRoute(java.lang.String peer, java.util.Enumeration addrs)
           
 net.jxta.endpoint.EndpointAddress getLocalRoute(java.lang.String pId)
           
 EndpointMessanger getMessanger(java.lang.String dstPeer, EndpointMessanger messanger, Endpoint endp)
           
 java.util.Enumeration getPeerAdv(java.lang.String pId)
           
 java.util.Vector getRoute(java.lang.String pId)
           
 boolean isLocalRoute(java.lang.String pId)
           
 boolean isRoute(java.lang.String pId)
           
 MessageImpl processIncomingMsg(MessageImpl msg)
           
 MessageImpl processOutgoingPropagateMsg(MessageImpl msg, java.lang.String srcPeer, int ttl)
           
 net.jxta.protocol.ResolverResponseMsg processQuery(net.jxta.protocol.ResolverQueryMsg query)
          Process the Query, and genrate response
 void publishPeerAdv(net.jxta.document.Advertisement adv)
           
 void pushResponse(net.jxta.protocol.ResolverResponseMsg response)
           
 void removeLocalRoute(java.lang.String pId)
           
 void removeRoute(java.lang.String pId)
           
 void run()
           
 void setLocalRoute(java.lang.String pId, net.jxta.endpoint.EndpointAddress addr)
           
 void setRoute(java.lang.String pId, java.util.Vector v)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

localPeerId

protected java.lang.String localPeerId
Constructor Detail

EndpointRouter

public EndpointRouter(net.jxta.peergroup.PeerGroup g,
                      Endpoint e)
Method Detail

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"

getMessanger

public EndpointMessanger getMessanger(java.lang.String dstPeer,
                                      EndpointMessanger messanger,
                                      Endpoint endp)

Project JXTA