|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.livetribe.slp.api.StandardAgent
org.livetribe.slp.api.ua.StandardUserAgent
public class StandardUserAgent
Field Summary |
---|
Fields inherited from class org.livetribe.slp.api.StandardAgent |
---|
logger |
Constructor Summary | |
---|---|
StandardUserAgent()
|
Method Summary | |
---|---|
void |
addMessageRegistrationListener(MessageRegistrationListener listener)
|
protected void |
configureUserAgentManager(UserAgentManager uaManager)
|
protected edu.emory.mathcs.backport.java.util.concurrent.ScheduledExecutorService |
createScheduledExecutorService()
Creates and returns the default ScheduledExecutorService, configured to use one daemon thread. |
protected UserAgentManager |
createUserAgentManager()
|
protected List |
discoverDirectoryAgents(Scopes scopes,
String filter)
|
protected void |
doStart()
|
protected void |
doStop()
|
List |
findDirectoryAgents(Scopes scopes,
String filter)
|
List |
findServiceAgents(Scopes scopes,
String filter)
|
List |
findServices(ServiceType serviceType,
Scopes scopes,
String filter,
String language)
Returns a list of ServiceInfo that are available on the network, and that match the given arguments. |
protected List |
getCachedDirectoryAgents(Scopes scopes,
String filter)
|
int |
getDiscoveryInitialWaitBound()
|
long |
getDiscoveryPeriod()
Returns the period, in seconds, between discovery of DirectoryAgents |
protected void |
handleMulticastDAAdvert(DAAdvert message,
InetSocketAddress address)
|
protected void |
handleMulticastSrvDeReg(SrvDeReg message)
|
protected void |
handleMulticastSrvReg(SrvReg message)
|
boolean |
isPeriodicDiscoveryEnabled()
Returns whether this UserAgent should periodically discover DirectoryAgents |
void |
removeMessageRegistrationListener(MessageRegistrationListener listener)
|
void |
setDiscoveryInitialWaitBound(int discoveryInitialWaitBound)
Sets the bound (in seconds) to the initial random delay this UserAgent waits before attempting to discover DirectoryAgents |
void |
setDiscoveryPeriod(long discoveryPeriod)
Sets the period, in seconds, between discovery of DirectoryAgents |
void |
setPeriodicDiscoveryEnabled(boolean periodicDiscoveryEnabled)
Sets whether this UserAgent should periodically discover DirectoryAgents |
void |
setScheduledExecutorService(edu.emory.mathcs.backport.java.util.concurrent.ScheduledExecutorService scheduledExecutorService)
Sets the ScheduledExecutorService used to perform periodic tasks such as discovery of DirectoryAgents. |
void |
setUserAgentManager(UserAgentManager manager)
|
Methods inherited from class org.livetribe.slp.api.StandardAgent |
---|
getPort, getScopes, isRunning, setPort, setScopes, start, stop |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.livetribe.slp.api.Agent |
---|
isRunning, setScopes, start, stop |
Constructor Detail |
---|
public StandardUserAgent()
Method Detail |
---|
public void setUserAgentManager(UserAgentManager manager)
setUserAgentManager
in interface UserAgent
public void setScheduledExecutorService(edu.emory.mathcs.backport.java.util.concurrent.ScheduledExecutorService scheduledExecutorService)
createScheduledExecutorService()
public boolean isPeriodicDiscoveryEnabled()
setPeriodicDiscoveryEnabled(boolean)
,
getDiscoveryPeriod()
public void setPeriodicDiscoveryEnabled(boolean periodicDiscoveryEnabled)
isPeriodicDiscoveryEnabled()
,
getDiscoveryPeriod()
public long getDiscoveryPeriod()
setDiscoveryPeriod(long)
,
isPeriodicDiscoveryEnabled()
public void setDiscoveryPeriod(long discoveryPeriod)
getDiscoveryPeriod()
,
isPeriodicDiscoveryEnabled()
public int getDiscoveryInitialWaitBound()
public void setDiscoveryInitialWaitBound(int discoveryInitialWaitBound)
protected void doStart() throws IOException
doStart
in class StandardAgent
IOException
protected UserAgentManager createUserAgentManager()
protected void configureUserAgentManager(UserAgentManager uaManager)
protected edu.emory.mathcs.backport.java.util.concurrent.ScheduledExecutorService createScheduledExecutorService()
protected void doStop() throws IOException
doStop
in class StandardAgent
IOException
public void addMessageRegistrationListener(MessageRegistrationListener listener)
addMessageRegistrationListener
in interface UserAgent
public void removeMessageRegistrationListener(MessageRegistrationListener listener)
removeMessageRegistrationListener
in interface UserAgent
public List findServices(ServiceType serviceType, Scopes scopes, String filter, String language) throws IOException, ServiceLocationException
ServiceInfo
that are available on the network, and that match the given arguments.
findServices
in interface UserAgent
serviceType
- The ServiceType of the services to findscopes
- The scopes of the services to findfilter
- An LDAPv3 filter expression for the attributes of the services to findlanguage
- The language of the services to find
IOException
ServiceLocationException
public List findDirectoryAgents(Scopes scopes, String filter) throws IOException, ServiceLocationException
IOException
ServiceLocationException
protected List getCachedDirectoryAgents(Scopes scopes, String filter)
protected List discoverDirectoryAgents(Scopes scopes, String filter) throws IOException
IOException
public List findServiceAgents(Scopes scopes, String filter) throws IOException, ServiceLocationException
IOException
ServiceLocationException
protected void handleMulticastDAAdvert(DAAdvert message, InetSocketAddress address)
protected void handleMulticastSrvReg(SrvReg message)
protected void handleMulticastSrvDeReg(SrvDeReg message)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |