| Method Summary |
|
| public void | addFilter(UTILFilterCallback callbackObj)
mySubscriptions is synchronized here and in cycle to make
sure that no subscriptions are added while iterating over the
list of current subscriptions (in cycle ()). |
| protected ParamMap | createParamTable(Vector envParams, MessageAddress ident)
Subclass to return a different ParamTable. |
| protected void | debug(String message)
Equivalent to "log(debug, ..)". |
| protected boolean | didSpawn()
|
| protected void | error(String message)
Equivalent to "log(ERROR, ..)". |
| protected void | execute()
Called every time one of the filterCallback subscriptions
change. |
| protected void | fatal(String message)
Equivalent to "log(FATAL, ..)". |
| protected PersistentState | findState()
|
| protected String | getClassName()
|
| protected String | getClassName(Object obj)
|
| public String | getClusterName()
|
| public void | getEnvData()
Allows child classes to read additional data from environment files. |
| final protected LDMService | getLDMService()
|
| protected LoggingService | getLoggingService()
Get the logging service, for subclass use. |
| public ParamMap | getMyParams()
Accessor to param table. |
| public String | getName()
|
| protected MessageAddress | getOriginalAgentID()
|
| protected void | info(String message)
Equivalent to "log(info, ..)". |
| protected boolean | isDebugEnabled()
|
| protected boolean | isErrorEnabled()
|
| protected boolean | isFatalEnabled()
|
| protected boolean | isInfoEnabled()
|
| protected boolean | isWarnEnabled()
|
| protected void | justRehydrated()
Automatic support for persistent state. |
| public void | localSetup()
Place to put any local plugin startup initiallization. |
| public void | preFilterSetup()
A place to put setup actions that will occur before
any filters are active.
I.e. |
| final protected void | publishAdd(Object o)
|
| final protected void | publishChange(Object o)
|
| final protected void | publishRemove(Object o)
|
| protected void | registerPersistentState(Object obj)
Call this method to add your state to what will be persisted
Call from inside of a transaction. |
| protected void | rehydrateState(List stuff)
|
| public void | removeFilter(UTILFilterCallback callbackObj)
mySubscriptions is synchronized here and in cycle to make
sure that no subscriptions are removed while iterating over the
list of current subscriptions (in cycle ()). |
| final public void | setLDMService(LDMService s)
|
| public void | setLoggingService(LoggingService bs)
rely upon load-time introspection to set these services -
don't worry about revokation. |
| public void | setupFilters()
The idea is to add subscriptions (via the filterCallback), and when
they change, to have the callback react to the change, and tell
the listener (many times the plugin) what to do. |
| final protected void | setupSubscriptions()
This method is called before cycle is ever called to
set up safe transactions for container subscriptions. |
| public IncrementalSubscription | subscribeFromCallback(UnaryPredicate pred)
Implemented for UTILFilterCallbackListener
This allows callbacks to make subscriptions. |
| public IncrementalSubscription | subscribeFromCallback(UnaryPredicate pred, Collection specialContainer)
Implemented for UTILFilterCallbackListener
This allows callbacks to make subscriptions with a special container. |
| public void | updateAllocationResult(PlanElement cpe)
if the reported allocation result has been successfully calculated
set the estimated equal to the reported to send a notification
back up.
Only reports results if the confidence is above a threshold.
This threshold is currently 0.99. |
| protected void | warn(String message)
Equivalent to "log(WARN, ..)". |
