|
|||||||||
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.
Constructor Summary | |
---|---|
BpelServerImpl()
|
Method Summary | |
---|---|
protected void |
assertNoTransaction()
|
protected void |
assertTransaction()
|
void |
cleanupProcess(javax.xml.namespace.QName pid)
|
MyRoleMessageExchange |
createMessageExchange(InvocationStyle istyle,
javax.xml.namespace.QName targetService,
java.lang.String operation,
java.lang.String clientKey)
Create a "my role" message exchange for invoking a BPEL process. |
BpelDatabase |
getBpelDb()
|
ODEProcess |
getBpelProcess(javax.xml.namespace.QName processId)
|
OdeConfigProperties |
getConfigProperties()
|
MessageExchange |
getMessageExchange(java.lang.String mexId)
Retrieve a message identified by the given identifer. |
MessageExchange |
getMessageExchangeByForeignKey(java.lang.String foreignKey)
|
ProcessModel |
getProcessModel(javax.xml.namespace.QName processId)
|
SharedEndpoints |
getSharedEndpoints()
|
java.util.Set<InvocationStyle> |
getSupportedInvocationStyle(javax.xml.namespace.QName serviceId)
Inquire of the engine the invocation styles that are supported for a given service. |
void |
init()
Initialize the BPEL engine. |
void |
onScheduledJob(Scheduler.JobInfo jobInfo)
|
void |
register(ProcessConf conf)
Register a process with the server. |
void |
registerBpelEventListener(BpelEventListener listener)
Register a global listener to receive BpelEvent s froom all processes. |
void |
registerExtensionBundle(ExtensionBundleRuntime bundle)
|
void |
registerExternalVariableEngine(ExternalVariableModule eve)
|
void |
registerMessageExchangeInterceptor(MessageExchangeInterceptor interceptor)
Register a global message exchange interceptor. |
void |
setBindingContext(BindingContext bc)
Configure the with a binding context. |
void |
setConfigProperties(OdeConfigProperties properties)
|
void |
setDaoConnectionFactory(BpelDAOConnectionFactory daoCF)
Set the DAO connection factory. |
void |
setDehydrationPolicy(DehydrationPolicy dehydrationPolicy)
|
void |
setEndpointReferenceContext(EndpointReferenceContext eprContext)
Configure the with an endpoint-reference (EPR) context. |
void |
setExecutor(java.util.concurrent.ExecutorService exec)
|
void |
setMessageExchangeContext(MessageExchangeContext mexContext)
Configure the with a message-exchange context. |
void |
setScheduler(Scheduler scheduler)
Configure the with a scheduler. |
void |
setTransacted(boolean atomicScope)
|
void |
setTransactionManager(javax.transaction.TransactionManager txm)
|
void |
shutdown()
Called to shutdown the BPEL egnine. |
void |
start()
Start the BPEL engine. |
void |
stop()
Stop the BPEL engine: results in the cessation of process execution. |
void |
unregister(javax.xml.namespace.QName pid)
Unregister a process from the server. |
void |
unregisterBpelEventListener(BpelEventListener listener)
Unregister a global listener from receive BpelEvent s from all processes. |
void |
unregisterExtensionBundle(java.lang.String nsURI)
|
void |
unregisterMessageExchangeInterceptor(MessageExchangeInterceptor interceptor)
Unregister a global message exchange interceptor. |
protected void |
waitForQuiessence()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public BpelServerImpl()
Method Detail |
---|
protected void waitForQuiessence()
public void start()
BpelServer
start
in interface BpelServer
public BpelDatabase getBpelDb()
public void registerExternalVariableEngine(ExternalVariableModule eve)
public void registerBpelEventListener(BpelEventListener listener)
BpelEvent
s froom all processes.
listener
- public void unregisterBpelEventListener(BpelEventListener listener)
BpelEvent
s from all processes.
listener
- public void registerExtensionBundle(ExtensionBundleRuntime bundle)
public void unregisterExtensionBundle(java.lang.String nsURI)
public void stop()
BpelServer
stop
in interface BpelServer
public void init() throws BpelEngineException
BpelServer
init
in interface BpelServer
BpelEngineException
public void shutdown() throws BpelEngineException
BpelServer
shutdown
in interface BpelServer
BpelEngineException
public void register(ProcessConf conf)
BpelServer
register
in interface BpelServer
public void unregister(javax.xml.namespace.QName pid) throws BpelEngineException
BpelServer
unregister
in interface BpelServer
pid
- process to unregister
BpelEngineException
public void cleanupProcess(javax.xml.namespace.QName pid) throws BpelEngineException
BpelEngineException
public void registerMessageExchangeInterceptor(MessageExchangeInterceptor interceptor)
interceptor
- message-exchange interceptorpublic void unregisterMessageExchangeInterceptor(MessageExchangeInterceptor interceptor)
interceptor
- message-exchange interceptorpublic void onScheduledJob(Scheduler.JobInfo jobInfo) throws Scheduler.JobProcessorException
onScheduledJob
in interface Scheduler.JobProcessor
Scheduler.JobProcessorException
public void setTransactionManager(javax.transaction.TransactionManager txm)
public void setDehydrationPolicy(DehydrationPolicy dehydrationPolicy)
public void setConfigProperties(OdeConfigProperties properties)
public OdeConfigProperties getConfigProperties()
public void setMessageExchangeContext(MessageExchangeContext mexContext) throws BpelEngineException
BpelServer
setMessageExchangeContext
in interface BpelServer
mexContext
- MessageExchangeContext
implementation
BpelEngineException
MessageExchangeContext
public void setScheduler(Scheduler scheduler) throws BpelEngineException
BpelServer
setScheduler
in interface BpelServer
BpelEngineException
public void setEndpointReferenceContext(EndpointReferenceContext eprContext) throws BpelEngineException
BpelServer
setEndpointReferenceContext
in interface BpelServer
eprContext
- EndpointReferenceContext
implementation
BpelEngineException
EndpointReferenceContext
public void setDaoConnectionFactory(BpelDAOConnectionFactory daoCF) throws BpelEngineException
daoCF
- BpelDAOConnectionFactory
implementation.
BpelEngineException
public void setBindingContext(BindingContext bc)
BpelServer
setBindingContext
in interface BpelServer
bc
- BindingContext
implementationBindingContext
public SharedEndpoints getSharedEndpoints()
public void setExecutor(java.util.concurrent.ExecutorService exec)
public MyRoleMessageExchange createMessageExchange(InvocationStyle istyle, javax.xml.namespace.QName targetService, java.lang.String operation, java.lang.String clientKey) throws BpelEngineException
BpelServer
createMessageExchange
in interface BpelServer
targetService
- the service id of the process being called, if knownoperation
- name of the operation
MyRoleMessageExchange
the newly created message exchange
BpelEngineException
public MessageExchange getMessageExchange(java.lang.String mexId) throws BpelEngineException
BpelServer
getMessageExchange
in interface BpelServer
mexId
- message exhcange identifier
BpelEngineException
public MessageExchange getMessageExchangeByForeignKey(java.lang.String foreignKey) throws BpelEngineException
getMessageExchangeByForeignKey
in interface BpelServer
BpelEngineException
public java.util.Set<InvocationStyle> getSupportedInvocationStyle(javax.xml.namespace.QName serviceId)
BpelServer
getSupportedInvocationStyle
in interface BpelServer
serviceId
- service identifier
InvocationStyle
spublic ProcessModel getProcessModel(javax.xml.namespace.QName processId)
protected void assertTransaction()
protected void assertNoTransaction()
public ODEProcess getBpelProcess(javax.xml.namespace.QName processId)
public void setTransacted(boolean atomicScope)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |