| |
|
| java.lang.Object org.cougaar.core.blackboard.Subscriber org.cougaar.core.blackboard.Blackboard
Inner Class :interface PlanEnvelope | |
Inner Class :public static class ObjectTracker | |
INSERTION_POINT | final public static String INSERTION_POINT(Code) | | |
PEDANTIC | final public static boolean PEDANTIC(Code) | | |
enablePublishException | final public static boolean enablePublishException(Code) | | |
isSavePriorPublisher | final public static boolean isSavePriorPublisher(Code) | | |
add | public void add(Object o)(Code) | | Add Object to the Blackboard Collection
|
appendMessagesToSend | public void appendMessagesToSend(List messages)(Code) | | |
change | public void change(Object o)(Code) | | Change Object to the Blackboard Collection
|
clientAddedObject | protected EnvelopeTuple clientAddedObject(Object o)(Code) | | override to immediately publish deltas rather than delay until transaction close
|
clientChangedObject | protected EnvelopeTuple clientChangedObject(Object o, List changes)(Code) | | override to immediately publish deltas rather than delay until transaction close
|
clientRemovedObject | protected EnvelopeTuple clientRemovedObject(Object o)(Code) | | override to immediately publish deltas rather than delay until transaction close
|
connectDomains | protected void connectDomains()(Code) | | Ensure that all the domains know that this is THE blackboard
|
countBlackboard | public int countBlackboard(Class cl)(Code) | | |
currentTimeMillis | public long currentTimeMillis()(Code) | | |
executeDelayedLPActions | protected Envelope executeDelayedLPActions()(Code) | | |
fillSubscription | public void fillSubscription(Subscription subscription)(Code) | | Provide a new subscription with its initial fill. Called under
the protection of the distributor lock so we are guaranteed that
the allPlanObjects won't change.
|
getBlackboardClientName | public String getBlackboardClientName()(Code) | | |
getBlackboardSize | public int getBlackboardSize()(Code) | | |
init | final public void init()(Code) | | |
invokeABAChangeLPs | public void invokeABAChangeLPs(Set communities)(Code) | | Tell all the ABA interested LPs about the new
community memberships, using the local cache of ABA translations.
|
prepareForEnvelopes | final public void prepareForEnvelopes()(Code) | | called by distributor to prepare for "receiveEnvelope(..)" calls.
|
receiveEnvelope | final public Envelope receiveEnvelope(Envelope envelope)(Code) | | Called by transaction close within the thread of Plugins.
Also called at the end of an LP pseudo-transaction, but
most of the logic here is disabled in that case.
|
receiveMessages | final public Envelope receiveMessages(List msgs)(Code) | | Process incoming directive messages. All messages have been
blessed by the message manager. The messages are implicitly
acknowledged by this method. The envelope of published events
resulting from handling the messages is returned.
|
remove | public void remove(Object o)(Code) | | Removed Object to the Blackboard Collection
|
sendDirective | public void sendDirective(Directive aDirective)(Code) | | Alias for sendDirective(aDirective, null);
|
sendDirective | public void sendDirective(Directive aDirective, Collection c)(Code) | | Submit a directive with attached ChangeReports for transmission
from this agent. We fill in the ContentsId with the next available number.
|
Fields inherited from org.cougaar.core.blackboard.Subscriber | final protected List subscriptions(Code)(Java Doc)
|
|
|
|