| java.lang.Object
 org.cougaar.core.blackboard.Distributor
| Distributor | | final class Distributor (Code) | | The Distributor coordinates blackboard transactions, subscriber
updates, and persistence.
|
| DEFAULT_SINGLE_TRANSACTION | | final public static boolean DEFAULT_SINGLE_TRANSACTION(Code) | | The default setting for single transaction model
|
| history | | final public PublishHistory history(Code) | | The publish history is available for subscriber use.
|
| acquireTransactionMutex | | final protected void acquireTransactionMutex()(Code) | | Acquire the transaction mutex. No-op if not running in SINGLE_TRANSACTION mode.
|
| discardRehydrationInfo | | void discardRehydrationInfo(Subscriber subscriber)(Code) | | Called by subscriber to discard rehydration info.
|
| fillSubscription | | public void fillSubscription(Subscription subscription)(Code) | | Provide a new subscription with its initial fill. If the
subscriber of the subscription was persisted, we fill from the
persisted information (see rehydrateNewSubscription) otherwise
we fill from the Blackboard (blackboard.fillSubscription).
|
| getBlackboardCount | | public int getBlackboardCount(Class cl)(Code) | | Pass thru to blackboard to safely return blackboard object
counts.
Used by BlackboardMetricsService
Parameters:
cl - The class type |
| getBlackboardCount | | public int getBlackboardCount(UnaryPredicate predicate)(Code) | | Pass thru to blackboard to safely return blackboard object
counts.
Used by BlackboardMetricsService
Parameters:
predicate - The objects to count in the blackboard int The count of objects that match the predicatecurrently in the blackboard |
| getBlackboardSize | | public int getBlackboardSize()(Code) | | Pass thru to blackboard to safely return the size of the
blackboard collection.
|
| getPersistence | | Persistence getPersistence()(Code) | | Called by Subscriber to link into Blackboard persistence
mechanism
|
| getPersistenceObject | | public PersistenceObject getPersistenceObject()(Code) | | Force a (full) persistence delta to be generated and
return result
|
| invokeABAChangeLPs | | public void invokeABAChangeLPs(Set communities)(Code) | | |
| persistNow | | public void persistNow()(Code) | | Force a persistence delta to be generated.
|
| receiveMessages | | public void receiveMessages(List messages)(Code) | | Process directive and ack messages from other agents. Acks
are given to the message manager. Directive messages are passed
through the message manager for validation and then given to
the Blackboard for processing. Envelopes resulting from that
processing are distributed.
|
| registerSubscriber | | public void registerSubscriber(Subscriber subscriber)(Code) | | Register a Subscriber with the Distributor. Future envelopes are
distributed to all registered subscribers.
|
| releaseTransactionMutex | | final protected void releaseTransactionMutex()(Code) | | Release the transaction mutex. No-op if not running in SINGLE_TRANSACTION mode.
|
| resume | | public void resume()(Code) | | |
| setPersistence | | void setPersistence(Persistence newPersistence, boolean lazy)(Code) | | Called by the blackboard immediately after the constructor,
and only once.
|
| start | | public void start(MessageSwitchService msgSwitch, Object state)(Code) | | Start the distribution thread.
Note that although Distributor is Runnable, it does not
extend Thread, rather, it maintains its own thread state
privately.
|
| startTransaction | | public void startTransaction()(Code) | | |
| suspend | | public void suspend()(Code) | | Complete any active persists, lockout transactions and
timer-based persists, and only allow external state
captures via "persistNow()" and "getPersistenceObject()".
|
| unregisterSubscriber | | public void unregisterSubscriber(Subscriber subscriber)(Code) | | Unregister subscriber with the Distributor. Future envelopes are
not distributed to unregistered subscribers.
|
|
|