svn commit: r1209056 - /camel/trunk/camel-core/src/main/java/org/apache/camel/component/vm/VmComponent.java

[ningjiang]

Author: ningjiang
Date: Thu Dec  1 12:46:36 2011
New Revision: 1209056

URL: http://svn.apache.org/viewvc?rev=1209056&view=rev
Log:
CAMEL-4729 Supports to set the default value of VMComponent

Modified:
    
camel/trunk/camel-core/src/main/java/org/apache/camel/component/vm/VmComponent.java

Modified: 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/vm/VmComponent.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/vm/VmComponent.java?rev=1209056&r1=1209055&r2=1209056&view=diff
==============================================================================
--- 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/vm/VmComponent.java
 (original)
+++ 
camel/trunk/camel-core/src/main/java/org/apache/camel/component/vm/VmComponent.java
 Thu Dec  1 12:46:36 2011
@@ -51,7 +51,11 @@ public class VmComponent extends SedaCom
         if (size != null && size > 0) {
             queue = new LinkedBlockingQueue<Exchange>(size);
         } else {
-            queue = new LinkedBlockingQueue<Exchange>();
+            if (getQueueSize() > 0) {
+                queue = new LinkedBlockingQueue<Exchange>(getQueueSize());
+            } else {
+                queue = new LinkedBlockingQueue<Exchange>();
+            }
         }
 
         QUEUES.put(key, queue);