METHOD_0 ( ) { connection = METHOD_1 ( ) ; javax . jms . IDENT_0 session = connection . METHOD_2 ( false , IDENT_0 . IDENT_1 ) ; javax . jms . IDENT_2 queue = session . METHOD_3 ( METHOD_4 ( ) ) ; connection . start ( ) ; final javax . jms . IDENT_3 IDENT_4 = session . METHOD_5 ( queue ) ; IDENT_4 . METHOD_6 ( IDENT_5 . IDENT_6 ) ; final javax . jms . Message m = session . METHOD_7 ( STRING_0 ) ; org . apache . activemq . transport . IDENT_7 . IDENT_8 . IDENT_9 t = new org . apache . activemq . transport . IDENT_7 . IDENT_8 . METHOD_8 ( ) { @ org . apache . activemq . transport . IDENT_7 . Override public MOD_0 void run ( ) { try { for ( int i = 0 ; i < INT_0 ; ++ i ) { IDENT_4 . METHOD_9 ( m ) ; MOD_0 ( IDENT_4 ) { IDENT_4 . METHOD_10 ( ) ; } TimeUnit . IDENT_10 . sleep ( 100 ) ; } msg = STRING_1 ; } catch ( java . lang . Exception ex ) { org . apache . activemq . transport . IDENT_7 . IDENT_8 . LOG . info ( STRING_2 , ex ) ; } } } ; MOD_0 ( IDENT_4 ) { new java . lang . Thread ( t ) . start ( ) ; IDENT_4 . METHOD_11 ( INT_1 ) ; } METHOD_12 ( ) ; "<AssertPlaceHolder>" ; } METHOD_13 ( ) { if ( ( msg ) != null ) { org . junit . Assert . fail ( msg ) ; } return true ; }
org . junit . Assert . assertTrue ( t . METHOD_13 ( ) )