default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.backoffErrorThreshold(int backoffErrorThreshold) |
The number of subsequent error polls (failed due some error) that
should happen before the backoffMultipler should kick-in.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.backoffErrorThreshold(String backoffErrorThreshold) |
The number of subsequent error polls (failed due some error) that
should happen before the backoffMultipler should kick-in.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.backoffIdleThreshold(int backoffIdleThreshold) |
The number of subsequent idle polls that should happen before the
backoffMultipler should kick-in.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.backoffIdleThreshold(String backoffIdleThreshold) |
The number of subsequent idle polls that should happen before the
backoffMultipler should kick-in.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.backoffMultiplier(int backoffMultiplier) |
To let the scheduled polling consumer backoff if there has been a
number of subsequent idles/errors in a row.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.backoffMultiplier(String backoffMultiplier) |
To let the scheduled polling consumer backoff if there has been a
number of subsequent idles/errors in a row.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.AdvancedIronMQEndpointConsumerBuilder.basic() |
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.batchDelete(boolean batchDelete) |
Should messages be deleted in one batch.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.batchDelete(String batchDelete) |
Should messages be deleted in one batch.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.bridgeErrorHandler(boolean bridgeErrorHandler) |
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions occurred while the consumer is trying to
pickup incoming messages, or the likes, will now be processed as a
message and handled by the routing Error Handler.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.bridgeErrorHandler(String bridgeErrorHandler) |
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions occurred while the consumer is trying to
pickup incoming messages, or the likes, will now be processed as a
message and handled by the routing Error Handler.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.client(Object client) |
Reference to a io.iron.ironmq.Client in the Registry.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.client(String client) |
Reference to a io.iron.ironmq.Client in the Registry.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.concurrentConsumers(int concurrentConsumers) |
The number of concurrent consumers.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.concurrentConsumers(String concurrentConsumers) |
The number of concurrent consumers.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.delay(long delay) |
Milliseconds before the next poll.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.delay(String delay) |
Milliseconds before the next poll.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.greedy(boolean greedy) |
If greedy is enabled, then the ScheduledPollConsumer will run
immediately again, if the previous run polled 1 or more messages.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.greedy(String greedy) |
If greedy is enabled, then the ScheduledPollConsumer will run
immediately again, if the previous run polled 1 or more messages.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.initialDelay(long initialDelay) |
Milliseconds before the first poll starts.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.initialDelay(String initialDelay) |
Milliseconds before the first poll starts.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.ironMQCloud(String ironMQCloud) |
IronMq Cloud url.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.maxMessagesPerPoll(int maxMessagesPerPoll) |
Number of messages to poll pr.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.maxMessagesPerPoll(String maxMessagesPerPoll) |
Number of messages to poll pr.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.preserveHeaders(boolean preserveHeaders) |
Should message headers be preserved when publishing messages.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.preserveHeaders(String preserveHeaders) |
Should message headers be preserved when publishing messages.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.projectId(String projectId) |
IronMQ projectId.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.repeatCount(long repeatCount) |
Specifies a maximum limit of number of fires.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.repeatCount(String repeatCount) |
Specifies a maximum limit of number of fires.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.runLoggingLevel(String runLoggingLevel) |
The consumer logs a start/complete log line when it polls.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.runLoggingLevel(org.apache.camel.LoggingLevel runLoggingLevel) |
The consumer logs a start/complete log line when it polls.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.scheduledExecutorService(String scheduledExecutorService) |
Allows for configuring a custom/shared thread pool to use for the
consumer.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.scheduledExecutorService(ScheduledExecutorService scheduledExecutorService) |
Allows for configuring a custom/shared thread pool to use for the
consumer.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.scheduler(Object scheduler) |
To use a cron scheduler from either camel-spring or camel-quartz
component.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.scheduler(String scheduler) |
To use a cron scheduler from either camel-spring or camel-quartz
component.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.schedulerProperties(String key,
Object value) |
To configure additional properties when using a custom scheduler or
any of the Quartz, Spring based scheduler.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.schedulerProperties(Map values) |
To configure additional properties when using a custom scheduler or
any of the Quartz, Spring based scheduler.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.sendEmptyMessageWhenIdle(boolean sendEmptyMessageWhenIdle) |
If the polling consumer did not poll any files, you can enable this
option to send an empty message (no body) instead.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.sendEmptyMessageWhenIdle(String sendEmptyMessageWhenIdle) |
If the polling consumer did not poll any files, you can enable this
option to send an empty message (no body) instead.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.startScheduler(boolean startScheduler) |
Whether the scheduler should be auto started.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.startScheduler(String startScheduler) |
Whether the scheduler should be auto started.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.timeout(int timeout) |
After timeout (in seconds), item will be placed back onto the queue.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.timeout(String timeout) |
After timeout (in seconds), item will be placed back onto the queue.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.timeUnit(String timeUnit) |
Time unit for initialDelay and delay options.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.timeUnit(TimeUnit timeUnit) |
Time unit for initialDelay and delay options.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.token(String token) |
IronMQ token.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.useFixedDelay(boolean useFixedDelay) |
Controls if fixed delay or fixed rate is used.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.useFixedDelay(String useFixedDelay) |
Controls if fixed delay or fixed rate is used.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.wait(int wait) |
Time in seconds to wait for a message to become available.
|
default IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder |
IronMQEndpointBuilderFactory.IronMQEndpointConsumerBuilder.wait(String wait) |
Time in seconds to wait for a message to become available.
|