elasticmq-spring-config.java

@Primary
  @Bean("AwsSqs")
  public AmazonSQSAsync createAWSSQSClient() {
    String endpoint = "http://localhost:9324";
    String region = "elasticmq";
    String accessKey = "x";
    String secretKey = "x";

    AmazonSQSAsync client =
        AmazonSQSAsyncClientBuilder.standard()
            .withCredentials(
                new AWSStaticCredentialsProvider(new BasicAWSCredentials(accessKey, secretKey)))
            .withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration(endpoint, region))
            .build();

    String queueUrl = client.getQueueUrl("AOD-MQttDropConnQueue").getQueueUrl();
    client.sendMessage(queueUrl, "mqtt-client-id");

    return client;
  }