}
@Override
public void run() {
- TransactionAccumulator accumulator = new TransactionAccumulator(accFilter);
+ TransactionAccumulator accumulator = new TransactionAccumulator(accFilter, accFilter);
for (TransactionWithAccounts tr : list) {
if (isInterrupted()) {