diff --git a/src/main/java/nl/knaw/dans/dvingest/DdDataverseIngestApplication.java b/src/main/java/nl/knaw/dans/dvingest/DdDataverseIngestApplication.java index 928702a..4e32127 100644 --- a/src/main/java/nl/knaw/dans/dvingest/DdDataverseIngestApplication.java +++ b/src/main/java/nl/knaw/dans/dvingest/DdDataverseIngestApplication.java @@ -118,7 +118,7 @@ public void run(final DdDataverseIngestConfiguration configuration, final Enviro * Auto ingest area */ var autoIngestConfig = configuration.getIngest().getAutoIngest(); - var inboxTaskFactory = new InboxTaskFactoryImpl(dataverseIngestDepositFactory, depositTaskFactoryImport); + var inboxTaskFactory = new InboxTaskFactoryImpl(dataverseIngestDepositFactory, depositTaskFactoryImport, autoIngestConfig.getOutbox()); var inbox = Inbox.builder().inbox(autoIngestConfig.getInbox()).taskFactory(inboxTaskFactory).build(); var autoIngestArea = new AutoIngestArea(inbox, autoIngestConfig.getOutbox()); diff --git a/src/main/java/nl/knaw/dans/dvingest/InboxTaskFactoryImpl.java b/src/main/java/nl/knaw/dans/dvingest/InboxTaskFactoryImpl.java index 924740c..8644f59 100644 --- a/src/main/java/nl/knaw/dans/dvingest/InboxTaskFactoryImpl.java +++ b/src/main/java/nl/knaw/dans/dvingest/InboxTaskFactoryImpl.java @@ -26,10 +26,11 @@ public class InboxTaskFactoryImpl implements InboxTaskFactory { private final DataverseIngestDepositFactory dataverseIngestDepositFactory; private final DepositTaskFactory depositTaskFactory; + private final Path outputDir; @Override public Runnable createInboxTask(Path path) { var dataVerseIngestDeposit = dataverseIngestDepositFactory.createDataverseIngestDeposit(path); - return depositTaskFactory.createDepositTask(dataVerseIngestDeposit, path, false); + return depositTaskFactory.createDepositTask(dataVerseIngestDeposit, outputDir, false); } }