Updated Branches: refs/heads/camel-2.11.x 6cef9dad0 -> ba11b38fb
CAMEL-6551 RemoteFileConsumer just writing the warning message at the first time. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/ba11b38f Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/ba11b38f Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/ba11b38f Branch: refs/heads/camel-2.11.x Commit: ba11b38fb61132fe462bb0bb3be826559a9c4c43 Parents: 6cef9da Author: Willem Jiang <ningji...@apache.org> Authored: Tue Jul 16 10:35:24 2013 +0800 Committer: Willem Jiang <ningji...@apache.org> Committed: Tue Jul 16 10:48:55 2013 +0800 ---------------------------------------------------------------------- .../camel/component/file/remote/RemoteFileConsumer.java | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/ba11b38f/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/RemoteFileConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/RemoteFileConsumer.java b/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/RemoteFileConsumer.java index e347c7d..8bf4da2 100644 --- a/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/RemoteFileConsumer.java +++ b/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/RemoteFileConsumer.java @@ -28,6 +28,7 @@ import org.apache.camel.component.file.GenericFileOperationFailedException; */ public abstract class RemoteFileConsumer<T> extends GenericFileConsumer<T> { protected boolean loggedIn; + protected boolean loggedInWarning; public RemoteFileConsumer(RemoteFileEndpoint<T> endpoint, Processor processor, RemoteFileOperations<T> operations) { super(endpoint, processor, operations); @@ -66,10 +67,16 @@ public abstract class RemoteFileConsumer<T> extends GenericFileConsumer<T> { if (!loggedIn) { String message = "Cannot connect/login to: " + remoteServer() + ". Will skip this poll."; - log.warn(message); + if (!loggedInWarning) { + log.warn(message); + loggedInWarning = true; + } return false; + } else { + // need to log the failed login again + loggedInWarning = false; } - + return true; }
