default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.accessKey(String accessKey) |
Amazon AWS Access Key.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.amazonS3Client(Object amazonS3Client) |
Reference to a com.amazonaws.services.s3.AmazonS3 in the registry.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.amazonS3Client(String amazonS3Client) |
Reference to a com.amazonaws.services.s3.AmazonS3 in the registry.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.autoCreateBucket(boolean autoCreateBucket) |
Setting the autocreation of the bucket.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.autoCreateBucket(String autoCreateBucket) |
Setting the autocreation of the bucket.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.autoDiscoverClient(boolean autoDiscoverClient) |
Setting the autoDiscoverClient mechanism, if true, the component will
look for a client instance in the registry automatically otherwise it
will skip that checking.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.autoDiscoverClient(String autoDiscoverClient) |
Setting the autoDiscoverClient mechanism, if true, the component will
look for a client instance in the registry automatically otherwise it
will skip that checking.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.backoffErrorThreshold(int backoffErrorThreshold) |
The number of subsequent error polls (failed due some error) that
should happen before the backoffMultipler should kick-in.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.backoffErrorThreshold(String backoffErrorThreshold) |
The number of subsequent error polls (failed due some error) that
should happen before the backoffMultipler should kick-in.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.backoffIdleThreshold(int backoffIdleThreshold) |
The number of subsequent idle polls that should happen before the
backoffMultipler should kick-in.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.backoffIdleThreshold(String backoffIdleThreshold) |
The number of subsequent idle polls that should happen before the
backoffMultipler should kick-in.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.backoffMultiplier(int backoffMultiplier) |
To let the scheduled polling consumer backoff if there has been a
number of subsequent idles/errors in a row.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.backoffMultiplier(String backoffMultiplier) |
To let the scheduled polling consumer backoff if there has been a
number of subsequent idles/errors in a row.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.AdvancedS3EndpointConsumerBuilder.basic() |
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.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 S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.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 S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.delay(long delay) |
Milliseconds before the next poll.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.delay(String delay) |
Milliseconds before the next poll.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.deleteAfterRead(boolean deleteAfterRead) |
Delete objects from S3 after they have been retrieved.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.deleteAfterRead(String deleteAfterRead) |
Delete objects from S3 after they have been retrieved.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.delimiter(String delimiter) |
The delimiter which is used in the
com.amazonaws.services.s3.model.ListObjectsRequest to only consume
objects we are interested in.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.endpointConfiguration(Object endpointConfiguration) |
Amazon AWS Endpoint Configuration.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.endpointConfiguration(String endpointConfiguration) |
Amazon AWS Endpoint Configuration.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.fileName(String fileName) |
To get the object from the bucket with the given file name.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.greedy(boolean greedy) |
If greedy is enabled, then the ScheduledPollConsumer will run
immediately again, if the previous run polled 1 or more messages.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.greedy(String greedy) |
If greedy is enabled, then the ScheduledPollConsumer will run
immediately again, if the previous run polled 1 or more messages.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.includeBody(boolean includeBody) |
If it is true, the exchange body will be set to a stream to the
contents of the file.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.includeBody(String includeBody) |
If it is true, the exchange body will be set to a stream to the
contents of the file.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.initialDelay(long initialDelay) |
Milliseconds before the first poll starts.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.initialDelay(String initialDelay) |
Milliseconds before the first poll starts.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.maxConnections(int maxConnections) |
Set the maxConnections parameter in the S3 client configuration.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.maxConnections(String maxConnections) |
Set the maxConnections parameter in the S3 client configuration.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.maxMessagesPerPoll(int maxMessagesPerPoll) |
Gets the maximum number of messages as a limit to poll at each
polling.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.maxMessagesPerPoll(String maxMessagesPerPoll) |
Gets the maximum number of messages as a limit to poll at each
polling.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.pathStyleAccess(boolean pathStyleAccess) |
Whether or not the S3 client should use path style access.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.pathStyleAccess(String pathStyleAccess) |
Whether or not the S3 client should use path style access.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.policy(String policy) |
The policy for this queue to set in the
com.amazonaws.services.s3.AmazonS3#setBucketPolicy() method.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.prefix(String prefix) |
The prefix which is used in the
com.amazonaws.services.s3.model.ListObjectsRequest to only consume
objects we are interested in.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.proxyHost(String proxyHost) |
To define a proxy host when instantiating the S3 client.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.proxyPort(Integer proxyPort) |
Specify a proxy port to be used inside the client definition.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.proxyPort(String proxyPort) |
Specify a proxy port to be used inside the client definition.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.proxyProtocol(String proxyProtocol) |
To define a proxy protocol when instantiating the S3 client.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.proxyProtocol(S3EndpointBuilderFactory.Protocol proxyProtocol) |
To define a proxy protocol when instantiating the S3 client.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.region(String region) |
The region in which S3 client needs to work.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.repeatCount(long repeatCount) |
Specifies a maximum limit of number of fires.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.repeatCount(String repeatCount) |
Specifies a maximum limit of number of fires.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.runLoggingLevel(String runLoggingLevel) |
The consumer logs a start/complete log line when it polls.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.runLoggingLevel(org.apache.camel.LoggingLevel runLoggingLevel) |
The consumer logs a start/complete log line when it polls.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.scheduledExecutorService(String scheduledExecutorService) |
Allows for configuring a custom/shared thread pool to use for the
consumer.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.scheduledExecutorService(ScheduledExecutorService scheduledExecutorService) |
Allows for configuring a custom/shared thread pool to use for the
consumer.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.scheduler(Object scheduler) |
To use a cron scheduler from either camel-spring or camel-quartz
component.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.scheduler(String scheduler) |
To use a cron scheduler from either camel-spring or camel-quartz
component.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.schedulerProperties(String key,
Object value) |
To configure additional properties when using a custom scheduler or
any of the Quartz, Spring based scheduler.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.schedulerProperties(Map values) |
To configure additional properties when using a custom scheduler or
any of the Quartz, Spring based scheduler.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.secretKey(String secretKey) |
Amazon AWS Secret Key.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.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 S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.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 S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.startScheduler(boolean startScheduler) |
Whether the scheduler should be auto started.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.startScheduler(String startScheduler) |
Whether the scheduler should be auto started.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.timeUnit(String timeUnit) |
Time unit for initialDelay and delay options.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.timeUnit(TimeUnit timeUnit) |
Time unit for initialDelay and delay options.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.useFixedDelay(boolean useFixedDelay) |
Controls if fixed delay or fixed rate is used.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.useFixedDelay(String useFixedDelay) |
Controls if fixed delay or fixed rate is used.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.useIAMCredentials(boolean useIAMCredentials) |
Set whether the S3 client should expect to load credentials on an EC2
instance or to expect static credentials to be passed in.
|
default S3EndpointBuilderFactory.S3EndpointConsumerBuilder |
S3EndpointBuilderFactory.S3EndpointConsumerBuilder.useIAMCredentials(String useIAMCredentials) |
Set whether the S3 client should expect to load credentials on an EC2
instance or to expect static credentials to be passed in.
|