Java Doc for Blackboard.java in  » Science » Cougaar12_4 » org » cougaar » core » blackboard » Java Source Code / Java DocumentationJava Source Code and Java Documentation

Java Source Code / Java Documentation
1. 6.0 JDK Core
2. 6.0 JDK Modules
3. 6.0 JDK Modules com.sun
4. 6.0 JDK Modules com.sun.java
5. 6.0 JDK Modules sun
6. 6.0 JDK Platform
7. Ajax
8. Apache Harmony Java SE
9. Aspect oriented
10. Authentication Authorization
11. Blogger System
12. Build
13. Byte Code
14. Cache
15. Chart
16. Chat
17. Code Analyzer
18. Collaboration
19. Content Management System
20. Database Client
21. Database DBMS
22. Database JDBC Connection Pool
23. Database ORM
24. Development
25. EJB Server geronimo
26. EJB Server GlassFish
27. EJB Server JBoss 4.2.1
28. EJB Server resin 3.1.5
29. ERP CRM Financial
30. ESB
31. Forum
32. GIS
33. Graphic Library
34. Groupware
35. HTML Parser
36. IDE
37. IDE Eclipse
38. IDE Netbeans
39. Installer
40. Internationalization Localization
41. Inversion of Control
42. Issue Tracking
43. J2EE
44. JBoss
45. JMS
46. JMX
47. Library
48. Mail Clients
49. Net
50. Parser
51. PDF
52. Portal
53. Profiler
54. Project Management
55. Report
56. RSS RDF
57. Rule Engine
58. Science
59. Scripting
60. Search Engine
61. Security
62. Sevlet Container
63. Source Control
64. Swing Library
65. Template Engine
66. Test Coverage
67. Testing
68. UML
69. Web Crawler
70. Web Framework
71. Web Mail
72. Web Server
73. Web Services
74. Web Services apache cxf 2.0.1
75. Web Services AXIS2
76. Wiki Engine
77. Workflow Engines
78. XML
79. XML UI
Java
Java Tutorial
Java Open Source
Jar File Download
Java Articles
Java Products
Java by API
Photoshop Tutorials
Maya Tutorials
Flash Tutorials
3ds-Max Tutorials
Illustrator Tutorials
GIMP Tutorials
C# / C Sharp
C# / CSharp Tutorial
C# / CSharp Open Source
ASP.Net
ASP.NET Tutorial
JavaScript DHTML
JavaScript Tutorial
JavaScript Reference
HTML / CSS
HTML CSS Reference
C / ANSI-C
C Tutorial
C++
C++ Tutorial
Ruby
PHP
Python
Python Tutorial
Python Open Source
SQL Server / T-SQL
SQL Server / T-SQL Tutorial
Oracle PL / SQL
Oracle PL/SQL Tutorial
PostgreSQL
SQL / MySQL
MySQL Tutorial
VB.Net
VB.Net Tutorial
Flash / Flex / ActionScript
VBA / Excel / Access / Word
XML
XML Tutorial
Microsoft Office PowerPoint 2007 Tutorial
Microsoft Office Excel 2007 Tutorial
Microsoft Office Word 2007 Tutorial
Java Source Code / Java Documentation » Science » Cougaar12_4 » org.cougaar.core.blackboard 
Source Cross Reference  Class Diagram Java Document (Java Doc) 


java.lang.Object
   org.cougaar.core.blackboard.Subscriber
      org.cougaar.core.blackboard.Blackboard

Blackboard
public class Blackboard extends Subscriber implements BlackboardServesDomain,BlackboardClient,PrivilegedClaimant(Code)
A Subscriber created by the StandardBlackboard that maintains a view of all published objects, invokes org.cougaar.core.domain.Domain org.cougaar.core.domain.LogicProvider s, and monitors community membership changes.

Inner Class :interface PlanEnvelope
Inner Class :public static class ObjectTracker

Field Summary
final public static  StringINSERTION_POINT
    
final public static  booleanPEDANTIC
    
protected  AlarmServicealarmService
    
final public static  booleanenablePublishException
    
protected  CollectionSubscriptioneverything
    
final public static  booleanisSavePriorPublisher
    
protected  LoggingServicelogger
    
protected  DomainForBlackboardServicemyDomainService
    
protected  ServiceBrokermyServiceBroker
    
protected  MessageAddressself
    
protected  ThreadServicethreadS
    

Constructor Summary
public  Blackboard(MessageSwitchService msgSwitch, ServiceBroker sb, Object state)
    

Method Summary
public  voidadd(Object o)
    
public  voidappendMessagesToSend(List messages)
    
public  voidchange(Object o)
    
public  voidchange(Object o, Collection changes)
    
protected  EnvelopeTupleclientAddedObject(Object o)
    
protected  EnvelopeTupleclientChangedObject(Object o, List changes)
    
protected  EnvelopeTupleclientRemovedObject(Object o)
    
protected  voidconnectDomains()
    
public  intcountBlackboard(Class cl)
    
public  intcountBlackboard(UnaryPredicate predicate)
    
protected  EnvelopecreateEnvelope()
    
protected  PersistencecreatePersistence()
    
public  longcurrentTimeMillis()
    
protected  EnvelopeexecuteDelayedLPActions()
    
public  voidfillQuery(Subscription subscription)
    
public  voidfillSubscription(Subscription subscription)
     Provide a new subscription with its initial fill.
public  CollectiongetABAAddresses(AttributeBasedAddress aba)
    
public  ABATranslationgetABATranslation(AttributeBasedAddress aba)
    
public  StringgetBlackboardClientName()
    
public  intgetBlackboardSize()
    
public  MessageAddressgetCID()
    
protected  StringgetCommunitySpec(AttributeBasedAddress aba)
    
public  DistributorgetDistributor()
    
public  PublishHistorygetHistory()
    
public  PersistenceObjectgetPersistenceObject()
    
final public static  ObjectTrackergetTracker()
    
final public  voidinit()
    
public  voidinvokeABAChangeLPs(Set communities)
     Tell all the ABA interested LPs about the new community memberships, using the local cache of ABA translations.
final public  voidprepareForEnvelopes()
     called by distributor to prepare for "receiveEnvelope(..)" calls.
final public  EnvelopereceiveEnvelope(Envelope envelope)
     Called by transaction close within the thread of Plugins.
final public  EnvelopereceiveMessages(List msgs)
     Process incoming directive messages.
public  voidremove(Object o)
    
public  voidrestart(MessageAddress cid)
    
public  EnumerationsearchBlackboard(UnaryPredicate predicate)
    
public  voidsendDirective(Directive aDirective)
    
public  voidsendDirective(Directive aDirective, Collection c)
     Submit a directive with attached ChangeReports for transmission from this agent.
public  voidstop()
    

Field Detail
INSERTION_POINT
final public static String INSERTION_POINT(Code)



PEDANTIC
final public static boolean PEDANTIC(Code)



alarmService
protected AlarmService alarmService(Code)



enablePublishException
final public static boolean enablePublishException(Code)



everything
protected CollectionSubscription everything(Code)



isSavePriorPublisher
final public static boolean isSavePriorPublisher(Code)



logger
protected LoggingService logger(Code)



myDomainService
protected DomainForBlackboardService myDomainService(Code)



myServiceBroker
protected ServiceBroker myServiceBroker(Code)



self
protected MessageAddress self(Code)



threadS
protected ThreadService threadS(Code)




Constructor Detail
Blackboard
public Blackboard(MessageSwitchService msgSwitch, ServiceBroker sb, Object state)(Code)




Method Detail
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



change
public void change(Object o, Collection changes)(Code)



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)



countBlackboard
public int countBlackboard(UnaryPredicate predicate)(Code)



createEnvelope
protected Envelope createEnvelope()(Code)



createPersistence
protected Persistence createPersistence()(Code)



currentTimeMillis
public long currentTimeMillis()(Code)



executeDelayedLPActions
protected Envelope executeDelayedLPActions()(Code)



fillQuery
public void fillQuery(Subscription subscription)(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.



getABAAddresses
public Collection getABAAddresses(AttributeBasedAddress aba)(Code)



getABATranslation
public ABATranslation getABATranslation(AttributeBasedAddress aba)(Code)



getBlackboardClientName
public String getBlackboardClientName()(Code)



getBlackboardSize
public int getBlackboardSize()(Code)



getCID
public MessageAddress getCID()(Code)



getCommunitySpec
protected String getCommunitySpec(AttributeBasedAddress aba)(Code)



getDistributor
public Distributor getDistributor()(Code)



getHistory
public PublishHistory getHistory()(Code)



getPersistenceObject
public PersistenceObject getPersistenceObject() throws PersistenceNotEnabledException(Code)



getTracker
final public static ObjectTracker getTracker()(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



restart
public void restart(MessageAddress cid)(Code)



searchBlackboard
public Enumeration searchBlackboard(UnaryPredicate predicate)(Code)



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.



stop
public void stop()(Code)



Fields inherited from org.cougaar.core.blackboard.Subscriber
final protected List subscriptions(Code)(Java Doc)

Methods inherited from org.cougaar.core.blackboard.Subscriber
public static boolean abortTransaction()(Code)(Java Doc)
protected EnvelopeTuple bulkAddObject(Collection c)(Code)(Java Doc)
protected EnvelopeTuple bulkAddObject(Enumeration en)(Code)(Java Doc)
protected EnvelopeTuple bulkAddObject(Iterator en)(Code)(Java Doc)
final void checkTransactionOK(String methodname, Object arg)(Code)(Java Doc)
final void checkTransactionOK(String methodname)(Code)(Java Doc)
final protected void checkUnpostedChangeReports()(Code)(Java Doc)
protected void claimObject(Object o)(Code)(Java Doc)
protected EnvelopeTuple clientAddedObject(Object o)(Code)(Java Doc)
protected EnvelopeTuple clientChangedObject(Object o, List changes)(Code)(Java Doc)
protected EnvelopeTuple clientRemovedObject(Object o)(Code)(Java Doc)
final public void closeTransaction(boolean resetSubscriptions) throws SubscriberException(Code)(Java Doc)
final public void closeTransaction()(Code)(Java Doc)
final public void closeTransactionDontReset()(Code)(Java Doc)
protected Envelope createEnvelope()(Code)(Java Doc)
public boolean didRehydrate()(Code)(Java Doc)
protected Envelope flushOutbox()(Code)(Java Doc)
public BlackboardClient getClient()(Code)(Java Doc)
public String getName()(Code)(Java Doc)
public List getPendingEnvelopes()(Code)(Java Doc)
public Persistence getPersistence()(Code)(Java Doc)
public int getPublishAddedCount()(Code)(Java Doc)
public int getPublishChangedCount()(Code)(Java Doc)
public int getPublishRemovedCount()(Code)(Java Doc)
public Subscriber getSubscriber()(Code)(Java Doc)
public int getSubscriptionCount()(Code)(Java Doc)
public int getSubscriptionSize()(Code)(Java Doc)
public List getTransactionEnvelopes()(Code)(Java Doc)
public boolean haveCollectionsChanged()(Code)(Java Doc)
public boolean isBusy()(Code)(Java Doc)
final public boolean isInTransaction()(Code)(Java Doc)
final public boolean isMyTransaction()(Code)(Java Doc)
public boolean isQuiescent()(Code)(Java Doc)
boolean isReadyToPersist()(Code)(Java Doc)
final protected boolean isTimestamped()(Code)(Java Doc)
final public boolean isTransactionOpen()(Code)(Java Doc)
protected Transaction newTransaction()(Code)(Java Doc)
final public void openTransaction()(Code)(Java Doc)
public void persistNow() throws PersistenceNotEnabledException(Code)(Java Doc)
protected Envelope privateGetPublishedChanges()(Code)(Java Doc)
protected boolean privateUpdateSubscriptions()(Code)(Java Doc)
final public void publishAdd(Object o)(Code)(Java Doc)
final public void publishChange(Object o)(Code)(Java Doc)
final public void publishChange(Object o, Collection changes)(Code)(Java Doc)
final public void publishRemove(Object o)(Code)(Java Doc)
final public Collection query(UnaryPredicate isMember)(Code)(Java Doc)
public void receiveEnvelopes(List envelopes, boolean envelopeQuiescenceRequired)(Code)(Java Doc)
final public SubscriptionWatcher registerInterest(SubscriptionWatcher w)(Code)(Java Doc)
final public SubscriptionWatcher registerInterest()(Code)(Java Doc)
protected void resetSubscriptionChanges()(Code)(Java Doc)
public void setClientDistributor(BlackboardClient client, Distributor newDistributor)(Code)(Java Doc)
public void setName(String newName)(Code)(Java Doc)
public void setReadyToPersist()(Code)(Java Doc)
public void setShouldBePersisted(boolean shouldBePersisted)(Code)(Java Doc)
final protected long setTransactionOpenTime()(Code)(Java Doc)
public boolean shouldBePersisted()(Code)(Java Doc)
public void signalClientActivity()(Code)(Java Doc)
public void signalExternalActivity()(Code)(Java Doc)
public void signalInternalActivity()(Code)(Java Doc)
final protected void startTransaction()(Code)(Java Doc)
final protected void stopTransaction()(Code)(Java Doc)
public Subscription subscribe(UnaryPredicate isMember)(Code)(Java Doc)
public Subscription subscribe(UnaryPredicate isMember, boolean isIncremental)(Code)(Java Doc)
public Subscription subscribe(UnaryPredicate isMember, Collection realCollection)(Code)(Java Doc)
public Subscription subscribe(UnaryPredicate isMember, Collection realCollection, boolean isIncremental)(Code)(Java Doc)
final public Subscription subscribe(Subscription subscription)(Code)(Java Doc)
public String toString()(Code)(Java Doc)
final public boolean tryOpenTransaction()(Code)(Java Doc)
protected void unclaimObject(Object o)(Code)(Java Doc)
final public void unregisterInterest(SubscriptionWatcher w) throws SubscriberException(Code)(Java Doc)
public void unsubscribe(Subscription subscription)(Code)(Java Doc)
public boolean wasClientActivity()(Code)(Java Doc)
public boolean wasExternalActivity()(Code)(Java Doc)
public boolean wasInternalActivity()(Code)(Java Doc)

Methods inherited from java.lang.Object
native protected Object clone() throws CloneNotSupportedException(Code)(Java Doc)
public boolean equals(Object obj)(Code)(Java Doc)
protected void finalize() throws Throwable(Code)(Java Doc)
final native public Class getClass()(Code)(Java Doc)
native public int hashCode()(Code)(Java Doc)
final native public void notify()(Code)(Java Doc)
final native public void notifyAll()(Code)(Java Doc)
public String toString()(Code)(Java Doc)
final native public void wait(long timeout) throws InterruptedException(Code)(Java Doc)
final public void wait(long timeout, int nanos) throws InterruptedException(Code)(Java Doc)
final public void wait() throws InterruptedException(Code)(Java Doc)

www.java2java.com | Contact Us
Copyright 2009 - 12 Demo Source and Support. All rights reserved.
All other trademarks are property of their respective owners.