Merge pull request #2111 from arunans23/vfs

Remove obsolete implementation from VFSTransportListener
wso2 · Nov 6, 2023 · 218ed0c · 218ed0c
2 parents 5b88561 + d049957
commit 218ed0c
Showing 1 changed file with 1 addition and 16 deletions.
diff --git a/...nsports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java b/...nsports/core/vfs/src/main/java/org/apache/synapse/transport/vfs/VFSTransportListener.java
@@ -201,23 +201,8 @@ protected void scanFileOrDirectory(final PollTableEntry entry, String fileURI) {
             log.debug("Polling: " + VFSUtils.maskURLPassword(fileURI));
         }
         if (entry.isClusterAware()) {
-            boolean leader = true;
-            ClusteringAgent agent = getConfigurationContext().getAxisConfiguration().getClusteringAgent();
-            log.warn("Although proxy is cluster aware, clustering config are not present, hence running the" +
-                         " the polling task in this node");
-            if (!leader) {
-                if (log.isDebugEnabled()) {
-                    log.debug("This Member is not the leader");
-                }
-                entry.setLastPollState(PollTableEntry.NONE);
-                long now = System.currentTimeMillis();
-                entry.setLastPollTime(now);
-                entry.setNextPollTime(now + entry.getPollInterval());
-                onPollCompletion(entry);
-                return;
-            }
             if (log.isDebugEnabled()) {
-                log.debug("This Member is the leader");
+                log.debug("Cluster aware flag is enabled.");
             }
         }
         FileSystemOptions fso = null;