DropService { public Drop createDrop(Repository repository) { logger.debug("Create drop for repository id: {}", repository.getId()); Drop drop = new Drop(); drop.setRepository(repository); drop.setDropExporterType(repository.getDropExporterType()); drop.setName(getDropName(new Date())); return dropRepository.save(drop); }  Drop createDrop(Repository repository); @Pollable(expectedSubTaskNumber = 1, message = "Start the Drop export process") PollableFuture<Drop> startDropExportProcess(
            ExportDropConfig exportDropConfig,
            @InjectCurrentTask PollableTask currentTask); @Pollable(async = true, message = "Start importing drop", expectedSubTaskNumber = 1) PollableFuture importDrop(
            Long dropId,
            TMTextUnitVariant.Status importStatus,
            @InjectCurrentTask PollableTask currentTask); @Pollable(async = true, message = "Start canceling drop") PollableFuture<Drop> cancelDrop(Long dropId, @InjectCurrentTask PollableTask currentTask); @Transactional void completeDrop(Drop drop);  }
@Test public void testCreateDrop() throws Exception { Repository repository = repositoryService.createRepository(testIdWatcher.getEntityName("repository")); Drop createDrop = dropService.createDrop(repository); assertEquals(createDrop.getRepository().getId(), repository.getId()); assertNotNull(createDrop.getCreatedByUser()); }