NIFI-2574 fixed queue swap threshold setting

This commit is contained in:
joewitt 2016-08-17 09:05:36 -07:00
parent d9633757a6
commit 7c99b5e638
1 changed files with 1 additions and 0 deletions

View File

@ -915,6 +915,7 @@ public class FlowController implements EventAccess, ControllerServiceProvider, R
.source(requireNonNull(source)) .source(requireNonNull(source))
.destination(destination) .destination(destination)
.swapManager(swapManager) .swapManager(swapManager)
.queueSwapThreshold(nifiProperties.getQueueSwapThreshold())
.eventReporter(eventReporter) .eventReporter(eventReporter)
.resourceClaimManager(resourceClaimManager) .resourceClaimManager(resourceClaimManager)
.flowFileRepository(flowFileRepository) .flowFileRepository(flowFileRepository)