HistoricActivityInstanceQuery query = historyService.createHistoricActivityInstanceQuery();
query.activityId("message");
assertEquals(1, query.count());
assertNotNull(query.singleResult().getEndTime());
assertEquals("boundaryMessage", query.singleResult().getActivityType());
Task task = taskService.createTaskQuery().singleResult();
taskService.complete(task.getId());
assertProcessEnded(pi.getId());