|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.apache.ode.bpel.engine.BpelServerImpl
public class BpelServerImpl
The BPEL server implementation.
This implementation is intended to be thread safe. The key concurrency mechanism is a "management" read/write lock that synchronizes all management operations (they require "write" access) and prevents concurrent management operations and processing (processing requires "read" access). Write access to the lock is scoped to the method, while read access is scoped to a transaction.
| Nested Class Summary | |
|---|---|
static interface |
BpelServerImpl.ContextsAware
A polled runnable instance that implements this interface will be set with the contexts before the run() method is called. |
static class |
BpelServerImpl.PolledRunnableProcessor
This wraps up the executor service for polled runnables. |
| Field Summary | |
|---|---|
protected BpelDatabase |
_db
|
static java.lang.String |
DEFERRED_PROCESS_INSTANCE_CLEANUP_DISABLED_NAME
|
| Constructor Summary | |
|---|---|
BpelServerImpl()
|
|
| Method Summary | |
|---|---|
void |
cleanupProcess(org.apache.ode.bpel.iapi.ProcessConf pconf)
|
protected BpelEngineImpl |
createBpelEngineImpl(Contexts contexts)
|
protected BpelProcess |
createBpelProcess(org.apache.ode.bpel.iapi.ProcessConf conf)
|
protected boolean |
deleteProcessDAO(javax.xml.namespace.QName pid,
boolean isInMemory)
|
Contexts |
getContexts()
|
org.apache.ode.bpel.iapi.DebuggerContext |
getDebugger(javax.xml.namespace.QName pid)
|
org.apache.ode.bpel.iapi.BpelEngine |
getEngine()
|
boolean |
hasActiveInstances(javax.xml.namespace.QName pid)
|
void |
init()
|
void |
onScheduledJob(org.apache.ode.bpel.iapi.Scheduler.JobInfo jobInfo)
|
void |
register(org.apache.ode.bpel.iapi.ProcessConf conf)
|
void |
registerBpelEventListener(org.apache.ode.bpel.iapi.BpelEventListener listener)
Register a global listener to receive BpelEvents froom all
processes. |
void |
registerExternalVariableEngine(org.apache.ode.bpel.evar.ExternalVariableModule eve)
|
void |
registerMessageExchangeInterceptor(MessageExchangeInterceptor interceptor)
Register a global message exchange interceptor. |
void |
setBindingContext(org.apache.ode.bpel.iapi.BindingContext bc)
|
void |
setConfigProperties(java.util.Properties configProperties)
|
void |
setCronScheduler(CronScheduler cronScheduler)
|
void |
setDaoConnectionFactory(org.apache.ode.bpel.dao.BpelDAOConnectionFactory daoCF)
Set the DAO connection factory. |
void |
setDehydrationPolicy(DehydrationPolicy dehydrationPolicy)
|
void |
setEndpointReferenceContext(org.apache.ode.bpel.iapi.EndpointReferenceContext eprContext)
|
void |
setHydrationLazy(boolean hydrationLazy)
|
void |
setHydrationLazyMinimumSize(int hydrationLazyMinimumSize)
|
void |
setInMemDaoConnectionFactory(org.apache.ode.bpel.dao.BpelDAOConnectionFactory daoCF)
|
void |
setInstanceThrottledMaximumCount(int instanceThrottledMaximumCount)
|
void |
setMessageExchangeContext(org.apache.ode.bpel.iapi.MessageExchangeContext mexContext)
|
void |
setMigrationTransactionTimeout(int migrationTransactionTimeout)
|
void |
setProcessThrottledMaximumCount(int hydrationThrottledMaximumCount)
|
void |
setProcessThrottledMaximumSize(long hydrationThrottledMaximumSize)
|
void |
setScheduler(org.apache.ode.bpel.iapi.Scheduler scheduler)
|
void |
shutdown()
|
void |
start()
|
void |
stop()
|
void |
unregister(javax.xml.namespace.QName pid)
|
void |
unregisterBpelEventListener(org.apache.ode.bpel.iapi.BpelEventListener listener)
Unregister a global listener from receive BpelEvents from all
processes. |
void |
unregisterMessageExchangeInterceptor(MessageExchangeInterceptor interceptor)
Unregister a global message exchange interceptor. |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
|---|
public static final java.lang.String DEFERRED_PROCESS_INSTANCE_CLEANUP_DISABLED_NAME
protected BpelDatabase _db
| Constructor Detail |
|---|
public BpelServerImpl()
| Method Detail |
|---|
public Contexts getContexts()
public void start()
start in interface org.apache.ode.bpel.iapi.BpelServerpublic void registerExternalVariableEngine(org.apache.ode.bpel.evar.ExternalVariableModule eve)
public void registerBpelEventListener(org.apache.ode.bpel.iapi.BpelEventListener listener)
BpelEvents froom all
processes.
listener - public void unregisterBpelEventListener(org.apache.ode.bpel.iapi.BpelEventListener listener)
BpelEvents from all
processes.
listener - public void stop()
stop in interface org.apache.ode.bpel.iapi.BpelServer
public void init()
throws org.apache.ode.bpel.iapi.BpelEngineException
init in interface org.apache.ode.bpel.iapi.BpelServerorg.apache.ode.bpel.iapi.BpelEngineExceptionprotected BpelEngineImpl createBpelEngineImpl(Contexts contexts)
public void shutdown()
throws org.apache.ode.bpel.iapi.BpelEngineException
shutdown in interface org.apache.ode.bpel.iapi.BpelServerorg.apache.ode.bpel.iapi.BpelEngineExceptionpublic org.apache.ode.bpel.iapi.BpelEngine getEngine()
getEngine in interface org.apache.ode.bpel.iapi.BpelServerpublic void register(org.apache.ode.bpel.iapi.ProcessConf conf)
register in interface org.apache.ode.bpel.iapi.BpelServerprotected BpelProcess createBpelProcess(org.apache.ode.bpel.iapi.ProcessConf conf)
public void unregister(javax.xml.namespace.QName pid)
throws org.apache.ode.bpel.iapi.BpelEngineException
unregister in interface org.apache.ode.bpel.iapi.BpelServerorg.apache.ode.bpel.iapi.BpelEngineExceptionpublic void registerMessageExchangeInterceptor(MessageExchangeInterceptor interceptor)
interceptor - message-exchange interceptorpublic void unregisterMessageExchangeInterceptor(MessageExchangeInterceptor interceptor)
interceptor - message-exchange interceptor
protected boolean deleteProcessDAO(javax.xml.namespace.QName pid,
boolean isInMemory)
public void onScheduledJob(org.apache.ode.bpel.iapi.Scheduler.JobInfo jobInfo)
throws org.apache.ode.bpel.iapi.Scheduler.JobProcessorException
onScheduledJob in interface org.apache.ode.bpel.iapi.Scheduler.JobProcessororg.apache.ode.bpel.iapi.Scheduler.JobProcessorExceptionpublic void setDehydrationPolicy(DehydrationPolicy dehydrationPolicy)
public void setConfigProperties(java.util.Properties configProperties)
public void setMessageExchangeContext(org.apache.ode.bpel.iapi.MessageExchangeContext mexContext)
throws org.apache.ode.bpel.iapi.BpelEngineException
setMessageExchangeContext in interface org.apache.ode.bpel.iapi.BpelServerorg.apache.ode.bpel.iapi.BpelEngineException
public void setScheduler(org.apache.ode.bpel.iapi.Scheduler scheduler)
throws org.apache.ode.bpel.iapi.BpelEngineException
setScheduler in interface org.apache.ode.bpel.iapi.BpelServerorg.apache.ode.bpel.iapi.BpelEngineException
public void setCronScheduler(CronScheduler cronScheduler)
throws org.apache.ode.bpel.iapi.BpelEngineException
org.apache.ode.bpel.iapi.BpelEngineException
public void setEndpointReferenceContext(org.apache.ode.bpel.iapi.EndpointReferenceContext eprContext)
throws org.apache.ode.bpel.iapi.BpelEngineException
setEndpointReferenceContext in interface org.apache.ode.bpel.iapi.BpelServerorg.apache.ode.bpel.iapi.BpelEngineException
public void setDaoConnectionFactory(org.apache.ode.bpel.dao.BpelDAOConnectionFactory daoCF)
throws org.apache.ode.bpel.iapi.BpelEngineException
daoCF - BpelDAOConnectionFactory implementation.
org.apache.ode.bpel.iapi.BpelEngineExceptionpublic void setInMemDaoConnectionFactory(org.apache.ode.bpel.dao.BpelDAOConnectionFactory daoCF)
public void setBindingContext(org.apache.ode.bpel.iapi.BindingContext bc)
setBindingContext in interface org.apache.ode.bpel.iapi.BpelServer
public org.apache.ode.bpel.iapi.DebuggerContext getDebugger(javax.xml.namespace.QName pid)
throws org.apache.ode.bpel.iapi.BpelEngineException
getDebugger in interface org.apache.ode.bpel.iapi.BpelServerorg.apache.ode.bpel.iapi.BpelEngineExceptionpublic boolean hasActiveInstances(javax.xml.namespace.QName pid)
public void setHydrationLazy(boolean hydrationLazy)
public void setProcessThrottledMaximumSize(long hydrationThrottledMaximumSize)
public void setProcessThrottledMaximumCount(int hydrationThrottledMaximumCount)
public void setHydrationLazyMinimumSize(int hydrationLazyMinimumSize)
public void setInstanceThrottledMaximumCount(int instanceThrottledMaximumCount)
public void cleanupProcess(org.apache.ode.bpel.iapi.ProcessConf pconf)
throws org.apache.ode.bpel.iapi.BpelEngineException
cleanupProcess in interface org.apache.ode.bpel.iapi.BpelServerorg.apache.ode.bpel.iapi.BpelEngineExceptionpublic void setMigrationTransactionTimeout(int migrationTransactionTimeout)
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||