public class OpenShiftConsumer
extends org.apache.camel.impl.ScheduledPollConsumer
Constructor and Description |
---|
OpenShiftConsumer(org.apache.camel.Endpoint endpoint,
org.apache.camel.Processor processor) |
Modifier and Type | Method and Description |
---|---|
protected int |
doPollAll(com.openshift.client.IDomain domain) |
protected int |
doPollOnChange(com.openshift.client.IDomain domain) |
protected void |
doStart() |
OpenShiftEndpoint |
getEndpoint() |
protected int |
poll() |
afterPoll, beforePoll, doShutdown, doStop, doSuspend, getBackoffCounter, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, isGreedy, isPollAllowed, isPolling, isSchedulerStarted, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, onInit, processEmptyMessage, run, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay, startScheduler
createUoW, doneUoW, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
doResume, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public OpenShiftConsumer(org.apache.camel.Endpoint endpoint, org.apache.camel.Processor processor)
public OpenShiftEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.DefaultConsumer
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.ScheduledPollConsumer
Exception
protected int poll() throws Exception
poll
in class org.apache.camel.impl.ScheduledPollConsumer
Exception
protected int doPollAll(com.openshift.client.IDomain domain)
protected int doPollOnChange(com.openshift.client.IDomain domain)
Apache Camel