Package org.jbpm.kie.services.impl
Class AbstractDeploymentService
- java.lang.Object
-
- org.jbpm.kie.services.impl.AbstractDeploymentService
-
- All Implemented Interfaces:
DeploymentService,ListenerSupport
- Direct Known Subclasses:
KModuleDeploymentService
public abstract class AbstractDeploymentService extends Object implements DeploymentService, ListenerSupport
-
-
Field Summary
Fields Modifier and Type Field Description protected Map<String,DeployedUnit>deploymentsMapprotected javax.persistence.EntityManagerFactoryemfprotected org.kie.internal.identity.IdentityProvideridentityProviderprotected Set<DeploymentEventListener>listenersprotected org.kie.api.runtime.manager.RuntimeManagerFactorymanagerFactoryprotected RuntimeDataServiceruntimeDataService
-
Constructor Summary
Constructors Constructor Description AbstractDeploymentService()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddListener(DeploymentEventListener listener)Adds a new deployment listener.voidcommonDeploy(DeploymentUnit unit, DeployedUnitImpl deployedUnit, org.kie.api.runtime.manager.RuntimeEnvironment environemnt, org.kie.api.runtime.KieContainer kieContainer)voiddeploy(DeploymentUnit unit)Performs deployment operation of givenunit.DeployedUnitgetDeployedUnit(String deploymentUnitId)ReturnsDeployedUnitinstance for given deployment id if existsCollection<DeployedUnit>getDeployedUnits()Returns all (currently) deployed units.Map<String,DeployedUnit>getDeploymentsMap()javax.persistence.EntityManagerFactorygetEmf()Collection<DeploymentEventListener>getListeners()Returns all deployment listenersorg.kie.api.runtime.manager.RuntimeManagerFactorygetManagerFactory()RuntimeDataServicegetRuntimeDataService()org.kie.api.runtime.manager.RuntimeManagergetRuntimeManager(String deploymentUnitId)ReturnsRuntimeManagerinstance dedicated to deployment unit identified by given idbooleanisDeployed(String deploymentUnitId)Performs a check if given deployment is already activevoidnotifyOnActivate(DeploymentUnit unit, DeployedUnit deployedUnit)voidnotifyOnDeactivate(DeploymentUnit unit, DeployedUnit deployedUnit)voidnotifyOnDeploy(DeploymentUnit unit, DeployedUnit deployedUnit)voidnotifyOnUnDeploy(DeploymentUnit unit, DeployedUnit deployedUnit)voidremoveListener(DeploymentEventListener listener)Removes an existing deployment listener.voidsetEmf(javax.persistence.EntityManagerFactory emf)voidsetIdentityProvider(org.kie.internal.identity.IdentityProvider identityProvider)voidsetManagerFactory(org.kie.api.runtime.manager.RuntimeManagerFactory managerFactory)voidsetRuntimeDataService(RuntimeDataService runtimeDataService)protected AuditEventBuildersetupAuditLogger(org.kie.internal.identity.IdentityProvider identityProvider, String deploymentUnitId)voidshutdown()voidundeploy(DeploymentUnit unit)Performs undeployment operation of givenunit.voidundeploy(DeploymentUnit unit, Function<DeploymentUnit,Boolean> beforeUndeploy)Performs undeployment operation of givenunitaborting existing process instances if needed.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.jbpm.services.api.DeploymentService
activate, deactivate
-
-
-
-
Field Detail
-
managerFactory
protected org.kie.api.runtime.manager.RuntimeManagerFactory managerFactory
-
runtimeDataService
protected RuntimeDataService runtimeDataService
-
emf
protected javax.persistence.EntityManagerFactory emf
-
identityProvider
protected org.kie.internal.identity.IdentityProvider identityProvider
-
listeners
protected Set<DeploymentEventListener> listeners
-
deploymentsMap
protected Map<String,DeployedUnit> deploymentsMap
-
-
Method Detail
-
addListener
public void addListener(DeploymentEventListener listener)
Description copied from interface:ListenerSupportAdds a new deployment listener.- Specified by:
addListenerin interfaceListenerSupport
-
removeListener
public void removeListener(DeploymentEventListener listener)
Description copied from interface:ListenerSupportRemoves an existing deployment listener.- Specified by:
removeListenerin interfaceListenerSupport
-
getListeners
public Collection<DeploymentEventListener> getListeners()
Description copied from interface:ListenerSupportReturns all deployment listeners- Specified by:
getListenersin interfaceListenerSupport- Returns:
- deployment listeners
-
deploy
public void deploy(DeploymentUnit unit)
Description copied from interface:DeploymentServicePerforms deployment operation of givenunit.- Specified by:
deployin interfaceDeploymentService- Parameters:
unit- deployment unit to be deployed to runtime
-
notifyOnDeploy
public void notifyOnDeploy(DeploymentUnit unit, DeployedUnit deployedUnit)
-
notifyOnUnDeploy
public void notifyOnUnDeploy(DeploymentUnit unit, DeployedUnit deployedUnit)
-
notifyOnActivate
public void notifyOnActivate(DeploymentUnit unit, DeployedUnit deployedUnit)
-
notifyOnDeactivate
public void notifyOnDeactivate(DeploymentUnit unit, DeployedUnit deployedUnit)
-
commonDeploy
public void commonDeploy(DeploymentUnit unit, DeployedUnitImpl deployedUnit, org.kie.api.runtime.manager.RuntimeEnvironment environemnt, org.kie.api.runtime.KieContainer kieContainer)
-
undeploy
public void undeploy(DeploymentUnit unit)
Description copied from interface:DeploymentServicePerforms undeployment operation of givenunit.- Specified by:
undeployin interfaceDeploymentService- Parameters:
unit- deployment unit to be undeployed from runtime
-
undeploy
public void undeploy(DeploymentUnit unit, Function<DeploymentUnit,Boolean> beforeUndeploy)
Description copied from interface:DeploymentServicePerforms undeployment operation of givenunitaborting existing process instances if needed.- Specified by:
undeployin interfaceDeploymentService- Parameters:
unit- deployment unit to be undeployed from runtimebeforeUndeploy- a function to run custom actions before undeploying a givenDeploymentUnit. It should return if the unit can be deployed or not determining if the deployment can continue.
-
getRuntimeManager
public org.kie.api.runtime.manager.RuntimeManager getRuntimeManager(String deploymentUnitId)
Description copied from interface:DeploymentServiceReturnsRuntimeManagerinstance dedicated to deployment unit identified by given id- Specified by:
getRuntimeManagerin interfaceDeploymentService- Parameters:
deploymentUnitId- identifier of deployment unit- Returns:
RuntimeManagerif exists for given deployment id otherwise null
-
getDeployedUnit
public DeployedUnit getDeployedUnit(String deploymentUnitId)
Description copied from interface:DeploymentServiceReturnsDeployedUnitinstance for given deployment id if exists- Specified by:
getDeployedUnitin interfaceDeploymentService- Parameters:
deploymentUnitId- identifier of deployment unit- Returns:
DeployedUnitinstance if exists for given deployment id otherwise null
-
getDeploymentsMap
public Map<String,DeployedUnit> getDeploymentsMap()
-
getDeployedUnits
public Collection<DeployedUnit> getDeployedUnits()
Description copied from interface:DeploymentServiceReturns all (currently) deployed units.- Specified by:
getDeployedUnitsin interfaceDeploymentService- Returns:
- collections of all existing deployed units
-
getManagerFactory
public org.kie.api.runtime.manager.RuntimeManagerFactory getManagerFactory()
-
setManagerFactory
public void setManagerFactory(org.kie.api.runtime.manager.RuntimeManagerFactory managerFactory)
-
getRuntimeDataService
public RuntimeDataService getRuntimeDataService()
-
getEmf
public javax.persistence.EntityManagerFactory getEmf()
-
setEmf
public void setEmf(javax.persistence.EntityManagerFactory emf)
-
setRuntimeDataService
public void setRuntimeDataService(RuntimeDataService runtimeDataService)
-
setIdentityProvider
public void setIdentityProvider(org.kie.internal.identity.IdentityProvider identityProvider)
-
setupAuditLogger
protected AuditEventBuilder setupAuditLogger(org.kie.internal.identity.IdentityProvider identityProvider, String deploymentUnitId)
-
isDeployed
public boolean isDeployed(String deploymentUnitId)
Description copied from interface:DeploymentServicePerforms a check if given deployment is already active- Specified by:
isDeployedin interfaceDeploymentService- Returns:
- true if deployment is active, false if not
-
shutdown
public void shutdown()
-
-