code: @Test
      public void unmanaged_send_and_receive_is_working() throws JMSException {
  
          testSender2.send("UNMANAGED");
  
          try {
              unmanaged.await(1, TimeUnit.SECONDS);
  
              Assertions.assertThat(textUnmanaged).isEqualTo("UNMANAGED");
          } catch (InterruptedException e) {
              fail("Thread interrupted");
          }
      }
docs: TestSender2 and TestMessageListener2.