SchedulerMessageReceiverImpl extends BaseMessageReceiverImpl<SchedulerItemList> { @Override protected void execute(SchedulerItemList messageContent) { for (SchedulerItem item : messageContent.getItems()) { executeSingle(messageContent.getId(), item); } } SchedulerMessageReceiverImpl();   }
@Test public void testUpdateCreator() throws Exception { DublinCoreCatalog catalog = DublinCores.read(getClass().getResourceAsStream("/dublincore.xml")); SchedulerItemList schedulerItem = new SchedulerItemList("uuid", SchedulerItem.updateCatalog(catalog)); scheduler.execute(schedulerItem); Event event = index.getEventResult(); assertNotNull(event); assertEquals("Current user is expected to be creator as no other creator has been set explicitly", "Creator", event.getCreator()); event.setCreator("Hans"); index.setInitialEvent(event); scheduler.execute(schedulerItem); event = index.getEventResult(); assertNotNull(event); assertEquals("Creator has been updated", "Hans", event.getCreator()); }