import org.codehaus.plexus.logging.Logger;
import org.codehaus.plexus.util.DirectoryWalkListener;
import org.codehaus.plexus.util.SelectorUtils;
+import org.codehaus.plexus.util.StringUtils;
import java.io.File;
import java.util.Iterator;
if ( !consumer.init( this.repository ) )
{
- throw new IllegalStateException( "Consumer [" + consumer.getName()
- + "] is reporting that it is incompatible with the [" + repository.getId() + "] repository." );
+ throw new IllegalStateException( "Consumer [" + consumer.getName() +
+ "] is reporting that it is incompatible with the [" + repository.getId() + "] repository." );
}
}
{
Consumer consumer = (Consumer) itConsumers.next();
- if ( wantsFile( consumer, basefile.getRelativePath() ) )
+ if ( wantsFile( consumer, StringUtils.replace( basefile.getRelativePath(), "\\", "/" ) ) )
{
try
{
/* Intentionally Catch all exceptions.
* So that the discoverer processing can continue.
*/
- getLogger().error(
- "Consumer [" + consumer.getName() + "] had an error when processing file ["
- + basefile.getAbsolutePath() + "]: " + e.getMessage(), e );
+ getLogger().error( "Consumer [" + consumer.getName() + "] had an error when processing file [" +
+ basefile.getAbsolutePath() + "]: " + e.getMessage(), e );
}
}
else
{
getLogger().debug(
- "Skipping consumer " + consumer.getName() + " for file "
- + basefile.getRelativePath() );
+ "Skipping consumer " + consumer.getName() + " for file " + basefile.getRelativePath() );
}
}
}
// Not included, and Not excluded? Default to EXCLUDE.
return false;
}
-
+
public long getOnlyModifiedAfterTimestamp()
{
return onlyModifiedAfterTimestamp;