Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
S
- S3_REF - Static variable in class org.springframework.integration.aws.config.xml.AwsParserUtils
-
The 's3' reference attribute name.
- S3FileInfo - Class in org.springframework.integration.aws.support
-
An Amazon S3
FileInfoimplementation. - S3FileInfo(S3ObjectSummary) - Constructor for class org.springframework.integration.aws.support.S3FileInfo
- S3InboundChannelAdapterParser - Class in org.springframework.integration.aws.config.xml
-
Parser for the AWS 's3-inbound-channel-adapter' element.
- S3InboundChannelAdapterParser() - Constructor for class org.springframework.integration.aws.config.xml.S3InboundChannelAdapterParser
- S3InboundFileSynchronizer - Class in org.springframework.integration.aws.inbound
-
An implementation of
AbstractInboundFileSynchronizerfor Amazon S3. - S3InboundFileSynchronizer() - Constructor for class org.springframework.integration.aws.inbound.S3InboundFileSynchronizer
- S3InboundFileSynchronizer(AmazonS3) - Constructor for class org.springframework.integration.aws.inbound.S3InboundFileSynchronizer
- S3InboundFileSynchronizer(SessionFactory<S3ObjectSummary>) - Constructor for class org.springframework.integration.aws.inbound.S3InboundFileSynchronizer
-
Create a synchronizer with the
SessionFactoryused to acquireSessioninstances. - S3InboundFileSynchronizingMessageSource - Class in org.springframework.integration.aws.inbound
-
A
MessageSourceimplementation for the Amazon S3. - S3InboundFileSynchronizingMessageSource(AbstractInboundFileSynchronizer<S3ObjectSummary>) - Constructor for class org.springframework.integration.aws.inbound.S3InboundFileSynchronizingMessageSource
- S3InboundFileSynchronizingMessageSource(AbstractInboundFileSynchronizer<S3ObjectSummary>, Comparator<File>) - Constructor for class org.springframework.integration.aws.inbound.S3InboundFileSynchronizingMessageSource
- S3MessageHandler - Class in org.springframework.integration.aws.outbound
-
The
AbstractReplyProducingMessageHandlerimplementation for the Amazon S3 services. - S3MessageHandler(AmazonS3, String) - Constructor for class org.springframework.integration.aws.outbound.S3MessageHandler
- S3MessageHandler(AmazonS3, String, boolean) - Constructor for class org.springframework.integration.aws.outbound.S3MessageHandler
- S3MessageHandler(AmazonS3, Expression) - Constructor for class org.springframework.integration.aws.outbound.S3MessageHandler
- S3MessageHandler(AmazonS3, Expression, boolean) - Constructor for class org.springframework.integration.aws.outbound.S3MessageHandler
- S3MessageHandler(TransferManager, String) - Constructor for class org.springframework.integration.aws.outbound.S3MessageHandler
- S3MessageHandler(TransferManager, String, boolean) - Constructor for class org.springframework.integration.aws.outbound.S3MessageHandler
- S3MessageHandler(TransferManager, Expression) - Constructor for class org.springframework.integration.aws.outbound.S3MessageHandler
- S3MessageHandler(TransferManager, Expression, boolean) - Constructor for class org.springframework.integration.aws.outbound.S3MessageHandler
- S3MessageHandler.Command - Enum Class in org.springframework.integration.aws.outbound
-
The
S3MessageHandlermode. - S3MessageHandler.MessageS3ProgressListener - Interface in org.springframework.integration.aws.outbound
- S3MessageHandler.UploadMetadataProvider - Interface in org.springframework.integration.aws.outbound
-
The callback to populate an
ObjectMetadatafor upload operation. - S3OutboundChannelAdapterParser - Class in org.springframework.integration.aws.config.xml
-
The parser for the
<int-aws:s3-outbound-channel-adapter>. - S3OutboundChannelAdapterParser() - Constructor for class org.springframework.integration.aws.config.xml.S3OutboundChannelAdapterParser
- S3OutboundGatewayParser - Class in org.springframework.integration.aws.config.xml
-
The parser for the
<int-aws:s3-outbound-gateway>. - S3OutboundGatewayParser() - Constructor for class org.springframework.integration.aws.config.xml.S3OutboundGatewayParser
- S3PersistentAcceptOnceFileListFilter - Class in org.springframework.integration.aws.support.filters
-
Persistent file list filter using the server's file timestamp to detect if we've already 'seen' this file.
- S3PersistentAcceptOnceFileListFilter(ConcurrentMetadataStore, String) - Constructor for class org.springframework.integration.aws.support.filters.S3PersistentAcceptOnceFileListFilter
- S3RegexPatternFileListFilter - Class in org.springframework.integration.aws.support.filters
-
Implementation of
AbstractRegexPatternFileListFilterfor Amazon S3. - S3RegexPatternFileListFilter(String) - Constructor for class org.springframework.integration.aws.support.filters.S3RegexPatternFileListFilter
- S3RegexPatternFileListFilter(Pattern) - Constructor for class org.springframework.integration.aws.support.filters.S3RegexPatternFileListFilter
- S3RemoteFileTemplate - Class in org.springframework.integration.aws.support
-
An Amazon S3 specific
RemoteFileTemplateextension. - S3RemoteFileTemplate() - Constructor for class org.springframework.integration.aws.support.S3RemoteFileTemplate
- S3RemoteFileTemplate(AmazonS3) - Constructor for class org.springframework.integration.aws.support.S3RemoteFileTemplate
- S3RemoteFileTemplate(SessionFactory<S3ObjectSummary>) - Constructor for class org.springframework.integration.aws.support.S3RemoteFileTemplate
-
Construct a
RemoteFileTemplatewith the supplied session factory. - S3Session - Class in org.springframework.integration.aws.support
-
An Amazon S3
Sessionimplementation. - S3Session(AmazonS3) - Constructor for class org.springframework.integration.aws.support.S3Session
- S3Session(AmazonS3, ResourceIdResolver) - Constructor for class org.springframework.integration.aws.support.S3Session
- S3SessionFactory - Class in org.springframework.integration.aws.support
-
An Amazon S3 specific
SessionFactoryimplementation. - S3SessionFactory() - Constructor for class org.springframework.integration.aws.support.S3SessionFactory
- S3SessionFactory(AmazonS3) - Constructor for class org.springframework.integration.aws.support.S3SessionFactory
- S3SessionFactory(AmazonS3, ResourceIdResolver) - Constructor for class org.springframework.integration.aws.support.S3SessionFactory
- S3SimplePatternFileListFilter - Class in org.springframework.integration.aws.support.filters
-
Implementation of
AbstractSimplePatternFileListFilterfor Amazon S3. - S3SimplePatternFileListFilter(String) - Constructor for class org.springframework.integration.aws.support.filters.S3SimplePatternFileListFilter
- S3StreamingInboundChannelAdapterParser - Class in org.springframework.integration.aws.config.xml
-
Parser for the AWS 's3-inbound-streaming-channel-adapter' element.
- S3StreamingInboundChannelAdapterParser() - Constructor for class org.springframework.integration.aws.config.xml.S3StreamingInboundChannelAdapterParser
- S3StreamingMessageSource - Class in org.springframework.integration.aws.inbound
-
A
AbstractRemoteFileStreamingMessageSourceimplementation for the Amazon S3. - S3StreamingMessageSource(RemoteFileTemplate<S3ObjectSummary>) - Constructor for class org.springframework.integration.aws.inbound.S3StreamingMessageSource
- S3StreamingMessageSource(RemoteFileTemplate<S3ObjectSummary>, Comparator<S3ObjectSummary>) - Constructor for class org.springframework.integration.aws.inbound.S3StreamingMessageSource
- send(Object) - Method in class org.springframework.integration.aws.inbound.SnsInboundChannelAdapter
- SEQUENCE_NUMBER - Static variable in class org.springframework.integration.aws.support.AwsHeaders
-
The "aws_sequenceNumber" header for sending data to SQS/Kinesis.
- SERVICE_RESULT - Static variable in class org.springframework.integration.aws.support.AwsHeaders
-
The "aws_serviceResult" header represents a
AmazonWebServiceResult. - setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
- setAsyncHandler(AsyncHandler<? extends AmazonWebServiceRequest, ?>) - Method in class org.springframework.integration.aws.outbound.AbstractAwsMessageHandler
- setAutoStartup(boolean) - Method in class org.springframework.integration.aws.inbound.SqsMessageDrivenChannelAdapter
- setBillingMode(BillingMode) - Method in class org.springframework.integration.aws.lock.DynamoDbLockRegistry
- setBillingMode(BillingMode) - Method in class org.springframework.integration.aws.metadata.DynamoDbMetadataStore
- setBindSourceRecord(boolean) - Method in class org.springframework.integration.aws.inbound.kinesis.KclMessageDrivenChannelAdapter
-
Set to true to bind the source consumer record in the header named
IntegrationMessageHeaderAccessor.SOURCE_DATA. - setBindSourceRecord(boolean) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
-
Set to true to bind the source consumer record in the header named
IntegrationMessageHeaderAccessor.SOURCE_DATA. - setBodyExpression(Expression) - Method in class org.springframework.integration.aws.outbound.SnsMessageHandler
-
The
Expressionto produce the SNS notification message. - setCheckpointMode(CheckpointMode) - Method in class org.springframework.integration.aws.inbound.kinesis.KclMessageDrivenChannelAdapter
- setCheckpointMode(CheckpointMode) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
- setCheckpointsInterval(long) - Method in class org.springframework.integration.aws.inbound.kinesis.KclMessageDrivenChannelAdapter
-
Sets the interval between 2 checkpoints.
- setCheckpointsInterval(long) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
-
Sets the interval between 2 checkpoints.
- setCheckpointStore(ConcurrentMetadataStore) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
- setCommand(S3MessageHandler.Command) - Method in class org.springframework.integration.aws.outbound.S3MessageHandler
-
Specify a
S3MessageHandler.Commandto perform againstTransferManager. - setCommandExpression(Expression) - Method in class org.springframework.integration.aws.outbound.S3MessageHandler
-
The SpEL expression to evaluate the command to perform on
TransferManager:upload,downloadorcopy. - setConcurrency(int) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
-
The maximum number of concurrent
KinesisMessageDrivenChannelAdapter.ConsumerInvokers running. - setConsumerBackoff(int) - Method in class org.springframework.integration.aws.inbound.kinesis.KclMessageDrivenChannelAdapter
- setConsumerBackoff(int) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
- setConsumerExecutor(Executor) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
- setConsumerGroup(String) - Method in class org.springframework.integration.aws.inbound.kinesis.KclMessageDrivenChannelAdapter
- setConsumerGroup(String) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
- setConverter(Converter<byte[], Object>) - Method in class org.springframework.integration.aws.inbound.kinesis.KclMessageDrivenChannelAdapter
-
Specify a
Converterto deserialize thebyte[]from record's body. - setConverter(Converter<byte[], Object>) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
-
Specify a
Converterto deserialize thebyte[]from record's body. - setConverter(Converter<Object, byte[]>) - Method in class org.springframework.integration.aws.outbound.KinesisMessageHandler
-
Deprecated.
- setConverter(Converter<Object, byte[]>) - Method in class org.springframework.integration.aws.outbound.KplMessageHandler
-
Deprecated.
- setCreateTableDelay(int) - Method in class org.springframework.integration.aws.metadata.DynamoDbMetadataStore
- setCreateTableRetries(int) - Method in class org.springframework.integration.aws.metadata.DynamoDbMetadataStore
- setDelay(int) - Method in class org.springframework.integration.aws.outbound.SqsMessageHandler
- setDelayExpression(Expression) - Method in class org.springframework.integration.aws.outbound.SqsMessageHandler
- setDelayExpressionString(String) - Method in class org.springframework.integration.aws.outbound.SqsMessageHandler
- setDescribeStreamBackoff(int) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
- setDescribeStreamRetries(int) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
- setDestinationBucketExpression(Expression) - Method in class org.springframework.integration.aws.outbound.S3MessageHandler
-
The SpEL expression to evaluate the target S3 bucket for copy operation.
- setDestinationKeyExpression(Expression) - Method in class org.springframework.integration.aws.outbound.S3MessageHandler
-
The SpEL expression to evaluate the target S3 key for copy operation.
- setDestinationResolver(DestinationResolver<String>) - Method in class org.springframework.integration.aws.inbound.SqsMessageDrivenChannelAdapter
- setDispatcherExecutor(Executor) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
- setEmbeddedHeadersMapper(InboundMessageMapper<byte[]>) - Method in class org.springframework.integration.aws.inbound.kinesis.KclMessageDrivenChannelAdapter
-
Specify an
InboundMessageMapperto extract message headers embedded into the record data. - setEmbeddedHeadersMapper(InboundMessageMapper<byte[]>) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
-
Specify an
InboundMessageMapperto extract message headers embedded into the record data. - setEmbeddedHeadersMapper(OutboundMessageMapper<byte[]>) - Method in class org.springframework.integration.aws.outbound.KinesisMessageHandler
-
Specify a
OutboundMessageMapperfor embedding message headers into the record data together with payload. - setEmbeddedHeadersMapper(OutboundMessageMapper<byte[]>) - Method in class org.springframework.integration.aws.outbound.KplMessageHandler
-
Specify a
OutboundMessageMapperfor embedding message headers into the record data together with payload. - setEndpoint(String) - Method in class org.springframework.integration.aws.support.S3Session
- setEndpoint(String) - Method in class org.springframework.integration.aws.support.S3SessionFactory
- setErrorMessageStrategy(ErrorMessageStrategy) - Method in class org.springframework.integration.aws.outbound.AbstractAwsMessageHandler
- setExecutor(Executor) - Method in class org.springframework.integration.aws.lock.DynamoDbLockRegistry
-
Deprecated.with no-op in favor of internally created unmanaged threads.
- setExecutor(TaskExecutor) - Method in class org.springframework.integration.aws.inbound.kinesis.KclMessageDrivenChannelAdapter
- setExplicitHashKey(String) - Method in class org.springframework.integration.aws.outbound.KinesisMessageHandler
- setExplicitHashKey(String) - Method in class org.springframework.integration.aws.outbound.KplMessageHandler
- setExplicitHashKeyExpression(Expression) - Method in class org.springframework.integration.aws.outbound.KinesisMessageHandler
- setExplicitHashKeyExpression(Expression) - Method in class org.springframework.integration.aws.outbound.KplMessageHandler
- setExplicitHashKeyExpressionString(String) - Method in class org.springframework.integration.aws.outbound.KinesisMessageHandler
- setExplicitHashKeyExpressionString(String) - Method in class org.springframework.integration.aws.outbound.KplMessageHandler
- setExtractReplyPayload(boolean) - Method in class org.springframework.integration.aws.inbound.SnsInboundChannelAdapter
- setFailOnMissingQueue(boolean) - Method in class org.springframework.integration.aws.inbound.SqsMessageDrivenChannelAdapter
- setFailureChannel(MessageChannel) - Method in class org.springframework.integration.aws.outbound.AbstractAwsMessageHandler
-
Set the failure channel.
- setFailureChannelName(String) - Method in class org.springframework.integration.aws.outbound.AbstractAwsMessageHandler
-
Set the failure channel name.
- setFlushDuration(Duration) - Method in class org.springframework.integration.aws.outbound.KplMessageHandler
-
Configure a
Durationhow often to call aKinesisProducer.flush(). - setHandleNotificationStatus(boolean) - Method in class org.springframework.integration.aws.inbound.SnsInboundChannelAdapter
- setHeaderExpressions(Map<String, Expression>) - Method in class org.springframework.integration.aws.inbound.SnsInboundChannelAdapter
- setHeaderMapper(HeaderMapper<H>) - Method in class org.springframework.integration.aws.outbound.AbstractAwsMessageHandler
-
Specify a
HeaderMapperto map outbound headers. - setHeaderMapper(HeaderMapper<Void>) - Method in class org.springframework.integration.aws.outbound.KinesisMessageHandler
-
Unsupported operation.
- setHeaderMapper(HeaderMapper<Void>) - Method in class org.springframework.integration.aws.outbound.KplMessageHandler
-
Unsupported operation.
- setHeaderMapper(HeaderMapper<HttpHeaders>) - Method in class org.springframework.integration.aws.inbound.SnsInboundChannelAdapter
- setHeartbeatPeriod(long) - Method in class org.springframework.integration.aws.lock.DynamoDbLockRegistry
- setIdleBetweenPolls(int) - Method in class org.springframework.integration.aws.inbound.kinesis.KclMessageDrivenChannelAdapter
- setIdleBetweenPolls(int) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
-
The sleep interval in milliseconds used in the main loop between shards polling cycles.
- setIteratorType(ShardIteratorType) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisShardOffset
- setKeyExpression(Expression) - Method in class org.springframework.integration.aws.outbound.S3MessageHandler
-
The SpEL expression to evaluate S3 object key at runtime against
requestMessage. - setLeaseDuration(long) - Method in class org.springframework.integration.aws.lock.DynamoDbLockRegistry
- setListenerMode(ListenerMode) - Method in class org.springframework.integration.aws.inbound.kinesis.KclMessageDrivenChannelAdapter
- setListenerMode(ListenerMode) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
- setLockRegistry(LockRegistry) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
-
Specify a
LockRegistryfor an exclusive access to provided streams. - setLockRenewalTimeout(long) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
-
Configure a timeout in milliseconds to wait for lock on shard renewal.
- setMaxNumberOfMessages(Integer) - Method in class org.springframework.integration.aws.inbound.SqsMessageDrivenChannelAdapter
- setMergeWithDefaultConverters(boolean) - Method in class org.springframework.integration.aws.inbound.SnsInboundChannelAdapter
- setMessageConverter(MessageConverter) - Method in class org.springframework.integration.aws.outbound.KinesisMessageHandler
-
Configure a
MessageConverterfor converting payload tobyte[]for Kinesis record. - setMessageConverter(MessageConverter) - Method in class org.springframework.integration.aws.outbound.KplMessageHandler
-
Configure a
MessageConverterfor converting payload tobyte[]for Kinesis record. - setMessageConverter(MessageConverter) - Method in class org.springframework.integration.aws.outbound.SqsMessageHandler
- setMessageConverters(List<HttpMessageConverter<?>>) - Method in class org.springframework.integration.aws.inbound.SnsInboundChannelAdapter
- setMessageDeduplicationId(String) - Method in class org.springframework.integration.aws.outbound.SqsMessageHandler
- setMessageDeduplicationIdExpression(Expression) - Method in class org.springframework.integration.aws.outbound.SnsMessageHandler
-
The
Expressionto determine the deduplication ID for this message. - setMessageDeduplicationIdExpression(Expression) - Method in class org.springframework.integration.aws.outbound.SqsMessageHandler
- setMessageDeduplicationIdExpressionString(String) - Method in class org.springframework.integration.aws.outbound.SqsMessageHandler
- setMessageDeletionPolicy(SqsMessageDeletionPolicy) - Method in class org.springframework.integration.aws.inbound.SqsMessageDrivenChannelAdapter
- setMessageGroupId(String) - Method in class org.springframework.integration.aws.outbound.SnsMessageHandler
-
A fixed message-group ID to be set for messages sent to an SNS FIFO topic from this handler.
- setMessageGroupId(String) - Method in class org.springframework.integration.aws.outbound.SqsMessageHandler
- setMessageGroupIdExpression(Expression) - Method in class org.springframework.integration.aws.outbound.SnsMessageHandler
-
The
Expressionto determine the message group for messages sent to an SNS FIFO topic from this handler. - setMessageGroupIdExpression(Expression) - Method in class org.springframework.integration.aws.outbound.SqsMessageHandler
- setMessageGroupIdExpressionString(String) - Method in class org.springframework.integration.aws.outbound.SqsMessageHandler
- setMultipartResolver(MultipartResolver) - Method in class org.springframework.integration.aws.inbound.SnsInboundChannelAdapter
- setObjectAclExpression(Expression) - Method in class org.springframework.integration.aws.outbound.S3MessageHandler
-
The SpEL expression to evaluate S3 object ACL at runtime against
requestMessagefor theuploadoperation. - setOutboundHeaderNames(String...) - Method in class org.springframework.integration.aws.support.AbstractMessageAttributesHeaderMapper
-
Provide the header names that should be mapped to a AWS request object attributes (for outbound adapters) from a Spring Integration Message's headers.
- setPartitionKey(String) - Method in class org.springframework.integration.aws.lock.DynamoDbLockRegistry
- setPartitionKey(String) - Method in class org.springframework.integration.aws.outbound.KinesisMessageHandler
- setPartitionKey(String) - Method in class org.springframework.integration.aws.outbound.KplMessageHandler
- setPartitionKeyExpression(Expression) - Method in class org.springframework.integration.aws.outbound.KinesisMessageHandler
- setPartitionKeyExpression(Expression) - Method in class org.springframework.integration.aws.outbound.KplMessageHandler
- setPartitionKeyExpressionString(String) - Method in class org.springframework.integration.aws.outbound.KinesisMessageHandler
- setPartitionKeyExpressionString(String) - Method in class org.springframework.integration.aws.outbound.KplMessageHandler
- setPayloadExpression(Expression) - Method in class org.springframework.integration.aws.inbound.SnsInboundChannelAdapter
- setProgressListener(S3ProgressListener) - Method in class org.springframework.integration.aws.outbound.S3MessageHandler
-
Specify a
S3ProgressListenerfor upload and download operations. - setQueue(String) - Method in class org.springframework.integration.aws.outbound.SqsMessageHandler
- setQueueExpression(Expression) - Method in class org.springframework.integration.aws.outbound.SqsMessageHandler
- setQueueExpressionString(String) - Method in class org.springframework.integration.aws.outbound.SqsMessageHandler
- setQueueStopTimeout(long) - Method in class org.springframework.integration.aws.inbound.SqsMessageDrivenChannelAdapter
- setReadCapacity(long) - Method in class org.springframework.integration.aws.lock.DynamoDbLockRegistry
- setReadCapacity(long) - Method in class org.springframework.integration.aws.metadata.DynamoDbMetadataStore
- setRecordsLimit(int) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
-
The maximum record to poll per on get-records request.
- setRefreshPeriod(long) - Method in class org.springframework.integration.aws.lock.DynamoDbLockRegistry
- setRequestMapping(RequestMapping) - Method in class org.springframework.integration.aws.inbound.SnsInboundChannelAdapter
- setRequestPayloadTypeClass(Class<?>) - Method in class org.springframework.integration.aws.inbound.SnsInboundChannelAdapter
- setReset(boolean) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisShardOffset
- setResourceIdResolver(ResourceIdResolver) - Method in class org.springframework.integration.aws.inbound.SqsMessageDrivenChannelAdapter
- setResourceIdResolver(ResourceIdResolver) - Method in class org.springframework.integration.aws.outbound.S3MessageHandler
-
Specify a
ResourceIdResolverto resolve logical bucket names to physical resource ids. - setResourceIdResolver(ResourceIdResolver) - Method in class org.springframework.integration.aws.outbound.SnsMessageHandler
-
Specify a
ResourceIdResolverto resolve logical topic names to physical resource ids. - setSendTimeout(long) - Method in class org.springframework.integration.aws.outbound.AbstractAwsMessageHandler
- setSendTimeoutExpression(Expression) - Method in class org.springframework.integration.aws.outbound.AbstractAwsMessageHandler
- setSendTimeoutExpressionString(String) - Method in class org.springframework.integration.aws.outbound.AbstractAwsMessageHandler
- setSequenceNumber(String) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisShardOffset
- setSequenceNumberExpression(Expression) - Method in class org.springframework.integration.aws.outbound.KinesisMessageHandler
- setSequenceNumberExpression(Expression) - Method in class org.springframework.integration.aws.outbound.KplMessageHandler
- setSequenceNumberExpressionString(String) - Method in class org.springframework.integration.aws.outbound.KinesisMessageHandler
- setSequenceNumberExpressionString(String) - Method in class org.springframework.integration.aws.outbound.KplMessageHandler
- setShard(String) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisShardOffset
- setShardListFilter(Function<List<Shard>, List<Shard>>) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
-
Specify a
Function<List<Shard>, List<Shard>>to filter the shards which will be read from. - setSortKey(String) - Method in class org.springframework.integration.aws.lock.DynamoDbLockRegistry
-
Specify a value for the sort key attribute of the lock item.
- setSortKeyName(String) - Method in class org.springframework.integration.aws.lock.DynamoDbLockRegistry
-
Specify a name of the table attribute which is used as a sort key.
- setStartTimeout(int) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
- setStatusCodeExpression(Expression) - Method in class org.springframework.integration.aws.inbound.SnsInboundChannelAdapter
- setStream(String) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisShardOffset
- setStream(String) - Method in class org.springframework.integration.aws.outbound.KinesisMessageHandler
- setStream(String) - Method in class org.springframework.integration.aws.outbound.KplMessageHandler
- setStreamExpression(Expression) - Method in class org.springframework.integration.aws.outbound.KinesisMessageHandler
- setStreamExpression(Expression) - Method in class org.springframework.integration.aws.outbound.KplMessageHandler
- setStreamExpressionString(String) - Method in class org.springframework.integration.aws.outbound.KinesisMessageHandler
- setStreamExpressionString(String) - Method in class org.springframework.integration.aws.outbound.KplMessageHandler
- setStreamInitialSequence(InitialPositionInStream) - Method in class org.springframework.integration.aws.inbound.kinesis.KclMessageDrivenChannelAdapter
- setStreamInitialSequence(KinesisShardOffset) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
- setSubject(String) - Method in class org.springframework.integration.aws.outbound.SnsMessageHandler
- setSubjectExpression(Expression) - Method in class org.springframework.integration.aws.outbound.SnsMessageHandler
- setSync(boolean) - Method in class org.springframework.integration.aws.outbound.AbstractAwsMessageHandler
- setTaskExecutor(AsyncTaskExecutor) - Method in class org.springframework.integration.aws.inbound.SqsMessageDrivenChannelAdapter
- setTimestamp(Date) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisShardOffset
- setTimeToLive(int) - Method in class org.springframework.integration.aws.metadata.DynamoDbMetadataStore
-
Configure a period in seconds for items expiration.
- setTopicArn(String) - Method in class org.springframework.integration.aws.outbound.SnsMessageHandler
- setTopicArnExpression(Expression) - Method in class org.springframework.integration.aws.outbound.SnsMessageHandler
- setUploadMetadataProvider(S3MessageHandler.UploadMetadataProvider) - Method in class org.springframework.integration.aws.outbound.S3MessageHandler
-
Specify an
ObjectMetadatacallback to populate the metadata for upload operation, e.g. - setVisibilityTimeout(Integer) - Method in class org.springframework.integration.aws.inbound.SqsMessageDrivenChannelAdapter
- setWaitTimeOut(Integer) - Method in class org.springframework.integration.aws.inbound.SqsMessageDrivenChannelAdapter
- setWorkerId(String) - Method in class org.springframework.integration.aws.inbound.kinesis.KclMessageDrivenChannelAdapter
-
Sets the worker identifier used to distinguish different workers/processes of a Kinesis application.
- setWriteCapacity(long) - Method in class org.springframework.integration.aws.lock.DynamoDbLockRegistry
- setWriteCapacity(long) - Method in class org.springframework.integration.aws.metadata.DynamoDbMetadataStore
- SHARD - Static variable in class org.springframework.integration.aws.support.AwsHeaders
-
The "aws_shard" header to represent Kinesis shardId.
- SNS_MESSAGE_TYPE - Static variable in class org.springframework.integration.aws.support.AwsHeaders
-
The "aws_snsMessageType" header for SNS message type.
- SNS_REF - Static variable in class org.springframework.integration.aws.config.xml.AwsParserUtils
-
The 'sns' reference attribute name.
- SnsBodyBuilder - Class in org.springframework.integration.aws.support
-
An utility class to simplify an SNS Message body building.
- SnsHeaderMapper - Class in org.springframework.integration.aws.support
-
The
AbstractMessageAttributesHeaderMapperimplementation for the mapping from headers to SNS message attributes. - SnsHeaderMapper() - Constructor for class org.springframework.integration.aws.support.SnsHeaderMapper
- SnsInboundChannelAdapter - Class in org.springframework.integration.aws.inbound
-
The
HttpRequestHandlingMessagingGatewayextension for the Amazon WS SNS HTTP(S) endpoints. - SnsInboundChannelAdapter(AmazonSNS, String...) - Constructor for class org.springframework.integration.aws.inbound.SnsInboundChannelAdapter
- SnsInboundChannelAdapterParser - Class in org.springframework.integration.aws.config.xml
-
The parser for the
<int-aws:sns-inbound-channel-adapter>. - SnsInboundChannelAdapterParser() - Constructor for class org.springframework.integration.aws.config.xml.SnsInboundChannelAdapterParser
- SnsMessageHandler - Class in org.springframework.integration.aws.outbound
-
The
AbstractAwsMessageHandlerimplementation to send SNS Notifications (AmazonSNSAsync.publishAsync(PublishRequest)) to the providedtopicArn(or evaluated at runtime againstMessage). - SnsMessageHandler(AmazonSNSAsync) - Constructor for class org.springframework.integration.aws.outbound.SnsMessageHandler
- SnsOutboundChannelAdapterParser - Class in org.springframework.integration.aws.config.xml
-
The parser for the
<int-aws:sns-outbound-channel-adapter>. - SnsOutboundChannelAdapterParser() - Constructor for class org.springframework.integration.aws.config.xml.SnsOutboundChannelAdapterParser
- SQS_REF - Static variable in class org.springframework.integration.aws.config.xml.AwsParserUtils
-
The 'sqs' reference attribute name.
- SqsHeaderMapper - Class in org.springframework.integration.aws.support
-
The
AbstractMessageAttributesHeaderMapperimplementation for the mapping from headers to SQS message attributes. - SqsHeaderMapper() - Constructor for class org.springframework.integration.aws.support.SqsHeaderMapper
- SqsMessageDrivenChannelAdapter - Class in org.springframework.integration.aws.inbound
-
The
MessageProducerSupportimplementation for the Amazon SQSreceiveMessage. - SqsMessageDrivenChannelAdapter(AmazonSQSAsync, String...) - Constructor for class org.springframework.integration.aws.inbound.SqsMessageDrivenChannelAdapter
- SqsMessageDrivenChannelAdapterParser - Class in org.springframework.integration.aws.config.xml
-
The parser for the
<int-aws:sqs-message-driven-channel-adapter>. - SqsMessageDrivenChannelAdapterParser() - Constructor for class org.springframework.integration.aws.config.xml.SqsMessageDrivenChannelAdapterParser
- SqsMessageHandler - Class in org.springframework.integration.aws.outbound
-
The
AbstractMessageHandlerimplementation for the Amazon SQSsendMessage. - SqsMessageHandler(AmazonSQSAsync) - Constructor for class org.springframework.integration.aws.outbound.SqsMessageHandler
- SqsMessageHandler(AmazonSQSAsync, ResourceIdResolver) - Constructor for class org.springframework.integration.aws.outbound.SqsMessageHandler
- SqsMessageHandler(AmazonSQSAsync, DestinationResolver<?>) - Constructor for class org.springframework.integration.aws.outbound.SqsMessageHandler
- SqsOutboundChannelAdapterParser - Class in org.springframework.integration.aws.config.xml
-
The parser for the
<int-aws:sqs-outbound-channel-adapter>. - SqsOutboundChannelAdapterParser() - Constructor for class org.springframework.integration.aws.config.xml.SqsOutboundChannelAdapterParser
- start() - Method in class org.springframework.integration.aws.outbound.KplMessageHandler
- start(String) - Method in class org.springframework.integration.aws.inbound.SqsMessageDrivenChannelAdapter
- startConsumer(String, String) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
- stop() - Method in class org.springframework.integration.aws.outbound.KplMessageHandler
- stop(String) - Method in class org.springframework.integration.aws.inbound.SqsMessageDrivenChannelAdapter
- stopConsumer(String, String) - Method in class org.springframework.integration.aws.inbound.kinesis.KinesisMessageDrivenChannelAdapter
- STREAM - Static variable in class org.springframework.integration.aws.support.AwsHeaders
-
The "aws_stream" header for sending data to Kinesis.
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
KinesisMessageHandler.setMessageConverter(org.springframework.messaging.converter.MessageConverter)