Repository: camel Updated Branches: refs/heads/master 7cc63e9d4 -> 33c6f3cb0
CAMEL-7386: camel-openshift component. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/33c6f3cb Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/33c6f3cb Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/33c6f3cb Branch: refs/heads/master Commit: 33c6f3cb0efcb73c5dfa7af34ca6bd953f945c1a Parents: 7cc63e9 Author: Claus Ibsen <davscl...@apache.org> Authored: Wed Apr 23 15:24:56 2014 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Wed Apr 23 15:25:17 2014 +0200 ---------------------------------------------------------------------- .../apache/camel/component/openshift/OpenShiftConsumer.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/33c6f3cb/components/camel-openshift/src/main/java/org/apache/camel/component/openshift/OpenShiftConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-openshift/src/main/java/org/apache/camel/component/openshift/OpenShiftConsumer.java b/components/camel-openshift/src/main/java/org/apache/camel/component/openshift/OpenShiftConsumer.java index 4e8920b..5c7f6b0 100644 --- a/components/camel-openshift/src/main/java/org/apache/camel/component/openshift/OpenShiftConsumer.java +++ b/components/camel-openshift/src/main/java/org/apache/camel/component/openshift/OpenShiftConsumer.java @@ -29,11 +29,17 @@ import org.apache.camel.impl.ScheduledPollConsumer; public class OpenShiftConsumer extends ScheduledPollConsumer { + // lets by default poll every 10 sec + private static final long INITIAL_DELAY = 1 * 1000L; + private static final long DELAY = 10 * 1000L; + private final Map<ApplicationState, ApplicationState> oldState = new HashMap<ApplicationState, ApplicationState>(); private volatile boolean initialPoll; public OpenShiftConsumer(Endpoint endpoint, Processor processor) { super(endpoint, processor); + setInitialDelay(INITIAL_DELAY); + setDelay(DELAY); } @Override
