You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2015/04/21 14:42:12 UTC

[4/4] camel git commit: Improved doc about file readLock in clustered mode.

Improved doc about file readLock in clustered mode.


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/c6868376
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/c6868376
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/c6868376

Branch: refs/heads/master
Commit: c686837639c77545d64dd2f9f9a9ff93c6ab82c8
Parents: fcd3d3a
Author: Claus Ibsen <da...@apache.org>
Authored: Tue Apr 21 14:43:46 2015 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Tue Apr 21 14:44:50 2015 +0200

----------------------------------------------------------------------
 .../java/org/apache/camel/component/file/GenericFileEndpoint.java | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/c6868376/camel-core/src/main/java/org/apache/camel/component/file/GenericFileEndpoint.java
----------------------------------------------------------------------
diff --git a/camel-core/src/main/java/org/apache/camel/component/file/GenericFileEndpoint.java b/camel-core/src/main/java/org/apache/camel/component/file/GenericFileEndpoint.java
index cb0f963..0e7dfcb 100644
--- a/camel-core/src/main/java/org/apache/camel/component/file/GenericFileEndpoint.java
+++ b/camel-core/src/main/java/org/apache/camel/component/file/GenericFileEndpoint.java
@@ -805,6 +805,9 @@ public abstract class GenericFileEndpoint<T> extends ScheduledPollEndpoint imple
      *     a remote file system via a mount/share unless that file system supports distributed file locks.</li>
      *     <li>rename - rename is for using a try to rename the file as a test if we can get exclusive read-lock.</li>
      * </ul>
+     * Notice: The various read locks is not all suited to work in clustered mode, where concurrent consumers on different nodes is competing
+     * for the same files on a shared file system. The markerFile using a close to atomic operation to create the empty marker file,
+     * but its not guaranteed to work in a cluster. The fileLock may work better but then the file system need to support distributed file locks, and so on.
      */
     public void setReadLock(String readLock) {
         this.readLock = readLock;