Сбой приложения Spring Boot при запуске при использовании @SqsListener

Я пытаюсь реализовать прослушиватель SQS в своем приложении Spring Boot (Kotlin). Я использую spring-cloud-aws-messaging. Вот статья, которая прошла меня через реализацию.

Проблема: приложение не может запуститься.

Журналы говорят:

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'simpleMessageListenerContainer' defined in class path resource [org/springframework/cloud/aws/messaging/config/annotation/SqsConfiguration.class]: Invocation of init method failed; nested exception is com.amazonaws.services.sqs.model.AmazonSQSException: null (Service: AmazonSQS; Status Code: 500; Error Code: 500 ; Request ID: null)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1803)
...

Очень прошу помощи :)

docker-compose.yml

version: "2"

services:
  localstack:
    image: localstack/localstack:0.11.5
    ports:
      - "8085:8080"
      - "4569-4576:4569-4576"
    environment:
      - SERVICES=sqs:4573
      - DOCKER_HOST=unix:///var/run/docker.sock
      - DEFAULT_REGION=eu-west-1
      - DATA_DIR=/tmp/localstack/data
    volumes:
      - ./docker/dev/localstack-init-scripts:/docker-entrypoint-initaws.d

docker-entrypoint-initaws.sh

#!/usr/bin/env bash
set -x
awslocal sqs create-queue --queue-name my-queue-name
set +x

InfrastructureConfiguration.kt

@EnableSqs
class InfrastructureConfiguration(...) {
  @Primary
  @Bean
  fun amazonSQSAsync(): AmazonSQSAsync {
    val credentials: AWSCredentials = BasicAWSCredentials("accessKey", "secretKey")

    return AmazonSQSAsyncClientBuilder
      .standard()
      .withEndpointConfiguration(
        AwsClientBuilder.EndpointConfiguration(
          "http://localstack:4573",
          Regions.fromName("eu-west-1").toString()
      )
    ).withCredentials(AWSStaticCredentialsProvider(credentials)).build()
  }

  @Primary
  @Bean
  fun simpleMessageListenerContainerFactory(amazonSQSAsync: AmazonSQSAsync): 
  SimpleMessageListenerContainerFactory {
    val factory = SimpleMessageListenerContainerFactory()
    factory.setAmazonSqs(amazonSQSAsync)
    factory.setAutoStartup(false)
    factory.setMaxNumberOfMessages(10)
    factory.setWaitTimeOut(20)
    return factory
  }
}

AmazonSqs.kt

val logger = KotlinLogging.logger {}

@Lazy
@Component
class AmazonSqs {
  companion object {
    const val QUEUE_NAME = "my-queue-name"
  }

  @SqsListener(QUEUE_NAME)
  fun receiveMessage(message: String?) {
    logger.info("Received message: {}")
  }
}

person wiktorkudej    schedule 28.09.2020    source источник
comment
Можете ли вы поделиться своим полным кодом в github ›   -  person gtiwari333    schedule 29.09.2020


Ответы (1)


Проблема кроется в локальном стеке. Я снова запустил docker-compose и заметил, что порт 4573 устарел.

localstack_1  | Starting edge router (https port 4566)...
localstack_1  | Starting mock SQS service on http ports 4566 (recommended) and 
4573 (deprecated)...

Решение состоит в том, чтобы открыть порт 4566 в docker-compose и использовать его вместо этого.

ports:
  - "8085:8080"
  - "4566-4576:4566-4576"
person wiktorkudej    schedule 29.09.2020