@UriEndpoint(scheme="scheduler",
title="Scheduler",
syntax="scheduler:name",
consumerOnly=true,
consumerClass=SchedulerConsumer.class,
label="core,scheduling")
public class SchedulerEndpoint
extends ScheduledPollEndpoint
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending| Constructor and Description |
|---|
SchedulerEndpoint(String uri,
SchedulerComponent component,
String remaining) |
| Modifier and Type | Method and Description |
|---|---|
Consumer |
createConsumer(Processor processor)
Creates a new Event
Driven Consumer which consumes messages from the endpoint using the
given processor
|
Producer |
createProducer()
Creates a new producer which is used send messages into the endpoint
|
SchedulerComponent |
getComponent()
Returns the component that created this endpoint.
|
int |
getConcurrentTasks() |
String |
getName() |
boolean |
isSingleton()
Whether this class supports being singleton or not.
|
void |
onConsumerStart(SchedulerConsumer consumer) |
void |
onConsumerStop(SchedulerConsumer consumer) |
void |
setConcurrentTasks(int concurrentTasks)
Number of threads used by the scheduling thread pool.
|
void |
setName(String name)
The name of the scheduler
|
configurePollingConsumer, configureProperties, configureScheduledPollConsumerProperties, doStart, doStop, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, initConsumerProperties, isGreedy, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelayconfigureConsumer, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toStringdoResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspendpublic SchedulerEndpoint(String uri, SchedulerComponent component, String remaining)
public SchedulerComponent getComponent()
DefaultEndpointgetComponent in class DefaultEndpointpublic Producer createProducer() throws Exception
EndpointException - can be thrownpublic Consumer createConsumer(Processor processor) throws Exception
Endpointprocessor - the given processorException - can be thrownpublic boolean isSingleton()
IsSingletonpublic int getConcurrentTasks()
public void setConcurrentTasks(int concurrentTasks)
public void onConsumerStart(SchedulerConsumer consumer)
public void onConsumerStop(SchedulerConsumer consumer)
Apache Camel