diff --git a/camel-filewatcher/src/main/java/nl/vpro/camel/FileWatcherConsumer.java b/camel-filewatcher/src/main/java/nl/vpro/camel/FileWatcherConsumer.java index 64f804f..cc29d95 100644 --- a/camel-filewatcher/src/main/java/nl/vpro/camel/FileWatcherConsumer.java +++ b/camel-filewatcher/src/main/java/nl/vpro/camel/FileWatcherConsumer.java @@ -18,10 +18,10 @@ import java.io.File; import java.net.URI; + import org.apache.camel.Exchange; import org.apache.camel.Processor; -import org.apache.camel.support.DefaultEndpoint; -import org.apache.camel.support.DefaultScheduledPollConsumer; +import org.apache.camel.support.*; import org.apache.camel.util.FileUtil; public class FileWatcherConsumer extends DefaultScheduledPollConsumer { @@ -37,6 +37,7 @@ public enum Event { FileWatcherConsumer(DefaultEndpoint endpoint, Processor processor) { super(endpoint, processor); + setPollStrategy(new DefaultPollingConsumerPollStrategy()); } @Override diff --git a/camel-filewatcher/src/test/resources/log4j2.properties b/camel-filewatcher/src/test/resources/log4j2.properties deleted file mode 100644 index 79b8e18..0000000 --- a/camel-filewatcher/src/test/resources/log4j2.properties +++ /dev/null @@ -1,6 +0,0 @@ -appender.out.type = Console -appender.out.name = out -appender.out.layout.type = PatternLayout -appender.out.layout.pattern=%-30.30c{1} %-5p %m%n -rootLogger.level = INFO -rootLogger.appenderRef.out.ref = out diff --git a/camel-filewatcher/src/test/resources/log4j2.xml b/camel-filewatcher/src/test/resources/log4j2.xml new file mode 100644 index 0000000..8667868 --- /dev/null +++ b/camel-filewatcher/src/test/resources/log4j2.xml @@ -0,0 +1,15 @@ + + + + + + + + + + + + + + + diff --git a/pom.xml b/pom.xml index a803373..80098e1 100644 --- a/pom.xml +++ b/pom.xml @@ -223,7 +223,7 @@ org.apache.logging.log4j - log4j-slf4j-impl + log4j-slf4j2-impl test