@ 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" ) ; } }
TestSender4 and TestMessageListener4 .