How to use SQSSource from behind proxy?

Akka Libraries Akka Streams & Alpakka
1

How can I use Alpakka AWS SQS connector from behind a proxy?

This is the sample code that I have

ActorSystem system = ActorSystem.create();
ActorMaterializer materializer = ActorMaterializer.create(system);

SqsSource.create(QUEUE_URL,
        SqsSourceSettings.Defaults(),
        SqsAsyncClient.builder()
                .build())
        .runForeach(message -> System.out.println(message.body()), materializer);
2

Hi @nytins,

Alpakka SQS doesn’t have specific support for Proxies.
It should be possible though to use Akka HTTP’s proxy support and put an amended Akka HTTP client in place as this example does with using Netty.

Alpakka SQS uses aws-spi-akka-http to implement the SdkAsyncHttpClient interface. In that library would be a great place to add preconfigured proxy support.

Cheers,
Enno.