import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Service;
+import java.util.ArrayList;
import java.util.Date;
import java.util.List;
private int processCount = 0;
+ private List<String> paths = new ArrayList<>( );
+
@Override
public void beginScan( ManagedRepository repository, Date whenGathered )
throws ConsumerException
throws ConsumerException
{
logger.info( "processFile: {}", path );
+ paths.add( path );
processCount++;
}
{
this.id = id;
}
+
+ public List<String> getPaths()
+ {
+ return paths;
+ }
}
assertNotNull( "Stats should not be null.", stats );
assertMinimumHits( "Stats.totalFileCount", 17, stats.getTotalFileCount() );
assertMinimumHits( "Processed Count", 17, consumer.getProcessCount() );
- assertEquals( "Processed Count (of invalid items)", 6, badconsumer.getProcessCount() );
+ assertEquals( "Processed Count (of invalid items):" + badconsumer.getPaths(), 6, badconsumer.getProcessCount() );
}
@Test