METHOD_0 ( ) { javax . jms . IDENT_0 IDENT_1 = new org . apache . activemq . METHOD_1 ( IDENT_2 ) ; javax . jms . IDENT_3 connection = IDENT_1 . METHOD_2 ( ) ; connection . start ( ) ; METHOD_3 ( IDENT_4 , IDENT_5 , connection ) ; { java . util . concurrent . atomic . IDENT_6 IDENT_7 = new java . util . concurrent . atomic . METHOD_4 ( ) ; java . util . Map < java . lang . String , java . lang . Boolean > IDENT_8 = new java . util . concurrent . METHOD_5 ( ) ; javax . jms . IDENT_9 session = connection . METHOD_6 ( true , IDENT_9 . IDENT_10 ) ; javax . jms . IDENT_11 IDENT_12 = session . METHOD_7 ( IDENT_5 ) ; javax . jms . IDENT_13 consumer = session . METHOD_8 ( IDENT_12 ) ; while ( ( IDENT_7 . get ( ) ) < ( IDENT_4 ) ) { javax . jms . IDENT_14 msg = ( ( javax . jms . IDENT_14 ) ( consumer . METHOD_9 ( INT_0 ) ) ) ; if ( msg != null ) { if ( ( IDENT_8 . put ( msg . getText ( ) , Boolean . IDENT_15 ) ) != null ) { org . apache . activemq . IDENT_16 . LOG . info ( ( ( ( ( ( STRING_0 + ( msg . getText ( ) ) ) + STRING_1 ) + ( IDENT_7 . METHOD_10 ( ) ) ) + STRING_2 ) + ( msg . METHOD_11 ( ) ) ) ) ; "<AssertPlaceHolder>" ; session . commit ( ) ; } else { org . apache . activemq . IDENT_16 . LOG . info ( ( ( ( STRING_3 + ( msg . getText ( ) ) ) + STRING_4 ) + ( msg . METHOD_11 ( ) ) ) ) ; session . METHOD_12 ( ) ; } } } consumer . close ( ) ; session . close ( ) ; } } METHOD_13 ( ) { if ( IDENT_17 . LOGGER . METHOD_14 ( ) ) { IDENT_17 . LOGGER . trace ( STRING_5 ) ; } return message . METHOD_13 ( ) ; }
org . junit . Assert . assertTrue ( msg . METHOD_13 ( ) )