Project JXTA

net.jxta.impl.endpoint
Class Endpoint

java.lang.Object
  |
  +--net.jxta.impl.endpoint.Endpoint

public class Endpoint
extends java.lang.Object

This class implements the placeholders for all the JXTA transport protocols, as well, as the API for the implementation of the core protocols that use directely the Endpoint


Field Summary
static boolean debugFlag
           
static int HandChecking
           
static int NonBlocking
           
 EndpointRouter router
           
 
Constructor Summary
Endpoint(Endpoint parent, net.jxta.peergroup.PeerGroup g)
           
 
Method Summary
 boolean addPeerRoute(java.lang.String peer)
           
 void addProtocol(TransportProtocol proto)
           
 void demux(MessageImpl msg)
           
 net.jxta.endpoint.EndpointAddress getEndpointAddress(java.lang.String Uri)
           
 int getLastMessageTime(boolean inbound)
           
 net.jxta.endpoint.Message getMessage()
           
 EndpointMessanger getMessanger(net.jxta.endpoint.EndpointAddress addr, int type)
           
 EndpointMessanger getMessanger(java.lang.String dstPeer, java.lang.String pName, java.lang.String pParam, int type)
           
 java.util.Enumeration getPeerAdv(java.lang.String pId)
           
 TransportProtocol getProtocolByName(java.lang.String name)
           
 java.util.Enumeration getProtocols()
           
 net.jxta.peergroup.PeerGroup getRootGroup()
           
 java.util.Enumeration getTrafficChannels(boolean inbound)
           
 java.lang.Long getTrafficOnChannel(java.lang.String channel, boolean inbound)
           
 EndpointHandler lookupHandler(java.lang.String address)
           
 boolean ping(net.jxta.endpoint.EndpointAddress addr)
           
 void propagate(net.jxta.peergroup.PeerGroup g, net.jxta.endpoint.Message srcMsg, java.lang.String pName, java.lang.String pParam, int ttl, java.lang.String prunePeer)
           
 void publishPeerAdv(net.jxta.document.Advertisement adv)
           
 void registerHandler(java.lang.String address, EndpointHandler handler)
           
 boolean removeProtocol(TransportProtocol proto)
           
 void setRootGroup(net.jxta.peergroup.PeerGroup g)
           
 boolean unregisterHandler(java.lang.String address, EndpointHandler handler)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

debugFlag

public static boolean debugFlag

NonBlocking

public static final int NonBlocking

HandChecking

public static final int HandChecking

router

public EndpointRouter router
Constructor Detail

Endpoint

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

publishPeerAdv

public void publishPeerAdv(net.jxta.document.Advertisement adv)

getPeerAdv

public java.util.Enumeration getPeerAdv(java.lang.String pId)

setRootGroup

public void setRootGroup(net.jxta.peergroup.PeerGroup g)

getRootGroup

public net.jxta.peergroup.PeerGroup getRootGroup()

addProtocol

public void addProtocol(TransportProtocol proto)
                 throws java.io.IOException

removeProtocol

public boolean removeProtocol(TransportProtocol proto)

getProtocols

public java.util.Enumeration getProtocols()

getMessage

public net.jxta.endpoint.Message getMessage()

getEndpointAddress

public net.jxta.endpoint.EndpointAddress getEndpointAddress(java.lang.String Uri)

getMessanger

public EndpointMessanger getMessanger(net.jxta.endpoint.EndpointAddress addr,
                                      int type)
                               throws java.io.IOException

getMessanger

public EndpointMessanger getMessanger(java.lang.String dstPeer,
                                      java.lang.String pName,
                                      java.lang.String pParam,
                                      int type)
                               throws java.io.IOException

propagate

public void propagate(net.jxta.peergroup.PeerGroup g,
                      net.jxta.endpoint.Message srcMsg,
                      java.lang.String pName,
                      java.lang.String pParam,
                      int ttl,
                      java.lang.String prunePeer)
               throws java.io.IOException

registerHandler

public void registerHandler(java.lang.String address,
                            EndpointHandler handler)
                     throws java.io.IOException

unregisterHandler

public boolean unregisterHandler(java.lang.String address,
                                 EndpointHandler handler)

lookupHandler

public EndpointHandler lookupHandler(java.lang.String address)

demux

public void demux(MessageImpl msg)
           throws java.io.IOException

getProtocolByName

public TransportProtocol getProtocolByName(java.lang.String name)

addPeerRoute

public boolean addPeerRoute(java.lang.String peer)

ping

public boolean ping(net.jxta.endpoint.EndpointAddress addr)

getTrafficChannels

public java.util.Enumeration getTrafficChannels(boolean inbound)

getTrafficOnChannel

public java.lang.Long getTrafficOnChannel(java.lang.String channel,
                                          boolean inbound)

getLastMessageTime

public int getLastMessageTime(boolean inbound)

Project JXTA