METHOD_0 ( ) { java . lang . String queue = STRING_0 ; final java . util . concurrent . IDENT_0 < java . lang . Boolean > result = new java . util . concurrent . IDENT_1 < java . lang . Boolean > ( 1 ) ; channel . METHOD_1 ( queue , false , true , false , null ) ; final com . IDENT_2 . client . IDENT_3 consumer = new com . IDENT_2 . client . METHOD_2 ( channel ) ; java . lang . IDENT_4 IDENT_5 = new java . lang . METHOD_3 ( ) { public void run ( ) { try { try { consumer . METHOD_4 ( ) ; } catch ( com . IDENT_2 . client . IDENT_6 e ) { result . put ( true ) ; return ; } catch ( com . IDENT_2 . client . IDENT_7 e ) { } catch ( java . lang . IDENT_8 e ) { } result . put ( false ) ; } catch ( java . lang . IDENT_8 e ) { org . junit . Assert . fail ( ) ; } } } ; java . lang . Thread t = new java . lang . Thread ( IDENT_5 ) ; t . start ( ) ; channel . METHOD_5 ( queue , consumer ) ; channel . METHOD_6 ( queue ) ; "<AssertPlaceHolder>" ; t . join ( ) ; } METHOD_7 ( ) { IDENT_9 x ; int c = - 1 ; final com . IDENT_2 . client . impl . IDENT_10 count = this . count ; final com . IDENT_2 . client . impl . IDENT_11 IDENT_12 = this . IDENT_12 ; IDENT_12 . METHOD_8 ( ) ; try { try { while ( ( count . get ( ) ) == 0 ) IDENT_13 . METHOD_9 ( ) ; } catch ( java . lang . IDENT_8 IDENT_14 ) { IDENT_13 . METHOD_10 ( ) ; throw IDENT_14 ; } x = METHOD_11 ( ) ; c = count . METHOD_12 ( ) ; if ( c > 1 ) IDENT_13 . METHOD_10 ( ) ; } finally { IDENT_12 . METHOD_13 ( ) ; } if ( c >= ( IDENT_15 ) ) METHOD_14 ( ) ; return x ; }
org . junit . Assert . assertTrue ( result . METHOD_7 ( ) )