METHOD_0 ( ) { java . lang . String sql = "" + ( ( ( STRING_0 + STRING_1 ) + STRING_2 ) + STRING_3 ) ; java . util . concurrent . atomic . IDENT_0 IDENT_1 = new java . util . concurrent . atomic . METHOD_1 ( ) ; org . IDENT_2 . IDENT_3 . core . stream . output . IDENT_4 IDENT_5 = new org . IDENT_2 . IDENT_3 . core . stream . output . METHOD_2 ( ) { @ org . apache . IDENT_6 . IDENT_7 . engine . IDENT_3 . Override public void METHOD_3 ( org . IDENT_2 . IDENT_3 . core . event . IDENT_8 [ ] IDENT_9 ) { IDENT_1 . set ( true ) ; } } ; java . lang . String IDENT_10 = ( streams ) + sql ; org . IDENT_2 . IDENT_3 . core . IDENT_11 runtime = IDENT_12 . METHOD_4 ( IDENT_10 ) ; runtime . METHOD_5 ( STRING_4 , IDENT_5 ) ; runtime . start ( ) ; org . IDENT_2 . IDENT_3 . core . stream . input . IDENT_13 handler = runtime . METHOD_6 ( STRING_5 ) ; METHOD_7 ( handler ) ; java . lang . Thread . sleep ( 1000 ) ; "<AssertPlaceHolder>" ; runtime . METHOD_8 ( ) ; } get ( ) { return new org . apache . IDENT_6 . app . IDENT_14 . impl . METHOD_9 ( ) ; }
org . junit . Assert . assertTrue ( IDENT_1 . get ( ) )