Package org.springframework.cloud.fn.consumer.s3

Class AwsS3ConsumerConfiguration

java.lang.Object

org.springframework.cloud.fn.consumer.s3.AwsS3ConsumerConfiguration

@Configuration(proxyBeanMethods=false)
@EnableConfigurationProperties(AwsS3ConsumerProperties.class)
public class AwsS3ConsumerConfiguration
extends Object

Constructor Summary

Constructors

Constructor	Description
AwsS3ConsumerConfiguration()

Method Summary

Modifier and Type	Method	Description
MessageHandler	amazonS3MessageHandler(software.amazon.awssdk.transfer.s3.S3TransferManager s3TransferManager, AwsS3ConsumerProperties s3ConsumerProperties, BeanFactory beanFactory, BiConsumer<software.amazon.awssdk.services.s3.model.PutObjectRequest.Builder,Message<?>> uploadMetadataProvider)
Consumer<Message<?>>	s3Consumer(org.springframework.integration.dsl.IntegrationFlow s3ConsumerFlow)
org.springframework.integration.dsl.IntegrationFlow	s3ConsumerFlow(software.amazon.awssdk.transfer.s3.progress.TransferListener transferListener, MessageHandler amazonS3MessageHandler)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AwsS3ConsumerConfiguration

public AwsS3ConsumerConfiguration()

Method Details

s3Consumer

@Bean
public Consumer<Message<?>> s3Consumer(org.springframework.integration.dsl.IntegrationFlow s3ConsumerFlow)

s3ConsumerFlow

@Bean
public org.springframework.integration.dsl.IntegrationFlow s3ConsumerFlow(@Nullable
 software.amazon.awssdk.transfer.s3.progress.TransferListener transferListener,
 MessageHandler amazonS3MessageHandler)

amazonS3MessageHandler

@Bean
public MessageHandler amazonS3MessageHandler(software.amazon.awssdk.transfer.s3.S3TransferManager s3TransferManager,
 AwsS3ConsumerProperties s3ConsumerProperties,
 BeanFactory beanFactory,
 @Nullable
 BiConsumer<software.amazon.awssdk.services.s3.model.PutObjectRequest.Builder,Message<?>> uploadMetadataProvider)