@Test void receive_withDefaultDestination_useDefaultDestination() { AmazonSQSAsync amazonSqs = createAmazonSqs(); QueueMessagingTemplate queueMessagingTemplate = new QueueMessagingTemplate( amazonSqs); queueMessagingTemplate.setDefaultDestinationName("my-queue"); queueMessagingTemplate.receive(); ArgumentCaptor<ReceiveMessageRequest> sendMessageRequestArgumentCaptor = ArgumentCaptor .forClass(ReceiveMessageRequest.class); verify(amazonSqs).receiveMessage(sendMessageRequestArgumentCaptor.capture()); assertThat(sendMessageRequestArgumentCaptor.getValue().getQueueUrl()) .isEqualTo("https: }
@Override public Message<?> receive() throws MessagingException { return receive(getRequiredDefaultDestination()); }
QueueMessagingTemplate extends AbstractMessageChannelMessagingSendingTemplate<QueueMessageChannel> implements DestinationResolvingMessageReceivingOperations<QueueMessageChannel> { @Override public Message<?> receive() throws MessagingException { return receive(getRequiredDefaultDestination()); } }
QueueMessagingTemplate extends AbstractMessageChannelMessagingSendingTemplate<QueueMessageChannel> implements DestinationResolvingMessageReceivingOperations<QueueMessageChannel> { @Override public Message<?> receive() throws MessagingException { return receive(getRequiredDefaultDestination()); } QueueMessagingTemplate(AmazonSQSAsync amazonSqs);  QueueMessagingTemplate(AmazonSQSAsync amazonSqs,
			ResourceIdResolver resourceIdResolver);  QueueMessagingTemplate(AmazonSQSAsync amazonSqs,
			ResourceIdResolver resourceIdResolver, MessageConverter messageConverter);  QueueMessagingTemplate(AmazonSQSAsync amazonSqs,
			DestinationResolver<String> destinationResolver,
			MessageConverter messageConverter); }
QueueMessagingTemplate extends AbstractMessageChannelMessagingSendingTemplate<QueueMessageChannel> implements DestinationResolvingMessageReceivingOperations<QueueMessageChannel> { @Override public Message<?> receive() throws MessagingException { return receive(getRequiredDefaultDestination()); } QueueMessagingTemplate(AmazonSQSAsync amazonSqs);  QueueMessagingTemplate(AmazonSQSAsync amazonSqs,
			ResourceIdResolver resourceIdResolver);  QueueMessagingTemplate(AmazonSQSAsync amazonSqs,
			ResourceIdResolver resourceIdResolver, MessageConverter messageConverter);  QueueMessagingTemplate(AmazonSQSAsync amazonSqs,
			DestinationResolver<String> destinationResolver,
			MessageConverter messageConverter); @Override Message<?> receive(); @Override Message<?> receive(QueueMessageChannel destination); @Override T receiveAndConvert(Class<T> targetClass); @SuppressWarnings("unchecked") @Override T receiveAndConvert(QueueMessageChannel destination, Class<T> targetClass); @Override Message<?> receive(String destinationName); @Override T receiveAndConvert(String destinationName, Class<T> targetClass); }
QueueMessagingTemplate extends AbstractMessageChannelMessagingSendingTemplate<QueueMessageChannel> implements DestinationResolvingMessageReceivingOperations<QueueMessageChannel> { @Override public Message<?> receive() throws MessagingException { return receive(getRequiredDefaultDestination()); } QueueMessagingTemplate(AmazonSQSAsync amazonSqs);  QueueMessagingTemplate(AmazonSQSAsync amazonSqs,
			ResourceIdResolver resourceIdResolver);  QueueMessagingTemplate(AmazonSQSAsync amazonSqs,
			ResourceIdResolver resourceIdResolver, MessageConverter messageConverter);  QueueMessagingTemplate(AmazonSQSAsync amazonSqs,
			DestinationResolver<String> destinationResolver,
			MessageConverter messageConverter); @Override Message<?> receive(); @Override Message<?> receive(QueueMessageChannel destination); @Override T receiveAndConvert(Class<T> targetClass); @SuppressWarnings("unchecked") @Override T receiveAndConvert(QueueMessageChannel destination, Class<T> targetClass); @Override Message<?> receive(String destinationName); @Override T receiveAndConvert(String destinationName, Class<T> targetClass);  }