@UriEndpoint(scheme="ironmq", syntax="ironmq:queueName", title="ironmq", consumerClass=IronMQConsumer.class, label="cloud,messaging") public class IronMQEndpoint extends org.apache.camel.impl.ScheduledPollEndpoint
Constructor and Description |
---|
IronMQEndpoint(String uri,
IronMQComponent component,
IronMQConfiguration ironMQConfiguration) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Exchange |
createExchange(io.iron.ironmq.Message msg) |
org.apache.camel.Producer |
createProducer() |
protected void |
doStart() |
protected void |
doStop() |
io.iron.ironmq.Client |
getClient() |
IronMQConfiguration |
getConfiguration() |
boolean |
isSingleton() |
void |
setClient(io.iron.ironmq.Client client) |
configurePollingConsumer, configureProperties, configureScheduledPollConsumerProperties, 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, setUseFixedDelay
configureConsumer, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, 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, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public IronMQEndpoint(String uri, IronMQComponent component, IronMQConfiguration ironMQConfiguration)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public org.apache.camel.Exchange createExchange(io.iron.ironmq.Message msg)
public boolean isSingleton()
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.ScheduledPollEndpoint
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.ScheduledPollEndpoint
Exception
public io.iron.ironmq.Client getClient()
public void setClient(io.iron.ironmq.Client client)
public IronMQConfiguration getConfiguration()
Apache Camel