METHOD_0 ( ) { count . set ( 0 ) ; com . stratio . IDENT_0 . unit . IDENT_1 . query . IDENT_2 . LOGGER . debug ( STRING_0 ) ; com . stratio . IDENT_0 . unit . IDENT_1 . query . IDENT_2 . LOGGER . debug ( STRING_1 ) ; com . stratio . IDENT_0 . unit . IDENT_1 . query . IDENT_2 . IDENT_3 = IDENT_4 . METHOD_1 ( IDENT_5 . IDENT_6 ) ; IDENT_4 . METHOD_2 ( IDENT_5 . IDENT_7 , new org . IDENT_8 . IDENT_1 . core . stream . output . METHOD_3 ( ) { @ com . stratio . IDENT_0 . unit . IDENT_1 . query . Override public void METHOD_4 ( org . IDENT_8 . IDENT_1 . core . event . IDENT_9 [ ] events ) { for ( org . IDENT_8 . IDENT_1 . core . event . IDENT_9 event : events ) { if ( event instanceof org . IDENT_8 . IDENT_1 . core . event . in . IDENT_10 ) { count . METHOD_5 ( ) ; com . stratio . IDENT_0 . unit . IDENT_1 . query . IDENT_2 . LOGGER . debug ( ( STRING_2 + ( event . toString ( ) ) ) ) ; } } } } ) ; com . stratio . IDENT_0 . unit . IDENT_1 . query . IDENT_2 . METHOD_6 ( com . stratio . IDENT_0 . unit . IDENT_1 . query . IDENT_2 . IDENT_11 ) ; java . lang . Thread . sleep ( INT_0 ) ; "<AssertPlaceHolder>" ; IDENT_4 . METHOD_7 ( com . stratio . IDENT_0 . unit . IDENT_1 . query . IDENT_2 . IDENT_3 ) ; } METHOD_6 ( java . lang . String ) { com . stratio . IDENT_0 . unit . IDENT_1 . query . IDENT_2 . LOGGER . debug ( ( STRING_3 + IDENT_12 ) ) ; java . util . List < java . lang . String [ ] > IDENT_13 = com . stratio . IDENT_0 . unit . IDENT_1 . query . IDENT_14 . METHOD_8 ( IDENT_12 , STRING_4 , STRING_5 , 1 ) ; java . util . List < com . stratio . IDENT_0 . unit . IDENT_1 . query . model . IDENT_15 > IDENT_16 = com . stratio . IDENT_0 . unit . IDENT_1 . query . model . IDENT_15 . METHOD_9 ( IDENT_13 ) ; for ( com . stratio . IDENT_0 . unit . IDENT_1 . query . model . IDENT_15 order : IDENT_16 ) { com . stratio . IDENT_0 . unit . IDENT_1 . query . IDENT_2 . LOGGER . debug ( ( ( ( STRING_6 + ( IDENT_5 . IDENT_17 ) ) + STRING_7 ) + ( order . METHOD_10 ( ) ) ) ) ; IDENT_4 . METHOD_11 ( IDENT_5 . IDENT_17 ) . METHOD_12 ( com . stratio . IDENT_0 . unit . IDENT_1 . query . IDENT_2 . METHOD_13 ( order ) ) ; } }
org . junit . Assert . assertEquals ( 1 , count . get ( ) )