code: @Test
      public void message_polling_is_working() throws JMSException {
          testSender4.send("HELLO");
  
          try {
              count.await(5, TimeUnit.SECONDS);
  
              Assertions.assertThat(text).isEqualTo("HELLO");
          } catch (InterruptedException e) {
              fail("Thread interrupted");
          }
      }
docs: TestSender4 and TestMessageListener4.