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:36 UTC
[9/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/d8a89413
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/d8a89413
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/d8a89413
Branch: refs/heads/camel-2.12.x
Commit: d8a89413ba4d25d90c7f2acd870c34bb56fd6f0b
Parents: d398b87
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:56:07 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/d8a89413/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);
}
-
}
}