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 2015/03/06 09:34:18 UTC
camel git commit: CAMEL-8368: Adding new scheduler component
Repository: camel
Updated Branches:
refs/heads/master e9d0cf4dc -> 5cddef75f
CAMEL-8368: Adding new scheduler component
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/5cddef75
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/5cddef75
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/5cddef75
Branch: refs/heads/master
Commit: 5cddef75fe8b555c4eeb013ce8448ee7e9c3da39
Parents: e9d0cf4
Author: Claus Ibsen <da...@apache.org>
Authored: Fri Mar 6 09:31:46 2015 +0100
Committer: Claus Ibsen <da...@apache.org>
Committed: Fri Mar 6 09:35:41 2015 +0100
----------------------------------------------------------------------
.../camel/component/scheduler/SchedulerComponent.java | 5 +++++
.../camel/component/scheduler/SchedulerEndpoint.java | 10 +++++++++-
2 files changed, 14 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/5cddef75/camel-core/src/main/java/org/apache/camel/component/scheduler/SchedulerComponent.java
----------------------------------------------------------------------
diff --git a/camel-core/src/main/java/org/apache/camel/component/scheduler/SchedulerComponent.java b/camel-core/src/main/java/org/apache/camel/component/scheduler/SchedulerComponent.java
index ea55880..c88594a 100644
--- a/camel-core/src/main/java/org/apache/camel/component/scheduler/SchedulerComponent.java
+++ b/camel-core/src/main/java/org/apache/camel/component/scheduler/SchedulerComponent.java
@@ -48,6 +48,11 @@ public class SchedulerComponent extends UriEndpointComponent {
return concurrentTasks;
}
+ /**
+ * Number of threads used by the scheduling thread pool.
+ * <p/>
+ * Is by default using a single thread
+ */
public void setConcurrentTasks(int concurrentTasks) {
this.concurrentTasks = concurrentTasks;
}
http://git-wip-us.apache.org/repos/asf/camel/blob/5cddef75/camel-core/src/main/java/org/apache/camel/component/scheduler/SchedulerEndpoint.java
----------------------------------------------------------------------
diff --git a/camel-core/src/main/java/org/apache/camel/component/scheduler/SchedulerEndpoint.java b/camel-core/src/main/java/org/apache/camel/component/scheduler/SchedulerEndpoint.java
index c39a53f..74b9bf5 100644
--- a/camel-core/src/main/java/org/apache/camel/component/scheduler/SchedulerEndpoint.java
+++ b/camel-core/src/main/java/org/apache/camel/component/scheduler/SchedulerEndpoint.java
@@ -32,7 +32,7 @@ public class SchedulerEndpoint extends ScheduledPollEndpoint {
@UriPath @Metadata(required = "true")
private String name;
- @UriParam
+ @UriParam(defaultValue = "1")
private int concurrentTasks = 1;
public SchedulerEndpoint(String uri, SchedulerComponent component, String remaining) {
@@ -66,6 +66,9 @@ public class SchedulerEndpoint extends ScheduledPollEndpoint {
return name;
}
+ /**
+ * The name of the scheduler
+ */
public void setName(String name) {
this.name = name;
}
@@ -74,6 +77,11 @@ public class SchedulerEndpoint extends ScheduledPollEndpoint {
return concurrentTasks;
}
+ /**
+ * Number of threads used by the scheduling thread pool.
+ * <p/>
+ * Is by default using a single thread
+ */
public void setConcurrentTasks(int concurrentTasks) {
this.concurrentTasks = concurrentTasks;
}