@Test
public void testGetQueueWithDefaultConfiguration() {

    when(configuration.getIntProperty(anyString(), anyInt())).thenAnswer(invocation -> invocation.getArguments()[1]);
    ListQueuesResult listQueuesResult = new ListQueuesResult().withQueueUrls("test_queue_1");
    when(amazonSQSClient.listQueues(any(ListQueuesRequest.class))).thenReturn(listQueuesResult);
    SQSEventQueueProvider sqsEventQueueProvider = new SQSEventQueueProvider(amazonSQSClient, configuration, Schedulers.from(Executors.newSingleThreadExecutor()));
    SQSObservableQueue sqsObservableQueue = (SQSObservableQueue) sqsEventQueueProvider.getQueue("test_queue_1");
    assertNotNull(sqsObservableQueue);
    assertEquals(1, sqsObservableQueue.getBatchSize());
    assertEquals(100, sqsObservableQueue.getPollTimeInMS());
    assertEquals(60, sqsObservableQueue.getVisibilityTimeoutInSeconds());
}