@Test
public void testGetQueues() {

	AMQPModule module = new AMQPModule();
	Mockito.when(config.getProperty(Mockito.anyString(), Mockito.anyString()))
			.thenAnswer(invocation -> invocation.getArgument(1));
	Mockito.when(config.getBooleanProperty(Mockito.anyString(), Mockito.anyBoolean()))
			.thenAnswer(invocation -> invocation.getArgument(1));
	Mockito.when(config.getIntProperty(Mockito.anyString(), Mockito.anyInt()))
			.thenAnswer(invocation -> invocation.getArgument(1));
	Map<Task.Status, ObservableQueue> queues = module.getQueues(config);
	Assert.assertNotNull(queues);
	Assert.assertEquals(2, queues.size());
	Assert.assertEquals(queues.containsKey(Task.Status.COMPLETED), true);
	Assert.assertEquals(queues.containsKey(Task.Status.FAILED), true);
}