default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.allowNamedParameters(boolean allowNamedParameters) |
Whether to allow using named parameters in the queries.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.allowNamedParameters(String allowNamedParameters) |
Whether to allow using named parameters in the queries.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.backoffErrorThreshold(int backoffErrorThreshold) |
The number of subsequent error polls (failed due some error) that
should happen before the backoffMultipler should kick-in.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.backoffErrorThreshold(String backoffErrorThreshold) |
The number of subsequent error polls (failed due some error) that
should happen before the backoffMultipler should kick-in.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.backoffIdleThreshold(int backoffIdleThreshold) |
The number of subsequent idle polls that should happen before the
backoffMultipler should kick-in.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.backoffIdleThreshold(String backoffIdleThreshold) |
The number of subsequent idle polls that should happen before the
backoffMultipler should kick-in.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.backoffMultiplier(int backoffMultiplier) |
To let the scheduled polling consumer backoff if there has been a
number of subsequent idles/errors in a row.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.backoffMultiplier(String backoffMultiplier) |
To let the scheduled polling consumer backoff if there has been a
number of subsequent idles/errors in a row.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.AdvancedElsqlEndpointConsumerBuilder.basic() |
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.breakBatchOnConsumeFail(boolean breakBatchOnConsumeFail) |
Sets whether to break batch if onConsume failed.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.breakBatchOnConsumeFail(String breakBatchOnConsumeFail) |
Sets whether to break batch if onConsume failed.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.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 ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.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 ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.databaseVendor(String databaseVendor) |
To use a vendor specific com.opengamma.elsql.ElSqlConfig.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.databaseVendor(ElsqlEndpointBuilderFactory.ElSqlDatabaseVendor databaseVendor) |
To use a vendor specific com.opengamma.elsql.ElSqlConfig.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.dataSource(Object dataSource) |
Sets the DataSource to use to communicate with the database.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.dataSource(String dataSource) |
Sets the DataSource to use to communicate with the database.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.dataSourceRef(String dataSourceRef) |
Deprecated.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.delay(long delay) |
Milliseconds before the next poll.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.delay(String delay) |
Milliseconds before the next poll.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.expectedUpdateCount(int expectedUpdateCount) |
Sets an expected update count to validate when using onConsume.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.expectedUpdateCount(String expectedUpdateCount) |
Sets an expected update count to validate when using onConsume.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.greedy(boolean greedy) |
If greedy is enabled, then the ScheduledPollConsumer will run
immediately again, if the previous run polled 1 or more messages.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.greedy(String greedy) |
If greedy is enabled, then the ScheduledPollConsumer will run
immediately again, if the previous run polled 1 or more messages.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.initialDelay(long initialDelay) |
Milliseconds before the first poll starts.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.initialDelay(String initialDelay) |
Milliseconds before the first poll starts.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.maxMessagesPerPoll(int maxMessagesPerPoll) |
Sets the maximum number of messages to poll.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.maxMessagesPerPoll(String maxMessagesPerPoll) |
Sets the maximum number of messages to poll.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.onConsume(String onConsume) |
After processing each row then this query can be executed, if the
Exchange was processed successfully, for example to mark the row as
processed.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.onConsumeBatchComplete(String onConsumeBatchComplete) |
After processing the entire batch, this query can be executed to bulk
update rows etc.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.onConsumeFailed(String onConsumeFailed) |
After processing each row then this query can be executed, if the
Exchange failed, for example to mark the row as failed.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.outputClass(String outputClass) |
Specify the full package and class name to use as conversion when
outputType=SelectOne.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.outputHeader(String outputHeader) |
Store the query result in a header instead of the message body.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.outputType(String outputType) |
Make the output of consumer or producer to SelectList as List of Map,
or SelectOne as single Java object in the following way: a) If the
query has only single column, then that JDBC Column object is
returned.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.outputType(ElsqlEndpointBuilderFactory.SqlOutputType outputType) |
Make the output of consumer or producer to SelectList as List of Map,
or SelectOne as single Java object in the following way: a) If the
query has only single column, then that JDBC Column object is
returned.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.repeatCount(long repeatCount) |
Specifies a maximum limit of number of fires.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.repeatCount(String repeatCount) |
Specifies a maximum limit of number of fires.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.routeEmptyResultSet(boolean routeEmptyResultSet) |
Sets whether empty resultset should be allowed to be sent to the next
hop.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.routeEmptyResultSet(String routeEmptyResultSet) |
Sets whether empty resultset should be allowed to be sent to the next
hop.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.runLoggingLevel(String runLoggingLevel) |
The consumer logs a start/complete log line when it polls.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.runLoggingLevel(org.apache.camel.LoggingLevel runLoggingLevel) |
The consumer logs a start/complete log line when it polls.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.scheduledExecutorService(String scheduledExecutorService) |
Allows for configuring a custom/shared thread pool to use for the
consumer.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.scheduledExecutorService(ScheduledExecutorService scheduledExecutorService) |
Allows for configuring a custom/shared thread pool to use for the
consumer.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.scheduler(Object scheduler) |
To use a cron scheduler from either camel-spring or camel-quartz
component.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.scheduler(String scheduler) |
To use a cron scheduler from either camel-spring or camel-quartz
component.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.schedulerProperties(String key,
Object value) |
To configure additional properties when using a custom scheduler or
any of the Quartz, Spring based scheduler.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.schedulerProperties(Map values) |
To configure additional properties when using a custom scheduler or
any of the Quartz, Spring based scheduler.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.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 ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.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 ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.separator(char separator) |
The separator to use when parameter values is taken from message body
(if the body is a String type), to be inserted at # placeholders.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.separator(String separator) |
The separator to use when parameter values is taken from message body
(if the body is a String type), to be inserted at # placeholders.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.startScheduler(boolean startScheduler) |
Whether the scheduler should be auto started.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.startScheduler(String startScheduler) |
Whether the scheduler should be auto started.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.timeUnit(String timeUnit) |
Time unit for initialDelay and delay options.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.timeUnit(TimeUnit timeUnit) |
Time unit for initialDelay and delay options.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.transacted(boolean transacted) |
Enables or disables transaction.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.transacted(String transacted) |
Enables or disables transaction.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.useFixedDelay(boolean useFixedDelay) |
Controls if fixed delay or fixed rate is used.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.useFixedDelay(String useFixedDelay) |
Controls if fixed delay or fixed rate is used.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.useIterator(boolean useIterator) |
Sets how resultset should be delivered to route.
|
default ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder |
ElsqlEndpointBuilderFactory.ElsqlEndpointConsumerBuilder.useIterator(String useIterator) |
Sets how resultset should be delivered to route.
|