Spring Cloud-SQS-La cola especificada no existe para esta versión de wsdl

amazon-web-services annotations

Question

Estoy intentando que Spring Cloud funcione con la mensajería mediante la configuración automática.

Mi archivo de propiedades contiene:

cloud.aws.credentials.accessKey=xxxxxxxxxx
cloud.aws.credentials.secretKey=xxxxxxxxxx
cloud.aws.region.static=us-west-2

Mi clase de configuración es la siguiente:

@EnableSqs
@ComponentScan
@EnableAutoConfiguration
public class Application {
public static void main(String[] args) throws Exception {
SpringApplication.run(Application.class, args);
}
}

Mi clase de oyente:

@RestController public class OrderListener {

@MessageMapping("orderQueue")
public void orderListener(Order order){
System.out.println("Order Name " + order.getName());
System.out.println("Order Url" + order.getUrl());
}
}

Sin embargo, cuando corro esto. Obtuve el siguiente error:

org.springframework.context.ApplicationContextException: Failed to start bean ''simpleMessageListenerContainer''; nested exception is org.springframework.messaging.core.DestinationResolutionException: The specified queue does not exist for this wsdl version. (Service: AmazonSQS; Status Code: 400; Error Code: AWS.SimpleQueueService.NonExistentQueue; Request ID: cc8cb199-be88-5993-bd58-fca3c9f17110); nested exception is com.amazonaws.services.sqs.model.QueueDoesNotExistException: The specified queue does not exist for this wsdl version. (Service: AmazonSQS; Status Code: 400; Error Code: AWS.SimpleQueueService.NonExistentQueue; Request ID: cc8cb199-be88-5993-bd58-fca3c9f17110)
at org.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:176)
at org.springframework.context.support.DefaultLifecycleProcessor.access$200(DefaultLifecycleProcessor.java:51)
at org.springframework.context.support.DefaultLifecycleProcessor$LifecycleGroup.start(DefaultLifecycleProcessor.java:346)
at org.springframework.context.support.DefaultLifecycleProcessor.startBeans(DefaultLifecycleProcessor.java:149)
at org.springframework.context.support.DefaultLifecycleProcessor.onRefresh(DefaultLifecycleProcessor.java:112)
at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:770)
at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.finishRefresh(EmbeddedWebApplicationContext.java:140)
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:483)
at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.refresh(EmbeddedWebApplicationContext.java:118)
at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:691)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:321)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:961)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:950)
at com.releasebot.processor.Application.main(Application.java:40)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:483)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:134)
Caused by: org.springframework.messaging.core.DestinationResolutionException: The specified queue does not exist for this wsdl version. (Service: AmazonSQS; Status Code: 400; Error Code: AWS.SimpleQueueService.NonExistentQueue; Request ID: cc8cb199-be88-5993-bd58-fca3c9f17110); nested exception is com.amazonaws.services.sqs.model.QueueDoesNotExistException: The specified queue does not exist for this wsdl version. (Service: AmazonSQS; Status Code: 400; Error Code: AWS.SimpleQueueService.NonExistentQueue; Request ID: cc8cb199-be88-5993-bd58-fca3c9f17110)
at org.springframework.cloud.aws.messaging.support.destination.DynamicQueueUrlDestinationResolver.resolveDestination(DynamicQueueUrlDestinationResolver.java:81)
at org.springframework.cloud.aws.messaging.support.destination.DynamicQueueUrlDestinationResolver.resolveDestination(DynamicQueueUrlDestinationResolver.java:37)
at org.springframework.messaging.core.CachingDestinationResolverProxy.resolveDestination(CachingDestinationResolverProxy.java:88)
at org.springframework.cloud.aws.messaging.listener.AbstractMessageListenerContainer.start(AbstractMessageListenerContainer.java:300)
at org.springframework.cloud.aws.messaging.listener.SimpleMessageListenerContainer.start(SimpleMessageListenerContainer.java:38)
at org.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:173)
... 18 common frames omitted

¿Alguien más ha encontrado esto? Cualquier ayuda sería apreciada grandemente

Answer 1

Este error significa que la cola especificada orderQueue no existe en la región us-west-2 . Solo créelo y debería funcionar.

Por cierto, no es necesario agregar @EnableSqs cuando se usa @EnableAutoConfiguration .

Answer 2

He afectado el mismo problema al intentar obtener-queue-url usando la línea de comandos. Mira lo que tenía:

 A client error (AWS.SimpleQueueService.NonExistentQueue) occurred when calling the GetQueueUrl operation: The specified queue does not exist for this wsdl version.

Tuve que ejecutar esto:

$aws configure

Y bajo el mensaje ''Nombre de región predeterminado [...]:'' ingresó la región a la que pertenece mi cola. Entonces el error desapareció.

Así que revisa tus configuraciones;)

Answer 3

La respuesta de Alain es correcta. Este error indica que la cola no existe en la región us-west-2. Una de las razones podría ser que el SDK Java de AWS usa us-east-1 como la región predeterminada. De la documentación de AWS http://docs.aws.amazon.com/java-sdk/latest/developer-guide/java-dg-region-selection.html

AWS SDK para Java usa us-east-1 como la región predeterminada si no especifica una región en su código. Sin embargo, la consola de administración de AWS usa us-west-2 como su valor predeterminado. Por lo tanto, cuando utilice la consola de administración de AWS junto con su desarrollo, asegúrese de especificar la misma región tanto en su código como en la consola.

Puede establecer la región o el punto final específicamente en el cliente utilizando los setRegion() o setEndpoint() del objeto AmazonSQSClient . Consulte http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/sqs/AmazonSQS.html#setEndpoint-java.lang.String-

Para obtener una lista de regiones y puntos finales, consulte http://docs.aws.amazon.com/general/latest/gr/rande.html#sqs_region

Answer 4

Trate de usar la URL de la cola, en lugar del nombre.