You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2013/08/31 12:56:35 UTC
[8/9] git commit: Polished
Polished
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/71dd1a63
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/71dd1a63
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/71dd1a63
Branch: refs/heads/master
Commit: 71dd1a63297fc813ac5d518a006792e497ff8915
Parents: 4f91442
Author: Claus Ibsen <da...@apache.org>
Authored: Sat Aug 31 12:55:45 2013 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Sat Aug 31 12:55:45 2013 +0200
----------------------------------------------------------------------
.../org/apache/camel/component/seda/SedaComponent.java | 12 ++++--------
1 file changed, 4 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/71dd1a63/camel-core/src/main/java/org/apache/camel/component/seda/SedaComponent.java
----------------------------------------------------------------------
diff --git a/camel-core/src/main/java/org/apache/camel/component/seda/SedaComponent.java b/camel-core/src/main/java/org/apache/camel/component/seda/SedaComponent.java
index 74e6278..ce08856d 100644
--- a/camel-core/src/main/java/org/apache/camel/component/seda/SedaComponent.java
+++ b/camel-core/src/main/java/org/apache/camel/component/seda/SedaComponent.java
@@ -39,6 +39,7 @@ public class SedaComponent extends UriEndpointComponent {
protected int defaultConcurrentConsumers = 1;
private final Map<String, QueueReference> queues = new HashMap<String, QueueReference>();
private BlockingQueueFactory<Exchange> defaultQueueFactory = new LinkedBlockingQueueFactory<Exchange>();
+
public SedaComponent() {
super(SedaEndpoint.class);
}
@@ -157,16 +158,12 @@ public class SedaComponent extends UriEndpointComponent {
+ maxConcurrentConsumers + " was " + consumers);
}
// Resolve queue reference
- BlockingQueue<Exchange> queue = resolveAndRemoveReferenceParameter(parameters, "queue",
- BlockingQueue.class);
+ BlockingQueue<Exchange> queue = resolveAndRemoveReferenceParameter(parameters, "queue", BlockingQueue.class);
SedaEndpoint answer;
// Resolve queue factory when no queue specified
if (queue == null) {
- BlockingQueueFactory<Exchange> queueFactory = resolveAndRemoveReferenceParameter(parameters,
- "queueFactory",
- BlockingQueueFactory.class);
- // defer creating queue till endpoint is started, so we pass the
- // queue factory
+ BlockingQueueFactory<Exchange> queueFactory = resolveAndRemoveReferenceParameter(parameters, "queueFactory", BlockingQueueFactory.class);
+ // defer creating queue till endpoint is started, so we pass the queue factory
answer = new SedaEndpoint(uri, this, queueFactory, consumers);
} else {
answer = new SedaEndpoint(uri, this, queue, consumers);
@@ -205,7 +202,6 @@ public class SedaComponent extends UriEndpointComponent {
// reference no longer needed so remove from queues
getQueues().remove(key);
}
-
}
}