default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.accessKey(String accessKey) |
Amazon AWS Access Key.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.amazonS3Client(Object amazonS3Client) |
Reference to a com.amazonaws.services.s3.AmazonS3 in the registry.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.amazonS3Client(String amazonS3Client) |
Reference to a com.amazonaws.services.s3.AmazonS3 in the registry.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.amazonS3Presigner(Object amazonS3Presigner) |
An S3 Presigner for Request, used mainly in createDownloadLink
operation.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.amazonS3Presigner(String amazonS3Presigner) |
An S3 Presigner for Request, used mainly in createDownloadLink
operation.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.autoCreateBucket(boolean autoCreateBucket) |
Setting the autocreation of the S3 bucket bucketName.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.autoCreateBucket(String autoCreateBucket) |
Setting the autocreation of the S3 bucket bucketName.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.backoffErrorThreshold(int backoffErrorThreshold) |
The number of subsequent error polls (failed due some error) that
should happen before the backoffMultipler should kick-in.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.backoffErrorThreshold(String backoffErrorThreshold) |
The number of subsequent error polls (failed due some error) that
should happen before the backoffMultipler should kick-in.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.backoffIdleThreshold(int backoffIdleThreshold) |
The number of subsequent idle polls that should happen before the
backoffMultipler should kick-in.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.backoffIdleThreshold(String backoffIdleThreshold) |
The number of subsequent idle polls that should happen before the
backoffMultipler should kick-in.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.backoffMultiplier(int backoffMultiplier) |
To let the scheduled polling consumer backoff if there has been a
number of subsequent idles/errors in a row.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.backoffMultiplier(String backoffMultiplier) |
To let the scheduled polling consumer backoff if there has been a
number of subsequent idles/errors in a row.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AdvancedAWS2S3EndpointConsumerBuilder.basic() |
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.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 AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.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 AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.delay(long delay) |
Milliseconds before the next poll.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.delay(String delay) |
Milliseconds before the next poll.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.deleteAfterRead(boolean deleteAfterRead) |
Delete objects from S3 after they have been retrieved.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.deleteAfterRead(String deleteAfterRead) |
Delete objects from S3 after they have been retrieved.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.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 AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.destinationBucket(String destinationBucket) |
Define the destination bucket where an object must be moved when
moveAfterRead is set to true.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.destinationBucketPrefix(String destinationBucketPrefix) |
Define the destination bucket prefix to use when an object must be
moved and moveAfterRead is set to true.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.destinationBucketSuffix(String destinationBucketSuffix) |
Define the destination bucket suffix to use when an object must be
moved and moveAfterRead is set to true.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.doneFileName(String doneFileName) |
If provided, Camel will only consume files if a done file exists.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.fileName(String fileName) |
To get the object from the bucket with the given file name.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.greedy(boolean greedy) |
If greedy is enabled, then the ScheduledPollConsumer will run
immediately again, if the previous run polled 1 or more messages.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.greedy(String greedy) |
If greedy is enabled, then the ScheduledPollConsumer will run
immediately again, if the previous run polled 1 or more messages.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.ignoreBody(boolean ignoreBody) |
If it is true, the S3 Object Body will be ignored completely, if it
is set to false the S3 Object will be put in the body.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.ignoreBody(String ignoreBody) |
If it is true, the S3 Object Body will be ignored completely, if it
is set to false the S3 Object will be put in the body.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.includeBody(boolean includeBody) |
If it is true, the S3Object exchange will be consumed and put into
the body and closed.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.includeBody(String includeBody) |
If it is true, the S3Object exchange will be consumed and put into
the body and closed.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.includeFolders(boolean includeFolders) |
If it is true, the folders/directories will be consumed.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.includeFolders(String includeFolders) |
If it is true, the folders/directories will be consumed.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.initialDelay(long initialDelay) |
Milliseconds before the first poll starts.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.initialDelay(String initialDelay) |
Milliseconds before the first poll starts.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.maxConnections(int maxConnections) |
Set the maxConnections parameter in the S3 client configuration.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.maxConnections(String maxConnections) |
Set the maxConnections parameter in the S3 client configuration.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.maxMessagesPerPoll(int maxMessagesPerPoll) |
Gets the maximum number of messages as a limit to poll at each
polling.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.maxMessagesPerPoll(String maxMessagesPerPoll) |
Gets the maximum number of messages as a limit to poll at each
polling.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.moveAfterRead(boolean moveAfterRead) |
Move objects from S3 bucket to a different bucket after they have
been retrieved.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.moveAfterRead(String moveAfterRead) |
Move objects from S3 bucket to a different bucket after they have
been retrieved.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.overrideEndpoint(boolean overrideEndpoint) |
Set the need for overidding the endpoint.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.overrideEndpoint(String overrideEndpoint) |
Set the need for overidding the endpoint.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.pojoRequest(boolean pojoRequest) |
If we want to use a POJO request as body or not.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.pojoRequest(String pojoRequest) |
If we want to use a POJO request as body or not.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.policy(String policy) |
The policy for this queue to set in the
com.amazonaws.services.s3.AmazonS3#setBucketPolicy() method.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.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 AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.proxyHost(String proxyHost) |
To define a proxy host when instantiating the SQS client.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.proxyPort(Integer proxyPort) |
Specify a proxy port to be used inside the client definition.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.proxyPort(String proxyPort) |
Specify a proxy port to be used inside the client definition.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.proxyProtocol(String proxyProtocol) |
To define a proxy protocol when instantiating the S3 client.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.proxyProtocol(AWS2S3EndpointBuilderFactory.Protocol proxyProtocol) |
To define a proxy protocol when instantiating the S3 client.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.region(String region) |
The region in which S3 client needs to work.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.repeatCount(long repeatCount) |
Specifies a maximum limit of number of fires.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.repeatCount(String repeatCount) |
Specifies a maximum limit of number of fires.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.runLoggingLevel(String runLoggingLevel) |
The consumer logs a start/complete log line when it polls.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.runLoggingLevel(org.apache.camel.LoggingLevel runLoggingLevel) |
The consumer logs a start/complete log line when it polls.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.scheduledExecutorService(String scheduledExecutorService) |
Allows for configuring a custom/shared thread pool to use for the
consumer.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.scheduledExecutorService(ScheduledExecutorService scheduledExecutorService) |
Allows for configuring a custom/shared thread pool to use for the
consumer.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.scheduler(Object scheduler) |
To use a cron scheduler from either camel-spring or camel-quartz
component.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.scheduler(String scheduler) |
To use a cron scheduler from either camel-spring or camel-quartz
component.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.schedulerProperties(String key,
Object value) |
To configure additional properties when using a custom scheduler or
any of the Quartz, Spring based scheduler.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.schedulerProperties(Map values) |
To configure additional properties when using a custom scheduler or
any of the Quartz, Spring based scheduler.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.secretKey(String secretKey) |
Amazon AWS Secret Key.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.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 AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.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 AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.startScheduler(boolean startScheduler) |
Whether the scheduler should be auto started.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.startScheduler(String startScheduler) |
Whether the scheduler should be auto started.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.timeUnit(String timeUnit) |
Time unit for initialDelay and delay options.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.timeUnit(TimeUnit timeUnit) |
Time unit for initialDelay and delay options.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.trustAllCertificates(boolean trustAllCertificates) |
If we want to trust all certificates in case of overriding the
endpoint.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.trustAllCertificates(String trustAllCertificates) |
If we want to trust all certificates in case of overriding the
endpoint.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.uriEndpointOverride(String uriEndpointOverride) |
Set the overriding uri endpoint.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.useDefaultCredentialsProvider(boolean useDefaultCredentialsProvider) |
Set whether the S3 client should expect to load credentials through a
default credentials provider or to expect static credentials to be
passed in.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.useDefaultCredentialsProvider(String useDefaultCredentialsProvider) |
Set whether the S3 client should expect to load credentials through a
default credentials provider or to expect static credentials to be
passed in.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.useFixedDelay(boolean useFixedDelay) |
Controls if fixed delay or fixed rate is used.
|
default AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder |
AWS2S3EndpointBuilderFactory.AWS2S3EndpointConsumerBuilder.useFixedDelay(String useFixedDelay) |
Controls if fixed delay or fixed rate is used.
|