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. */