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 2011/06/28 14:40:16 UTC
svn commit: r1140572 - in
/camel/trunk/camel-core/src/main/java/org/apache/camel:
PollingConsumerPollingStrategy.java impl/EventDrivenPollingConsumer.java
impl/ScheduledPollConsumer.java
Author: davsclaus
Date: Tue Jun 28 12:40:15 2011
New Revision: 1140572
URL: http://svn.apache.org/viewvc?rev=1140572&view=rev
Log:
CAMEL-3655: Polished a bit. Added more javadoc and renamed a method to better reflect what it does
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/PollingConsumerPollingStrategy.java
camel/trunk/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java
camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ScheduledPollConsumer.java
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/PollingConsumerPollingStrategy.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/PollingConsumerPollingStrategy.java?rev=1140572&r1=1140571&r2=1140572&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/PollingConsumerPollingStrategy.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/PollingConsumerPollingStrategy.java Tue Jun 28 12:40:15 2011
@@ -17,16 +17,21 @@
package org.apache.camel;
/**
- * Strategy that allows consumers to influence the {@link PollingConsumer}.
+ * Strategy that allows {@link Consumer}s to influence the {@link PollingConsumer}.
+ * <p/>
+ * For example this is used by schedule based consumers to be able to suspend/resume
+ * upon polling using a {@link PollingConsumer}.
+ *
+ * @see org.apache.camel.impl.EventDrivenPollingConsumer
*/
public interface PollingConsumerPollingStrategy {
/**
- * Callback invoked when the consumer is started.
+ * Callback invoked when the consumer is initialized such as when the {@link PollingConsumer} starts.
*
- * @throws Exception can be thrown if error starting.
+ * @throws Exception can be thrown if error initializing.
*/
- void onStartup() throws Exception;
+ void onInit() throws Exception;
/**
* Callback invoked before the poll.
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java?rev=1140572&r1=1140571&r2=1140572&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java Tue Jun 28 12:40:15 2011
@@ -144,7 +144,7 @@ public class EventDrivenPollingConsumer
// if the consumer has a polling strategy then invoke that
if (consumer instanceof PollingConsumerPollingStrategy) {
PollingConsumerPollingStrategy strategy = (PollingConsumerPollingStrategy) consumer;
- strategy.onStartup();
+ strategy.onInit();
} else {
// for regular consumers start it
ServiceHelper.startService(consumer);
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ScheduledPollConsumer.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ScheduledPollConsumer.java?rev=1140572&r1=1140571&r2=1140572&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ScheduledPollConsumer.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ScheduledPollConsumer.java Tue Jun 28 12:40:15 2011
@@ -274,7 +274,7 @@ public abstract class ScheduledPollConsu
}
@Override
- public void onStartup() throws Exception {
+ public void onInit() throws Exception {
// start our self
ServiceHelper.startService(this);
}