clientconfiguration information when connecting through proxy

[iamiddy]

Is there a way to Set optional proxy details on com.amazonaws.ClientConfiguration connecting through a proxy, am developing with spring-cloud-aws-version 1.0.0.RELEASE, spring-boot-version 1.2.2.RELEASE in spring-cloud-aws-autoconfigure. I want to be able to configure proxy details as follows

SO question here

[aemruli]

Hello @iamiddy currently it is not possible to specify an own client configuration. You can create your own custom aws service instance (e.g. AmazonEC2Client) and inject the client configuration there.

We will add support to configure the ClientConfiguration soon.

[iamiddy]

Hello @aemruli I went ahead and created a custom AmazonSQSClient with ClientConfiguration thanks for the tip , and passed it to the QueueMessagingTemplate , it works great for sending Messages to SQS queues by QueueMessagingTemplate through the proxy, however the issues comes to SQS Listener @MessageMapping, how can I make it's MessageHendler to use the custom AmazonSQSClient created above?

As it is right now the below code doesn't know about my proxy and ClientConfiguration in general

  @MessageMapping(QUEUE_NAME)
    private void receiveMessage(MessageToProcess message,) {
        LOG.debug("Received SQS message {}", message);
        }

I know that I can use QueueMessagingTemplate to receive the messages, but I would rather leverage what @MessageMapping has to offer.

Thank you in advance for yet another tip

[alainsahli]

Hi @iamiddy

If you are java config then you can achieve this by creating a SimpleMessageListenerContainerFactory bean that sets your custom client:

@Bean
public SimpleMessageListenerContainerFactory simpleMessageListenerContainerFactory() {
    SimpleMessageListenerContainerFactory factory = new SimpleMessageListenerContainerFactory();        
    factory.setAmazonSqs(yourCustomClient);

    return factory;
}

If you are using the @sendto annotation then you must also define the client of the send to messaging template:

@Bean
public QueueMessageHandlerFactory queueMessageHandlerFactory() {
    QueueMessageHandlerFactory factory = new QueueMessageHandlerFactory();
    factory.setAmazonSqs(yourCustomClient);

    return factory;
}

You can achieve the same with XML config:

<aws-messaging:annotation-driven-queue-listener amazon-sqs="yourCustomClient" send-to-message-template="messageTemplateThatUsersYourCustomClient" />

[iamiddy]

Thanks @alainsahli this worked out well

[stanislasbonifetto]

Hi, do you have some example how to configure AmazonS3Client in spring cloud when it is behind a proxy server?

[iamiddy]

There you go @stanislasbonifetto

 @Configuration
  @Profile("local")
  protected static class LocalAWSConfiguration {
    @Value("${proxy.host}")
    private String proxyHost;

    @Value("${proxy.port}")
    private int proxyPort;

    @Value("${proxy.user.name}")
    private String proxyUserName;

    @Value("${proxy.user.password}")
    private String proxyPassword;



    @Bean(name="amazonSQS")
    public AmazonSQSAsyncClient amazonSQSAsyncClient(AWSCredentialsProvider awsCredentialsProvider){
        return new AmazonSQSAsyncClient(awsCredentialsProvider,clientConfiguration());
    }

    @Bean(name="mazonS3Clent")
    public AmazonS3 amazonS3Client(AWSCredentialsProvider awsCredentialsProvider){
        return new AmazonS3Client(awsCredentialsProvider,clientConfiguration());
    }

    @Bean ClientConfiguration clientConfiguration(){
        ClientConfiguration clientConfiguration= new ClientConfiguration();
        clientConfiguration.setProxyHost(proxyHost);
        clientConfiguration.setProxyPort(proxyPort);
        clientConfiguration.setProxyUsername(proxyUserName);
        clientConfiguration.setProxyPassword(proxyPassword);

        return clientConfiguration;  
    }

[stanislasbonifetto]

Thank @iamiddy your code clarifies me how i need to implement.
Just to precise, i have corrected the name of the bean from "amazonS3Clent" amazonS3 to "amazonS3", so the SimpleStorageResource use it.

Below you can see my implementation:

public class AmazonS3ProxyConfiguration implements EnvironmentAware {

    private static final Logger LOG = LoggerFactory.getLogger(AmazonS3ProxyConfiguration.class);    
    private static final String PROPERTY_PREFIX = "cloud.aws.proxy";
    private static final String PROXY_HOST_PROPERTY_NAME = "host";
    private static final String PROXY_PORT_PROPERTY_NAME = "port";
    private static final String PROXY_USER_NAME_PROPERTY_NAME = "user.name";
    private static final String PROXY_PASSWORD_PROPERTY_NAME = "user.password";

    protected Environment environment;

    @Bean(name = "amazonS3")
    public AmazonS3 amazonS3Client(AWSCredentialsProvider awsCredentialsProvider) {
        AmazonS3 s3 = new AmazonS3Client(awsCredentialsProvider,clientConfiguration());
        return s3;
    }

    @Bean
    ClientConfiguration clientConfiguration() {

        ClientConfiguration clientConfiguration = new ClientConfiguration();
        clientConfiguration.setProtocol(Protocol.HTTPS);

        if (containsProperty(PROXY_HOST_PROPERTY_NAME)) {
            clientConfiguration.setProxyHost(getProperty(PROXY_HOST_PROPERTY_NAME));
        }
        if (containsProperty(PROXY_PORT_PROPERTY_NAME)) {
            clientConfiguration.setProxyPort(Integer.parseInt(getProperty(PROXY_PORT_PROPERTY_NAME)));
        }
        if (containsProperty(PROXY_USER_NAME_PROPERTY_NAME)) {
            clientConfiguration.setProxyUsername(getProperty(PROXY_USER_NAME_PROPERTY_NAME));
        }
        if (containsProperty(PROXY_PASSWORD_PROPERTY_NAME)) {
            clientConfiguration.setProxyPassword(getProperty(PROXY_PASSWORD_PROPERTY_NAME));
        }

        return clientConfiguration;
    }


    private boolean containsProperty(String name) {
        return this.environment.containsProperty(PROPERTY_PREFIX + "." + name);
    }

    private String getProperty(String name) {
        return this.environment.getProperty(PROPERTY_PREFIX + "." + name);
    }

    @Override
    public void setEnvironment(Environment environment) {
        this.environment = environment;
    }
}