Asynchronous User Task and Mocks

jwglista — Wed, 07 Sep 2016 12:25:41 GMT

Hello,I've had success using the MockExpressionManager to mock delegate methods for Service Tasks, as well as task listeners. I have a user task that is asynchronous, and I am attempting to mock a listener method on this user task for the create event. From my understanding, this requires the use

Re: Asynchronous User Task and Mocks

jwglista — Wed, 07 Sep 2016 17:14:32 GMT

Ok I'll give everyone a clue. It looks like the org.activiti.engine.test.mock.Mocks class is using ThreadLocal to store the Map of mocks. This will not work with async user tasks, since the process for those would be starting in a separate thread. Not sure if this will require a change in the Activiti code going forward, or if there is a way I can get around this.

<code>
public class Mocks {

private static ThreadLocal<Map<String, Object>> mockContainer = new ThreadLocal<Map<String, Object>>();

private static Map<String, Object> getMocks() {
 Map<String, Object> mocks = mockContainer.get();
 if (mocks == null) {
 mocks = new HashMap<String, Object>();
 Mocks.mockContainer.set(mocks);
 }
 return mocks;
}
</code>

Re: Asynchronous User Task and Mocks

trademak — Thu, 08 Sep 2016 07:13:24 GMT

The mock implementation isn't yet suitable for asynchronous service tasks. So that will need some changes to the mock classes.

Best regards,

Re: Asynchronous User Task and Mocks

jwglista — Thu, 08 Sep 2016 11:39:08 GMT

Thanks, Tijs. I ended up just creating a few classes to override org.activiti.engine.test.mock.Mocks so that it is not using a ThreadLocal object. This made the mocks global to the JVM through a static instance of a map. Not the most elegant solution, but it has worked perfectly.

Created the class MocksGlobal: 
<code>
public class MocksGlobal extends Mocks {

private static Map<String, Object> mockContainer = new HashMap<String, Object>();

@SuppressWarnings("unused")
private static Map<String, Object> getMocks() {
Map<String, Object> mocks = mockContainer;
if (mocks == null) {
 mockContainer = new HashMap<String, Object>();
}
return mocks;
}

/**
* This method lets you register a mock object. Make sure to register the
* {@link MockExpressionManager} with your process engine configuration.
*
* @param key
* the key under which the mock object will be registered
* @param value
* the mock object
*/
public static void register(String key, Object value) {
getMocks().put(key, value);
}

/**
* This method returns the mock object registered under the provided key or
* null if there is no object for the provided key.
*
* @param key
* the key of the requested object
* @return the mock object registered under the provided key or null if
* there is no object for the provided key
*/
public static Object get(Object key) {
return getMocks().get(key);
}

/**
* This method resets the internal map of mock objects.
*/
public static void reset() {
if (getMocks() != null) {
 getMocks().clear();
}
}
}
</code>

Created a new class, MockGlobalExpressionManager. This uses another new class, MockElGlobalResolver which is shown further down:

<code>
public class MockGlobalExpressionManager extends ExpressionManager {
 @Override
 protected ELResolver createElResolver(VariableScope variableScope) {
 CompositeELResolver compositeElResolver = new CompositeELResolver();
 compositeElResolver.add(new VariableScopeElResolver(variableScope));
 compositeElResolver.add(new MockElGlobalResolver());
 compositeElResolver.add(new ArrayELResolver());
 compositeElResolver.add(new ListELResolver());
 compositeElResolver.add(new MapELResolver());
 compositeElResolver.add(new BeanELResolver());
 return compositeElResolver;
 }
}
</code>

The MockElGlobalResolver class that uses the new MocksGlobal class to resolve mocks:

<code>
public class MockElGlobalResolver extends MockElResolver {
 @Override
 public Object getValue(ELContext context, Object base, Object property) {
 Object bean = MocksGlobal.get(property);
 if (bean != null) {
 context.setPropertyResolved(true);
 }
 return bean;
 }
}
</code>

Finally, in our unit test class, we now register MockGlobalExpressionManager instead of the Activiti MockExpressionManager:

<code>
@Before
public void setup() throws Exception {
MockitoAnnotations.initMocks(this);
SpringProcessEngineConfiguration configuration = (SpringProcessEngineConfiguration) processEngine.getProcessEngineConfiguration();
configuration.setExpressionManager(new MockGlobalExpressionManager());
}
</code>

Then in our test, we use the MocksGlobal class to register the mocks:

<code>
@Test
public void testWithMock() throws Exception {
System.out.println("================= testWithMock() start =================");
MocksGlobal.register("testMockDelegate", testMockDelegateMock);
MocksGlobal.register("testMockListener", testMockListenerMock);

when(testMockDelegateMock.execute((DelegateExecution) anyObject())).thenReturn("mock execute() was used");
ProcessInstance pi = runtimeService.startProcessInstanceByKey("testMockProcess");
assertNotNull(pi);

JobTestHelper.waitForJobExecutorToProcessAllJobs(processEngine.getProcessEngineConfiguration(), managementService, 180000L, 100L);

verify(testMockDelegateMock, times(1)).execute((DelegateExecution) anyObject());
verify(testMockListenerMock, times(1)).execute((ActivityExecution) anyObject());
verify(testMockListenerMock, times(1)).notify((DelegateTask) anyObject());
verifyNoMoreInteractions(testMockDelegateMock);
verifyNoMoreInteractions(testMockListenerMock);
System.out.println("================= testWithMock() end ================= \n");
}
</code>

topic Asynchronous User Task and Mocks in Alfresco Archive

Asynchronous User Task and Mocks

Re: Asynchronous User Task and Mocks

Re: Asynchronous User Task and Mocks

Re: Asynchronous User Task and Mocks