svn commit: r722808 - /activemq/camel/branches/camel-1.x/camel-core/src/main/java/org/apache/camel/component/file/FileConsumer.java

[davsclaus]

Author: davsclaus
Date: Wed Dec  3 00:30:25 2008
New Revision: 722808

URL: http://svn.apache.org/viewvc?rev=722808&view=rev
Log:
CAMEL-1138: Quick fix for file consumer not freeing memory

Modified:
    
activemq/camel/branches/camel-1.x/camel-core/src/main/java/org/apache/camel/component/file/FileConsumer.java

Modified: 
activemq/camel/branches/camel-1.x/camel-core/src/main/java/org/apache/camel/component/file/FileConsumer.java
URL: 
http://svn.apache.org/viewvc/activemq/camel/branches/camel-1.x/camel-core/src/main/java/org/apache/camel/component/file/FileConsumer.java?rev=722808&r1=722807&r2=722808&view=diff
==============================================================================
--- 
activemq/camel/branches/camel-1.x/camel-core/src/main/java/org/apache/camel/component/file/FileConsumer.java
 (original)
+++ 
activemq/camel/branches/camel-1.x/camel-core/src/main/java/org/apache/camel/component/file/FileConsumer.java
 Wed Dec  3 00:30:25 2008
@@ -27,6 +27,7 @@
 import org.apache.camel.Processor;
 import org.apache.camel.impl.ScheduledPollConsumer;
 import org.apache.camel.processor.DeadLetterChannel;
+import org.apache.camel.util.LRUCache;
 import org.apache.camel.util.ObjectHelper;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -41,8 +42,8 @@
 
     private FileEndpoint endpoint;
     private ConcurrentHashMap<File, File> filesBeingProcessed = new 
ConcurrentHashMap<File, File>();
-    private ConcurrentHashMap<File, Long> fileSizes = new 
ConcurrentHashMap<File, Long>();
-    private ConcurrentHashMap<File, Long> noopMap = new 
ConcurrentHashMap<File, Long>();
+    private ConcurrentHashMap<File, Long> fileSizes = new 
ConcurrentHashMap<File, Long>(new LRUCache(1000));
+    private ConcurrentHashMap<File, Long> noopMap = new 
ConcurrentHashMap<File, Long>(new LRUCache(1000));
 
     // the options below is @deprecated and will be removed in Camel 2.0
     private long lastPollTime;