Фабричный метод 'stackResourceRegistryFactoryBean' вызвал исключение; вложенное исключение java .lang.IllegalArgumentException: не определен допустимый идентификатор экземпляра - PullRequest
Новая
       9

Фабричный метод 'stackResourceRegistryFactoryBean' вызвал исключение; вложенное исключение java .lang.IllegalArgumentException: не определен допустимый идентификатор экземпляра

0 голосов
/ 26 февраля 2020

Я пытаюсь создать приложение Spring Boot, которое отправляет и получает сообщения в очередь. Я использую AWS SQS для очередей. Но во время работы моего приложения я получаю ошибку ниже, и мой код указан ниже.

enter image description here

SQSConfig. java

package com.sqs.Config;

import com.amazonaws.auth.AWSStaticCredentialsProvider;
import com.amazonaws.auth.BasicAWSCredentials;
import com.amazonaws.services.sqs.AmazonSQSAsync;
import com.amazonaws.services.sqs.AmazonSQSAsyncClientBuilder;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.aws.messaging.core.QueueMessagingTemplate;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class SQSConfig {

    @Value("${cloud.aws.region.static}")
    private String region;

    @Value("${cloud.aws.credentials.access-key}")
    private String awsAccessKey;

    @Value("${cloud.aws.credentials.secret-key}")
    private String awsSecretKey;

    @Bean
    public QueueMessagingTemplate queueMessagingTemplate() {
        return new QueueMessagingTemplate(amazonSQSAsync());
    }

    public AmazonSQSAsync amazonSQSAsync() {
        return AmazonSQSAsyncClientBuilder.standard().withRegion(region)
                .withCredentials(new AWSStaticCredentialsProvider(new BasicAWSCredentials(awsAccessKey, awsSecretKey)))
                .build();
    }
}

SQSController. java

package com.sqs.controller;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.aws.messaging.core.QueueMessagingTemplate;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/sqs")
public class SQSController {

    private static final Logger LOG = LoggerFactory.getLogger(SQSController.class);

    @Autowired
    private QueueMessagingTemplate queueMessagingTemplate;

    @Value("${cloud.aws.end-point.uri}")
    private String sqsEndPointURL;

    @GetMapping
    public void sendMessage() {
        queueMessagingTemplate.send(sqsEndPointURL, MessageBuilder.withPayload("My first queue message").build());
    }
}

application.properties 

server.port=8080

cloud.aws.region.static=
cloud.aws.region.auto=false
cloud.aws.credentials.access-key=
cloud.aws.credentials.secret-key=
cloud.aws.end-point.uri=

Я не смог найти, какую ошибку я совершил. Нужно решение.

Заранее спасибо.

...