Fixed AbstractFlowFileQueue logging
This closes
@@ -190,7 +190,6 @@ public abstract class AbstractFlowFileQueue implements FlowFileQueue {
@Override
public void run() {
int position = 0;
- int resultCount = 0;
final List<FlowFileSummary> summaries = new ArrayList<>();
// Create an ArrayList that contains all of the contents of the active queue.
@@ -216,7 +215,7 @@ public abstract class AbstractFlowFileQueue implements FlowFileQueue {
}
}
- logger.debug("{} Finished listing FlowFiles for active queue with a total of {} results", this, resultCount);
+ logger.debug("{} Finished listing FlowFiles for active queue with a total of {} results out of {} FlowFiles", this, summaries.size(), allFlowFiles.size());
listRequest.setFlowFileSummaries(summaries);
listRequest.setState(ListFlowFileState.COMPLETE);
}
