Java Doc for EngineImpl.java in  » Workflow-Engines » Dalma » dalma » impl » 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 » Workflow Engines » Dalma » dalma.impl 
Source Cross Reference  Class Diagram Java Document (Java Doc) 


java.lang.Object
   dalma.Engine
      dalma.spi.EngineSPI
         dalma.impl.EngineImpl

EngineImpl
final public class EngineImpl extends EngineSPI implements Serializable(Code)
Engine implementation.

Persistence of Engine

Engine object is serialized to persist the state of the engine itself across JVM sessions.
author:
   Kohsuke Kawaguchi



Field Summary
final transient  ClassLoaderclassLoader
     ClassLoader used to restore conversations.
final transient  ObjectcompletionLock
     Signals when all the conversation completes.
final transient  Map<Integer, ConversationImpl>conversations
     All conversations that belong to this engine.
final transient  Map<String, EndPointImpl>endPoints
     All EndPoint s that bleong to this engine.
final transient  EngineListenerSetlisteners
    
final transient  ObjectsaveLoadLock
     This lock is used to control "dalma.xml" access.

Constructor Summary
public  EngineImpl(File rootDir, ClassLoader classLoader, Executor executor)
    

Method Summary
public  voidaddEndPoint(EndPoint ep)
    
public synchronized  EndPointaddEndPoint(String name, String endpointURL)
    
public  Map<String, EndPoint>addEndPoints(Properties endpointURLs)
    
public  voidaddListener(EngineListener listener)
    
protected  voidaddToErrorQueue(Throwable t)
    
public  voidconfigureWithBSF(File scriptFile)
    
public  ConversationImplcreateConversation(Runnable target)
    
public  ConversationImplcreateConversation(Workflow workflow)
    
 intgenerateUniqueId()
     Generates unique IDs for ConversationImpl .
public  ConversationImplgetConversation(int id)
    
public synchronized  Collection<Conversation>getConversations()
    
 FilegetConversationsDir()
     Directory to store conversations.
public  intgetConversationsSize()
    
public  EndPointgetEndPoint(String name)
    
public  Map<String, EndPoint>getEndPoints()
    
public  ErrorHandlergetErrorHandler()
    
public  DategetLastActiveTime()
    
public  booleanisStarted()
    
 voidqueue(FiberImpl f)
     Queues a conversation that became newly runnable.
public  voidremoveListener(EngineListener listener)
    
public  voidsetErrorHandler(ErrorHandler errorHandler)
    
public  voidsetLogger(Logger logger)
    
public  voidstart()
    
public  voidstop()
    
public  voidwaitForCompletion()
    

Field Detail
classLoader
final transient ClassLoader classLoader(Code)
ClassLoader used to restore conversations. TODO: allow each conversation to have its own class loader, but this has an issue in the restoration. Transient because ClassLoaders can't be serialized in general.



completionLock
final transient Object completionLock(Code)
Signals when all the conversation completes.



conversations
final transient Map<Integer, ConversationImpl> conversations(Code)
All conversations that belong to this engine. access need to be synchronized. Keyed by their ConversationImpl.id .



endPoints
final transient Map<String, EndPointImpl> endPoints(Code)
All EndPoint s that bleong to this engine. access need to be synchronized.



listeners
final transient EngineListenerSet listeners(Code)



saveLoadLock
final transient Object saveLoadLock(Code)
This lock is used to control "dalma.xml" access.




Constructor Detail
EngineImpl
public EngineImpl(File rootDir, ClassLoader classLoader, Executor executor) throws IOException(Code)




Method Detail
addEndPoint
public void addEndPoint(EndPoint ep)(Code)



addEndPoint
public synchronized EndPoint addEndPoint(String name, String endpointURL) throws ParseException(Code)



addEndPoints
public Map<String, EndPoint> addEndPoints(Properties endpointURLs) throws ParseException(Code)



addListener
public void addListener(EngineListener listener)(Code)



addToErrorQueue
protected void addToErrorQueue(Throwable t)(Code)



configureWithBSF
public void configureWithBSF(File scriptFile) throws IOException(Code)



createConversation
public ConversationImpl createConversation(Runnable target) throws IOException(Code)



createConversation
public ConversationImpl createConversation(Workflow workflow) throws IOException(Code)



generateUniqueId
int generateUniqueId() throws IOException(Code)
Generates unique IDs for ConversationImpl .



getConversation
public ConversationImpl getConversation(int id)(Code)



getConversations
public synchronized Collection<Conversation> getConversations()(Code)



getConversationsDir
File getConversationsDir()(Code)
Directory to store conversations.



getConversationsSize
public int getConversationsSize()(Code)



getEndPoint
public EndPoint getEndPoint(String name)(Code)



getEndPoints
public Map<String, EndPoint> getEndPoints()(Code)



getErrorHandler
public ErrorHandler getErrorHandler()(Code)



getLastActiveTime
public Date getLastActiveTime()(Code)



isStarted
public boolean isStarted()(Code)



queue
void queue(FiberImpl f)(Code)
Queues a conversation that became newly runnable.



removeListener
public void removeListener(EngineListener listener)(Code)



setErrorHandler
public void setErrorHandler(ErrorHandler errorHandler)(Code)



setLogger
public void setLogger(Logger logger)(Code)



start
public void start()(Code)



stop
public void stop()(Code)



waitForCompletion
public void waitForCompletion() throws InterruptedException(Code)




Methods inherited from dalma.Engine
abstract public void addEndPoint(EndPoint endPoint)(Code)(Java Doc)
abstract public EndPoint addEndPoint(String endPointName, String endpointURL) throws ParseException(Code)(Java Doc)
abstract public Map<String, EndPoint> addEndPoints(Properties endpointURLs) throws ParseException(Code)(Java Doc)
abstract public void addListener(EngineListener listener)(Code)(Java Doc)
abstract public void configureWithBSF(File scriptFile) throws IOException(Code)(Java Doc)
abstract public Conversation createConversation(Workflow workflow) throws IOException(Code)(Java Doc)
abstract public Conversation createConversation(Runnable workflow) throws IOException(Code)(Java Doc)
abstract public Conversation getConversation(int id)(Code)(Java Doc)
abstract public Collection<Conversation> getConversations()(Code)(Java Doc)
abstract public int getConversationsSize()(Code)(Java Doc)
abstract public EndPoint getEndPoint(String name)(Code)(Java Doc)
abstract public Map<String, EndPoint> getEndPoints()(Code)(Java Doc)
abstract public ErrorHandler getErrorHandler()(Code)(Java Doc)
abstract public Date getLastActiveTime()(Code)(Java Doc)
abstract public boolean isStarted()(Code)(Java Doc)
abstract public void removeListener(EngineListener listener)(Code)(Java Doc)
abstract public void setErrorHandler(ErrorHandler errorHandler)(Code)(Java Doc)
abstract public void setLogger(Logger logger)(Code)(Java Doc)
abstract public void start()(Code)(Java Doc)
abstract public void stop()(Code)(Java Doc)
abstract public void waitForCompletion() throws InterruptedException(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.