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 2012/02/24 15:36:51 UTC
svn commit: r1293271 - in /camel/branches/camel-2.9.x: ./
camel-core/src/main/java/org/apache/camel/component/timer/
camel-core/src/test/java/org/apache/camel/component/timer/
Author: davsclaus
Date: Fri Feb 24 14:36:50 2012
New Revision: 1293271
URL: http://svn.apache.org/viewvc?rev=1293271&view=rev
Log:
CAMEL-5038: Timer endpoint should support multiple consumers.
Added:
camel/branches/camel-2.9.x/camel-core/src/test/java/org/apache/camel/component/timer/TimerMultipleConsumerStopRouteTest.java
- copied unchanged from r1293268, camel/trunk/camel-core/src/test/java/org/apache/camel/component/timer/TimerMultipleConsumerStopRouteTest.java
camel/branches/camel-2.9.x/camel-core/src/test/java/org/apache/camel/component/timer/TimerMultipleConsumerTest.java
- copied unchanged from r1293268, camel/trunk/camel-core/src/test/java/org/apache/camel/component/timer/TimerMultipleConsumerTest.java
Modified:
camel/branches/camel-2.9.x/ (props changed)
camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/component/timer/TimerEndpoint.java
Propchange: camel/branches/camel-2.9.x/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Fri Feb 24 14:36:50 2012
@@ -1 +1 @@
-/camel/trunk:1243046,1243057,1243234,1244518,1244644,1244859,1244861,1244864,1244870,1244872,1245021,1291555,1291727,1291848,1291864,1292114,1292384,1292725,1292760,1292767,1293079
+/camel/trunk:1243046,1243057,1243234,1244518,1244644,1244859,1244861,1244864,1244870,1244872,1245021,1291555,1291727,1291848,1291864,1292114,1292384,1292725,1292760,1292767,1293079,1293268
Propchange: camel/branches/camel-2.9.x/
------------------------------------------------------------------------------
Binary property 'svnmerge-integrated' - no diff available.
Modified: camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/component/timer/TimerEndpoint.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/component/timer/TimerEndpoint.java?rev=1293271&r1=1293270&r2=1293271&view=diff
==============================================================================
--- camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/component/timer/TimerEndpoint.java (original)
+++ camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/component/timer/TimerEndpoint.java Fri Feb 24 14:36:50 2012
@@ -21,6 +21,7 @@ import java.util.Timer;
import org.apache.camel.Component;
import org.apache.camel.Consumer;
+import org.apache.camel.MultipleConsumersSupport;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
import org.apache.camel.RuntimeCamelException;
@@ -34,7 +35,7 @@ import org.apache.camel.impl.DefaultEndp
* @version
*/
@ManagedResource(description = "Managed TimerEndpoint")
-public class TimerEndpoint extends DefaultEndpoint {
+public class TimerEndpoint extends DefaultEndpoint implements MultipleConsumersSupport {
private String timerName;
private Date time;
private long period = 1000;
@@ -72,6 +73,11 @@ public class TimerEndpoint extends Defau
super.doStop();
}
+ @ManagedAttribute
+ public boolean isMultipleConsumersSupported() {
+ return true;
+ }
+
@ManagedAttribute(description = "Timer Name")
public String getTimerName() {
if (timerName == null) {