Package org.operaton.bpm.engine.test.junit5.migration

Class MigrationTestExtension

java.lang.Object

org.operaton.bpm.engine.test.junit5.ProcessEngineTestExtension

org.operaton.bpm.engine.test.junit5.migration.MigrationTestExtension

All Implemented Interfaces:

org.junit.jupiter.api.extension.AfterEachCallback, org.junit.jupiter.api.extension.BeforeEachCallback, org.junit.jupiter.api.extension.Extension

public class MigrationTestExtension
extends ProcessEngineTestExtension

Author:

Thorben Lindhauer

Field Summary

Fields

Modifier and Type	Field	Description
ProcessInstanceSnapshot	snapshotAfterMigration
ProcessInstanceSnapshot	snapshotBeforeMigration

Fields inherited from class org.operaton.bpm.engine.test.junit5.ProcessEngineTestExtension

DEFAULT_BPMN_RESOURCE_NAME

Constructor Summary

Constructors

Constructor	Description
MigrationTestExtension(ProcessEngineExtension processEngineRule)

Method Summary

Modifier and Type	Method	Description
ActivityInstanceAssert.ActivityInstanceAssertThatClause	assertActivityTreeAfterMigration()
void	assertBoundaryTimerJobCreated(String activityId)
void	assertBoundaryTimerJobMigrated(String activityIdBefore, String activityIdAfter)
void	assertBoundaryTimerJobRemoved(String activityId)
void	assertEventSubProcessTimerJobCreated(String activityId)
void	assertEventSubProcessTimerJobRemoved(String activityId)
void	assertEventSubscriptionCreated(String activityId, String eventName)
void	assertEventSubscriptionMigrated(String activityIdBefore, String activityIdAfter, String eventName)
void	assertEventSubscriptionMigrated(String activityIdBefore, String eventNameBefore, String activityIdAfter, String eventNameAfter)
protected void	assertEventSubscriptionMigrated(EventSubscription eventSubscriptionBefore, String activityIdAfter, String eventName)
void	assertEventSubscriptionRemoved(String activityId, String eventName)
void	assertEventSubscriptionsMigrated(String activityIdBefore, String activityIdAfter, String eventName)
ExecutionAssert	assertExecutionTreeAfterMigration()
void	assertIntermediateTimerJobCreated(String activityId)
void	assertIntermediateTimerJobMigrated(String activityIdBefore, String activityIdAfter)
void	assertIntermediateTimerJobRemoved(String activityId)
void	assertJobCreated(String activityId, String handlerType)
void	assertJobMigrated(String activityIdBefore, String activityIdAfter, String handlerType)
void	assertJobMigrated(String activityIdBefore, String activityIdAfter, String handlerType, Date dueDateAfter)
void	assertJobMigrated(Job jobBefore, String activityIdAfter)
void	assertJobMigrated(Job jobBefore, String activityIdAfter, Date dueDateAfter)
void	assertJobRemoved(String activityId, String handlerType)
void	assertJobsCreated(String activityId, String handlerType, int countJobs)
void	assertSuperExecutionOfCaseInstance(String caseInstanceId, String expectedSuperExecutionId)
void	assertSuperExecutionOfProcessInstance(String processInstance, String expectedSuperExecutionId)
void	assertTaskListenerTimerJobCreated(String activityId)
void	assertTaskListenerTimerJobMigrated(String activityIdBefore, String activityIdAfter)
void	assertTaskListenerTimerJobMigrated(String activityIdBefore, String activityIdAfter, Date dueDateAfter)
void	assertTaskListenerTimerJobRemoved(String activityId)
void	assertTaskListenerTimerJobsCreated(String activityId, int countJobs)
void	assertTimerJob(Job job)
Job	assertTimerJobExists(ProcessInstanceSnapshot snapshot)
void	assertVariableMigratedToExecution(VariableInstance variableBefore, String executionId)
void	assertVariableMigratedToExecution(VariableInstance variableBefore, String executionId, String activityInstanceId)
ProcessInstance	createProcessInstanceAndMigrate(MigrationPlan migrationPlan)
ProcessInstance	createProcessInstanceAndMigrate(MigrationPlan migrationPlan, Map<String,Object> variables)
ActivityInstance	getSingleActivityInstance(ActivityInstance tree, String activityId)
ActivityInstance	getSingleActivityInstanceAfterMigration(String activityId)
ActivityInstance	getSingleActivityInstanceBeforeMigration(String activityId)
String	getSingleExecutionIdForActivity(ActivityInstance activityInstance, String activityId)
String	getSingleExecutionIdForActivityAfterMigration(String activityId)
String	getSingleExecutionIdForActivityBeforeMigration(String activityId)
void	migrateProcessInstance(MigrationPlan migrationPlan, ProcessInstance processInstance)
ProcessInstanceSnapshot	takeFullProcessInstanceSnapshot(ProcessInstance processInstance)
ProcessInstanceSnapshotBuilder	takeProcessInstanceSnapshot(ProcessInstance processInstance)
void	triggerTimer()

Methods inherited from class org.operaton.bpm.engine.test.junit5.ProcessEngineTestExtension

afterEach, areJobsAvailable, assertCaseEnded, assertProcessEnded, assertProcessNotEnded, assertTextPresent, assertTextPresentIgnoreCase, availableJobs, beforeEach, completeAnyTask, completeTask, correlateMessage, createCaseInstanceByKey, createCaseInstanceByKey, createCaseInstanceByKey, createCaseInstanceByKey, createDeploymentBuilder, createGrantAuthorization, defaultManualActivation, deleteAllAuthorizations, deleteAllStandaloneTasks, deleteHistoryCleanupJobs, deploy, deploy, deploy, deploy, deploy, deployAndGetDefinition, deployAndGetDefinition, deployForTenant, deployForTenant, deployForTenant, deployForTenantAndGetDefinition, deployForTenantAndGetDefinition, executeAvailableJobs, executeAvailableJobs, executeAvailableJobs, executeAvailableJobs, getDatabaseType, getInstancesForActivityId, getProcessEngine, isHistoryLevelActivity, isHistoryLevelAudit, isHistoryLevelFull, isHistoryLevelNone, sendSignal, setAnyVariable, setVariable, waitForJobExecutorToProcessAllJobs, waitForJobExecutorToProcessAllJobs

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

snapshotBeforeMigration

public ProcessInstanceSnapshot snapshotBeforeMigration

snapshotAfterMigration

public ProcessInstanceSnapshot snapshotAfterMigration

Constructor Details

MigrationTestExtension

public MigrationTestExtension(ProcessEngineExtension processEngineRule)

Method Details

getSingleExecutionIdForActivity

public String getSingleExecutionIdForActivity(ActivityInstance activityInstance,
 String activityId)

getSingleExecutionIdForActivityBeforeMigration

public String getSingleExecutionIdForActivityBeforeMigration(String activityId)

getSingleExecutionIdForActivityAfterMigration

public String getSingleExecutionIdForActivityAfterMigration(String activityId)

getSingleActivityInstance

public ActivityInstance getSingleActivityInstance(ActivityInstance tree,
 String activityId)

getSingleActivityInstanceBeforeMigration

public ActivityInstance getSingleActivityInstanceBeforeMigration(String activityId)

getSingleActivityInstanceAfterMigration

public ActivityInstance getSingleActivityInstanceAfterMigration(String activityId)

takeFullProcessInstanceSnapshot

public ProcessInstanceSnapshot takeFullProcessInstanceSnapshot(ProcessInstance processInstance)

takeProcessInstanceSnapshot

public ProcessInstanceSnapshotBuilder takeProcessInstanceSnapshot(ProcessInstance processInstance)

createProcessInstanceAndMigrate

public ProcessInstance createProcessInstanceAndMigrate(MigrationPlan migrationPlan)

createProcessInstanceAndMigrate

public ProcessInstance createProcessInstanceAndMigrate(MigrationPlan migrationPlan,
 Map<String,Object> variables)

migrateProcessInstance

public void migrateProcessInstance(MigrationPlan migrationPlan,
 ProcessInstance processInstance)

triggerTimer

public void triggerTimer()

assertExecutionTreeAfterMigration

public ExecutionAssert assertExecutionTreeAfterMigration()

assertActivityTreeAfterMigration

public ActivityInstanceAssert.ActivityInstanceAssertThatClause assertActivityTreeAfterMigration()

assertEventSubscriptionsMigrated

public void assertEventSubscriptionsMigrated(String activityIdBefore,
 String activityIdAfter,
 String eventName)

assertEventSubscriptionMigrated

protected void assertEventSubscriptionMigrated(EventSubscription eventSubscriptionBefore,
 String activityIdAfter,
 String eventName)

assertEventSubscriptionMigrated

public void assertEventSubscriptionMigrated(String activityIdBefore,
 String activityIdAfter,
 String eventName)

assertEventSubscriptionMigrated

public void assertEventSubscriptionMigrated(String activityIdBefore,
 String eventNameBefore,
 String activityIdAfter,
 String eventNameAfter)

assertEventSubscriptionRemoved

public void assertEventSubscriptionRemoved(String activityId,
 String eventName)

assertEventSubscriptionCreated

public void assertEventSubscriptionCreated(String activityId,
 String eventName)

assertTimerJob

public void assertTimerJob(Job job)

assertTimerJobExists

public Job assertTimerJobExists(ProcessInstanceSnapshot snapshot)

assertJobCreated

public void assertJobCreated(String activityId,
 String handlerType)

assertJobsCreated

public void assertJobsCreated(String activityId,
 String handlerType,
 int countJobs)

assertJobRemoved

public void assertJobRemoved(String activityId,
 String handlerType)

assertJobMigrated

public void assertJobMigrated(String activityIdBefore,
 String activityIdAfter,
 String handlerType)

assertJobMigrated

public void assertJobMigrated(String activityIdBefore,
 String activityIdAfter,
 String handlerType,
 Date dueDateAfter)

assertJobMigrated

public void assertJobMigrated(Job jobBefore,
 String activityIdAfter)

assertJobMigrated

public void assertJobMigrated(Job jobBefore,
 String activityIdAfter,
 Date dueDateAfter)

assertBoundaryTimerJobCreated

public void assertBoundaryTimerJobCreated(String activityId)

assertBoundaryTimerJobRemoved

public void assertBoundaryTimerJobRemoved(String activityId)

assertBoundaryTimerJobMigrated

public void assertBoundaryTimerJobMigrated(String activityIdBefore,
 String activityIdAfter)

assertIntermediateTimerJobCreated

public void assertIntermediateTimerJobCreated(String activityId)

assertIntermediateTimerJobRemoved

public void assertIntermediateTimerJobRemoved(String activityId)

assertIntermediateTimerJobMigrated

public void assertIntermediateTimerJobMigrated(String activityIdBefore,
 String activityIdAfter)

assertEventSubProcessTimerJobCreated

public void assertEventSubProcessTimerJobCreated(String activityId)

assertEventSubProcessTimerJobRemoved

public void assertEventSubProcessTimerJobRemoved(String activityId)

assertTaskListenerTimerJobCreated

public void assertTaskListenerTimerJobCreated(String activityId)

assertTaskListenerTimerJobsCreated

public void assertTaskListenerTimerJobsCreated(String activityId,
 int countJobs)

assertTaskListenerTimerJobRemoved

public void assertTaskListenerTimerJobRemoved(String activityId)

assertTaskListenerTimerJobMigrated

public void assertTaskListenerTimerJobMigrated(String activityIdBefore,
 String activityIdAfter)

assertTaskListenerTimerJobMigrated

public void assertTaskListenerTimerJobMigrated(String activityIdBefore,
 String activityIdAfter,
 Date dueDateAfter)

assertVariableMigratedToExecution

public void assertVariableMigratedToExecution(VariableInstance variableBefore,
 String executionId)

assertVariableMigratedToExecution

public void assertVariableMigratedToExecution(VariableInstance variableBefore,
 String executionId,
 String activityInstanceId)

assertSuperExecutionOfCaseInstance

public void assertSuperExecutionOfCaseInstance(String caseInstanceId,
 String expectedSuperExecutionId)

assertSuperExecutionOfProcessInstance

public void assertSuperExecutionOfProcessInstance(String processInstance,
 String expectedSuperExecutionId)