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
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 |
debugFlag
public static boolean debugFlag
NonBlocking
public static final int NonBlocking
HandChecking
public static final int HandChecking
router
public EndpointRouter router
Endpoint
public Endpoint(Endpoint parent,
net.jxta.peergroup.PeerGroup g)
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)