У меня есть эта интересная проблема, и я был бы рад получить любую помощь
Когда я пытаюсь создать очередь, клиент AmazonSQS создает очередь, но когда я пытаюсь отправлять сообщения, он бросает это исключение
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
@TestMethodOrder(MethodOrderer.OrderAnnotation.class)
@Testcontainers
public class AwsSqsTest {
private static final Network network = Network.newNetwork();
@Container
static final LocalStackContainer localStack = new LocalStackContainer(
DockerImageName.parse("localstack/localstack:latest"))
.withNetwork(network)
.withNetworkAliases("notthis", "localstack")
.withServices(Service.SQS);
static AmazonSQS amazonSQSClient;
final String SqsURL = "http://sqs.us-east-1.localstack:4566/000000000000/";
@BeforeAll
static void beforeAll() {
String localStackEndpoint = localStack.getEndpoint().toString();
amazonSQSClient = amazonSQS(
localStack.getAccessKey(),
localStack.getSecretKey(),
localStack.getRegion(),
localStackEndpoint
);
}
static AmazonSQS amazonSQS(String accessKey, String secretKey, String region, String stackEndpoint) {
var basicAWSCredentials = new BasicAWSCredentials(accessKey, secretKey);
var endpointConfiguration = new AwsClientBuilder.EndpointConfiguration(stackEndpoint, region);
var credentialsProvider = new AWSStaticCredentialsProvider(basicAWSCredentials);
return AmazonSQSClientBuilder.standard()
.withEndpointConfiguration(endpointConfiguration)
.withCredentials(credentialsProvider)
.build();
}
@Test
@Order(1)
void testSQSClientInitialization() {
assertNotNull(amazonSQSClient);
}
@ParameterizedTest
@ValueSource(strings = {"news", "trends"})
@Order(2)
void createQueueTest(String queueName) {
amazonSQSClient.createQueue(queueName);
var queues = amazonSQSClient.listQueues().getQueueUrls();
assertTrue(queues.contains(SqsURL + queueName));
}
@ParameterizedTest
@MethodSource("saveToQueue")
@Order(3)
void saveToQueue(String queueName, String data) {
String url = SqsURL + queueName;
amazonSQSClient.sendMessage(url, data);
var messages = amazonSQSClient.receiveMessage(url);
assertEquals(data, messages.getMessages().getFirst().getBody());
}
Stream saveToQueue() {
return Stream.of(
arguments("trends", "{}"),
arguments("news", "{}")
);
}
}
< /code>
журналы: < /p>
Unable to execute HTTP request: sqs.us-east-1.localstack
com.amazonaws.SdkClientException: Unable to execute HTTP request: sqs.us-east-1.localstack
...
Caused by: java.net.UnknownHostException: sqs.us-east-1.localstack
...
sqs.us-east-1.localstack
java.net.UnknownHostException: sqs.us-east-1.localstack
...
< /code>
< /code>
enter image description here
I tried to use other implementations of AmazonSQS and use docs, and nothing helped;(
Подробнее здесь: https://stackoverflow.com/questions/783 ... http-reque
LocalStack TestContainer + AWS SQS + Spring Boot -> Невозможно выполнить HTTP -запрос ⇐ JAVA
-
- Похожие темы
- Ответы
- Просмотры
- Последнее сообщение