Author: dkulp
Date: Thu Dec 22 16:08:06 2011
New Revision: 1222307
URL: http://svn.apache.org/viewvc?rev=1222307&view=rev
Log:
Merged revisions 1209056 via svnmerge from
https://svn.apache.org/repos/asf/camel/trunk
........
r1209056 | ningjiang | 2011-12-01 07:46:36 -0500 (Thu, 01 Dec 2011) | 1 line
CAMEL-4729 Supports to set the default value of VMComponent
........
Modified:
camel/branches/camel-2.8.x/ (props changed)
camel/branches/camel-2.8.x/camel-core/src/main/java/org/apache/camel/component/vm/VmComponent.java
Propchange: camel/branches/camel-2.8.x/
------------------------------------------------------------------------------
Binary property 'svnmerge-integrated' - no diff available.
Modified:
camel/branches/camel-2.8.x/camel-core/src/main/java/org/apache/camel/component/vm/VmComponent.java
URL:
http://svn.apache.org/viewvc/camel/branches/camel-2.8.x/camel-core/src/main/java/org/apache/camel/component/vm/VmComponent.java?rev=1222307&r1=1222306&r2=1222307&view=diff
==============================================================================
---
camel/branches/camel-2.8.x/camel-core/src/main/java/org/apache/camel/component/vm/VmComponent.java
(original)
+++
camel/branches/camel-2.8.x/camel-core/src/main/java/org/apache/camel/component/vm/VmComponent.java
Thu Dec 22 16:08:06 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);