svn commit: r765743 - /camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java

[wt...@apache.org]

Author: wtam
Date: Thu Apr 16 20:16:04 2009
New Revision: 765743

URL: http://svn.apache.org/viewvc?rev=765743&view=rev
Log:
[CAMEL-1510] removed getCollection() and reduced method scope to prevent collection from modified outside SenderThread

Modified:
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java?rev=765743&r1=765742&r2=765743&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/BatchProcessor.java Thu Apr 16 20:16:04 2009
@@ -134,7 +134,7 @@
      * A strategy method to decide if the "in" batch is completed. That is, whether the resulting exchanges in
      * the in queue should be drained to the "out" collection.
      */
-    protected boolean isInBatchCompleted(int num) {
+    private boolean isInBatchCompleted(int num) {
         return num >= batchSize;
     }
 
@@ -142,7 +142,7 @@
      * A strategy method to decide if the "out" batch is completed. That is, whether the resulting exchange in
      * the out collection should be sent.
      */
-    protected boolean isOutBatchCompleted() {
+    private boolean isOutBatchCompleted() {
         if (outBatchSize == 0) {
             // out batch is disabled, so go ahead and send.
             return true;
@@ -169,10 +169,6 @@
         collection.clear();
     }
 
-    protected Collection<Exchange> getCollection() {
-        return collection;
-    }
-
     /**
      * Enqueues an exchange for later batch processing.
      */