@Test void testWithDefaultTaskExecutorAndNoBeanName() throws Exception { SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(); container.setAmazonSqs(mock(AmazonSQSAsync.class, withSettings().stubOnly())); container.setMessageHandler(mock(QueueMessageHandler.class)); container.afterPropertiesSet(); ThreadPoolTaskExecutor taskExecutor = (ThreadPoolTaskExecutor) container .getTaskExecutor(); assertThat(taskExecutor).isNotNull(); assertThat(taskExecutor.getThreadNamePrefix()) .isEqualTo(SimpleMessageListenerContainer.class.getSimpleName() + "-"); }
protected AsyncTaskExecutor getTaskExecutor() { return this.taskExecutor; }
SimpleMessageListenerContainer extends AbstractMessageListenerContainer { protected AsyncTaskExecutor getTaskExecutor() { return this.taskExecutor; } }
SimpleMessageListenerContainer extends AbstractMessageListenerContainer { protected AsyncTaskExecutor getTaskExecutor() { return this.taskExecutor; }  }
SimpleMessageListenerContainer extends AbstractMessageListenerContainer { protected AsyncTaskExecutor getTaskExecutor() { return this.taskExecutor; }  void setTaskExecutor(AsyncTaskExecutor taskExecutor); long getBackOffTime(); void setBackOffTime(long backOffTime); long getQueueStopTimeout(); void setQueueStopTimeout(long queueStopTimeout); void stop(String logicalQueueName); void start(String logicalQueueName); boolean isRunning(String logicalQueueName); }
SimpleMessageListenerContainer extends AbstractMessageListenerContainer { protected AsyncTaskExecutor getTaskExecutor() { return this.taskExecutor; }  void setTaskExecutor(AsyncTaskExecutor taskExecutor); long getBackOffTime(); void setBackOffTime(long backOffTime); long getQueueStopTimeout(); void setQueueStopTimeout(long queueStopTimeout); void stop(String logicalQueueName); void start(String logicalQueueName); boolean isRunning(String logicalQueueName);  }