|
Project JXTA | ||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.jxta.impl.endpoint.relay.RelayServer
Relay server that maintains outgoing message queues, leases, etc.
Nested Class Summary | |
(package private) static class |
RelayServer.BGSend
Sends a message on an synchronous messenger. |
Field Summary | |
protected AccessList |
acl
|
protected File |
aclFile
|
protected long |
aclFileLastModified
|
protected PeerGroup |
group
|
protected String |
peerId
|
protected long |
refreshTime
|
protected net.jxta.impl.endpoint.relay.RelayServer.RelayServerCache |
relayServerCache
|
protected String |
serviceName
|
Constructor Summary | |
RelayServer(PeerGroup group,
String serviceName,
RelayConfigAdv relayConfigAdv)
constructor |
Method Summary | |
boolean |
allowsRouting()
|
EndpointService |
getEndpointService()
|
Messenger |
getMessenger(EndpointAddress destAddr,
Object hintIgnored)
|
String |
getProtocolName()
|
EndpointAddress |
getPublicAddress()
|
List |
getRelayedClients()
Debug routine: returns the list of relayedClients with details. |
protected void |
handleRequest(Message message,
EndpointAddress dstAddr)
|
protected void |
handleRequest(Messenger messenger,
EndpointAddress connectionAddress)
|
(package private) void |
handleRequest(String request,
String clientPeerId,
Messenger messenger)
|
boolean |
isConnectionOriented()
|
boolean |
isPropagateEnabled()
(@inheritdoc} |
boolean |
isPropagationSupported()
(@inheritdoc} |
boolean |
messengerReady(MessengerEvent event)
|
boolean |
ping(EndpointAddress addr)
|
void |
propagate(Message msg,
String serviceName,
String serviceParams,
String prunePeer)
|
protected void |
removeClient(String clientPeerId,
RelayServerClient handler)
|
void |
run()
|
boolean |
startServer()
|
void |
stopServer()
|
Object |
transportControl(Object operation,
Object Value)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected final PeerGroup group
protected final String serviceName
protected final String peerId
protected final AccessList acl
protected File aclFile
protected long refreshTime
protected long aclFileLastModified
protected final net.jxta.impl.endpoint.relay.RelayServer.RelayServerCache relayServerCache
Constructor Detail |
public RelayServer(PeerGroup group, String serviceName, RelayConfigAdv relayConfigAdv)
Method Detail |
public List getRelayedClients()
public boolean startServer()
public void stopServer()
public EndpointAddress getPublicAddress()
getPublicAddress
in interface MessageSender
public boolean isConnectionOriented()
isConnectionOriented
in interface MessageSender
public boolean allowsRouting()
allowsRouting
in interface MessageSender
public Object transportControl(Object operation, Object Value)
transportControl
in interface MessageTransport
public Messenger getMessenger(EndpointAddress destAddr, Object hintIgnored)
getMessenger
in interface MessageSender
public boolean isPropagateEnabled()
isPropagateEnabled
in interface MessageSender
public boolean isPropagationSupported()
isPropagationSupported
in interface MessageSender
public void propagate(Message msg, String serviceName, String serviceParams, String prunePeer) throws IOException
propagate
in interface MessageSender
IOException
public boolean ping(EndpointAddress addr)
ping
in interface MessageSender
public String getProtocolName()
getProtocolName
in interface MessageTransport
public EndpointService getEndpointService()
getEndpointService
in interface MessageTransport
public boolean messengerReady(MessengerEvent event)
messengerReady
in interface MessengerEventListener
protected void handleRequest(Messenger messenger, EndpointAddress connectionAddress)
protected void handleRequest(Message message, EndpointAddress dstAddr)
void handleRequest(String request, String clientPeerId, Messenger messenger)
protected void removeClient(String clientPeerId, RelayServerClient handler)
public void run()
run
in interface Runnable
|
JXTA J2SE | ||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |