public void manual_cyclic_fail() throws InterruptedException {
        logger.info("You should shutdown the broker...");
        Thread.sleep(5000);
        String message = "MANAGED1";
        while (true) {
            try {
                testSender3.send(message);
                break;
            } catch (JMSException e) {
                Thread.sleep(100);
                logger.info("Unable to send message: {}", message);
            }
        }
        latchConnect1.await(10, TimeUnit.SECONDS);
        Assertions.assertThat(text).isEqualTo(message);
    }
public void manual_cyclic_fail ( ) throws InterruptedException { logger . info ( "You should shutdown the broker..." ) ; Thread . sleep ( 5000 ) ; String message = "MANAGED1" ; while ( true ) { try { testSender3 . send ( message ) ; break ; } catch ( JMSException e ) { Thread . sleep ( 100 ) ; logger . info ( "Unable to send message: {}" , message ) ; } } latchConnect1 . await ( 10 , TimeUnit . SECONDS ) ; Assertions . assertThat ( text ) . isEqualTo ( message ) ; }
@Test