Defines a Consumer Endpoint for the 'org.springframework.integration.aws.outbound.S3MessageHandler'
with one-way behaviour to perform Amazon S3 operations .
Defines a Consumer Endpoint for the 'org.springframework.integration.aws.outbound.S3MessageHandler'
with request-reply behaviour to perform Amazon S3 operations.
Identifies the request channel attached to this gateway.
Identifies the reply channel attached to this gateway.
Specifies the order for invocation when this endpoint is connected as a
subscriber to a SubscribableChannel.
Reference to an instance of 'com.amazonaws.services.s3.AmazonS3'.
Mutually exclusive with the 'transfer-manager'.
Reference to an instance of 'com.amazonaws.services.s3.transfer.TransferManager'.
Mutually exclusive with the 's3'.
The S3 bucket to use.
Mutually exclusive with 'bucket-expression'.
A SpEL expression to evaluate S3 bucket at runtime against request message.
Mutually exclusive with 'bucket'.
The S3MessageHandler operation command.
Mutually exclusive with 'command-expression'.
A SpEL expression to evaluate S3MessageHandler operation command at runtime against request message.
Mutually exclusive with 'command'.
Reference to an instance of 'com.amazonaws.services.s3.transfer.internal.S3ProgressListener'.
Reference to an instance of
'org.springframework.integration.aws.outbound.S3MessageHandler$UploadMetadataProvider'.
A SpEL expression to evaluate S3Object key at runtime against request message.
A SpEL expression to evaluate S3Object ACL at runtime against request message
for the 'upload' operation.
A SpEL expression to evaluate destination S3 bucket at runtime against request message
for the 'copy' operation.
A SpEL expression to evaluate destination S3Object key at runtime against request message
for the 'copy' operation.
The 'org.springframework.cloud.aws.core.env.ResourceIdResolver' bean reference.
Configures a 'SourcePollingChannelAdapter' Endpoint for the
'org.springframework.integration.aws.inbound.S3InboundFileSynchronizingMessageSource' that
synchronizes a local directory with the contents of a remote Amazon S3 bucket.
Identifies the directory path (e.g.,
"/local/mytransfers") where files
will be transferred TO.
Extension used when downloading files.
We change it right after we know it's downloaded.
Allows you to provide a SpEL expression to
generate the file name of
the local (transferred) file. The root
object of the SpEL
evaluation is the name of the original
file.
For example, a valid expression would be "#this.toUpperCase() +
'.a'" where #this represents the
original name of the remote
file.
Allows you to specify a reference to a
[org.springframework.integration.file.filters.FileListFilter]
bean. This filter is applied to files after they have been
retrieved. The default is an AcceptOnceFileListFilter which means that,
even if a new instance of a file is retrieved from the remote server,
a message won't be generated. The filter provided here is combined
with a filter that prevents the message source from processing
files that are currently being downloaded.
Tells this adapter if the local directory must
be auto-created if it doesn't exist. Default is TRUE.
Specify whether to delete the remote source file after copying.
By default, the remote files will NOT be deleted.
Specify whether to preserve the modified timestamp from the remote source
file on the local file after copying.
By default, the remote timestamp will NOT be preserved.
Configures a 'SourcePollingChannelAdapter' Endpoint for the
'org.springframework.integration.aws.inbound.S3StreamingMessageSource'.
Reference to an [org.springframework.integration.file.remote.session.SessionFactory] bean with
a [com.amazonaws.services.s3.model.S3ObjectSummary] generic type parameter.
Allows you to provide remote file/directory
separator character. DEFAULT: '/'
Identifies the remote directory path (e.g., "/remote/mytransfers")
Mutually exclusive with 'remote-directory-expression'.
Specify a SpEL expression which will be used to evaluate the directory
path to where the files will be transferred
(e.g., "headers.['remote_dir'] + '/myTransfers'" for outbound endpoints)
There is no root object (message) for inbound endpoints
(e.g., "@someBean.fetchDirectory");
Allows you to provide a file name pattern to determine the file names that need to be scanned.
This is based on simple pattern matching (e.g., "*.txt, fo*.txt" etc.)
Allows you to provide a Regular Expression to determine the file names that need to be scanned.
(e.g., "f[o]+\.txt" etc.)
Allows you to specify a reference to a
[org.springframework.integration.file.filters.FileListFilter]
bean. This filter is applied to files on the remote server and
only files that pass the filter are retrieved.
Specify a Comparator to be used when ordering Files. If none is provided, the
order in which files are processed is the order they are received from the S3 server.
The generic type of the Comparator must be 'S3FileInfo'.
Defines an outbound SQS Channel Adapter for sending messages to queues.
The Amazon queue name or URL.
Mutually exclusive with 'queue-expression'.
This attribute isn't mandatory and the queue can be specified in message headers
with the 'AwsHeaders.QUEUE' header name.
A SpEL expression that resolves to an Amazon queue or its URL.
The 'requestMessage' is the root object for evaluation context.
Mutually exclusive with 'queue'.
This attribute isn't mandatory and the queue can be specified in message headers with
the 'AwsHeaders.QUEUE' header name.
A bean reference to the QueueMessagingTemplate that this class is supposed to use.
This attribute is mutually exclusive with the 'sqs' and 'resource-id-resolver'
attributes.
Configures an endpoint ('SqsMessageDrivenChannelAdapter') that will receive
Amazon SQS message from the provided 'queues'.
Message Channel to which error Messages should be sent.
Maximum amount of time in milliseconds to wait when sending a message
to the channel if such channel may block.
For example, a Queue Channel can block until space is available
if its maximum capacity has been reached.
Comma-separated SQS queue names or their URLs.
The 'org.springframework.core.task.AsyncTaskExecutor' to run the underlying listener
task
from the
'org.springframework.cloud.aws.messaging.listener.SimpleMessageListenerContainer'.
Configure the maximum number of messages that should be retrieved during one
poll to the Amazon SQS system. This number must be a positive, non-zero number that
has a maximum number of 10. Values higher then 10 are currently
not supported by the queueing system. Defaults to 1.
Configures the duration (in seconds) that the received messages are hidden from
subsequent poll requests after being retrieved from the system.
Configure the maximum number of milliseconds the method waits for a queue
to stop before interrupting the current thread. Defaults to 10000.
A reference to a bean that implements the
'org.springframework.messaging.core.DestinationResolver' interface.
E.g.
'org.springframework.cloud.aws.messaging.support.destination.DynamicQueueUrlDestinationResolver'
Defines the policy that must be used for the deletion of SQS messages once
they were processed. The default policy is NO_REDRIVE because it is the safest
way to avoid poison messages and have
a safe way to avoid the loss of messages (i.e. using a dead letter queue).
Defines an SNS inbound HTTP-based Channel Adapter - SnsInboundChannelAdapter.
The 'com.amazonaws.services.sns.AmazonSNS' bean reference.
Comma-separated URI paths (e.g., /orderId/{order}).
Ant-style path patterns are also supported (e.g. /myPath/*.do).
Maximum amount of time in milliseconds to wait when sending
a message to the channel if such channel may block.
For example, a Queue Channel can block until space
is available if its maximum capacity has been reached.
Allows you to specify SpEL expression to construct a Message payload.
The root evaluation object is a raw Message as a result of the 'HttpServletRequest'
conversion in the 'HttpRequestHandlingEndpointSupport' super class.
The MessagingGateway's 'error-channel' where to send an ErrorMessage in case
of Exception is caused from original message flow.
Flag to indicate if the 'SubscriptionConfirmation' and 'UnsubscribeConfirmation'
SNS messages should sent to the 'channel' or not. If 'true' the
'AwsHeaders.NOTIFICATION_STATUS' message header is populated with the 'NotificationStatus'
value. In this case it is an application responsibility to 'confirm' subscription or not using
that 'NotificationStatus' object. Defaults to 'false'.
Defines an outbound SNS Channel Adapter for publishing messages to the topic.
Defines an outbound SNS Channel Adapter for publishing messages to the topic.
Identifies the request channel attached to this gateway.
Identifies the reply channel attached to this
gateway.
Base type for the 'sqs-message-driven-channel-adapter' and 'sqs-outbound-channel-adapter' elements.
The 'com.amazonaws.services.sqs.AmazonSQS' bean reference.
Must be 'AmazonSQSAsync' for the 'sqs-message-driven-channel-adapter'.
The 'org.springframework.cloud.aws.core.env.ResourceIdResolver' bean reference.
The 'com.amazonaws.services.sns.AmazonSNS' bean reference.
The Amazon SNS Topic ARN.
Mutually exclusive with 'topic-arn-expression'.
This attribute isn't mandatory and the topic can be specified on the 'PublishRequest'
payload of the request Message.
A SpEL expression that resolves to an Amazon SNS Topic ARN.
The 'requestMessage' is the root object for evaluation context.
Mutually exclusive with 'topic-arn'.
This attribute isn't mandatory and the the topic can be specified on the
'com.amazonaws.services.sns.model.PublishRequest'
payload of the request Message.
The Notification Subject.
Mutually exclusive with 'subject-expression'.
This attribute isn't mandatory and the subject can be fully omitted.
The SpEL expression for Notification Subject.
The 'requestMessage' is the root object for evaluation context.
Mutually exclusive with 'subject-expression'.
This attribute isn't mandatory and the subject can be fully omitted.
The SpEL expression evaluating the 'message' object for
the 'com.amazonaws.services.sns.model.PublishRequest'.
The 'requestMessage' is the root object for evaluation context.
The 'org.springframework.integration.aws.support' package is registered with the
`EvaluationContext` to simplify usage of the `SnsBodyBuilder` from expression definition.
This attribute isn't mandatory and the 'payload' of request Message can be used directly.
The 'org.springframework.cloud.aws.core.env.ResourceIdResolver' bean reference.
Specifies the order for invocation when this endpoint is connected as a
subscriber to a SubscribableChannel.