@Test
public void testAsyncConsumeConsumption() {

  urlSetup("testQueue", "testUrl");
  receiveSetup();
  deleteSetup();
  AsyncConsumer<String> function = (str, threadpool) -> CompletableFuture.completedFuture(null);
  CompletableFuture<Boolean> result = asyncClient.consume(function, "testQueue");
  // testing final result
  assertTrue(result.join());
}