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 ) ; com . stratio . IDENT_0 . unit . IDENT_1 . query . IDENT_2 . IDENT_7 = IDENT_4 . METHOD_1 ( IDENT_5 . IDENT_8 ) ; IDENT_4 . METHOD_2 ( IDENT_5 . IDENT_9 , new org . IDENT_10 . IDENT_1 . core . stream . output . METHOD_3 ( ) { @ com . stratio . IDENT_0 . unit . IDENT_1 . query . Override public void METHOD_4 ( org . IDENT_10 . IDENT_1 . core . event . IDENT_11 [ ] events ) { for ( org . IDENT_10 . IDENT_1 . core . event . IDENT_11 event : events ) { if ( ( event instanceof org . IDENT_10 . IDENT_1 . core . event . in . IDENT_12 ) && ( event . METHOD_5 ( 2 ) . toString ( ) . equals ( STRING_2 ) ) ) { count . METHOD_6 ( ) ; com . stratio . IDENT_0 . unit . IDENT_1 . query . IDENT_2 . LOGGER . debug ( ( STRING_3 + ( event . toString ( ) ) ) ) ; } } } } ) ; com . stratio . IDENT_0 . unit . IDENT_1 . query . IDENT_2 . METHOD_7 ( com . stratio . IDENT_0 . unit . IDENT_1 . query . IDENT_2 . IDENT_13 ) ; java . lang . Thread . sleep ( INT_0 ) ; "<AssertPlaceHolder>" ; IDENT_4 . METHOD_8 ( com . stratio . IDENT_0 . unit . IDENT_1 . query . IDENT_2 . IDENT_3 ) ; IDENT_4 . METHOD_8 ( com . stratio . IDENT_0 . unit . IDENT_1 . query . IDENT_2 . IDENT_7 ) ; } METHOD_7 ( java . lang . String ) { com . stratio . IDENT_0 . unit . IDENT_1 . query . IDENT_2 . LOGGER . debug ( ( STRING_4 + IDENT_14 ) ) ; java . util . List < java . lang . String [ ] > IDENT_15 = com . stratio . IDENT_0 . unit . IDENT_1 . query . IDENT_16 . METHOD_9 ( IDENT_14 , STRING_5 , STRING_6 , 1 ) ; java . util . List < com . stratio . IDENT_0 . unit . IDENT_1 . query . model . IDENT_17 > IDENT_18 = com . stratio . IDENT_0 . unit . IDENT_1 . query . model . IDENT_17 . METHOD_10 ( IDENT_15 ) ; for ( com . stratio . IDENT_0 . unit . IDENT_1 . query . model . IDENT_17 IDENT_19 : IDENT_18 ) { com . stratio . IDENT_0 . unit . IDENT_1 . query . IDENT_2 . LOGGER . debug ( ( ( ( ( ( STRING_7 + ( IDENT_5 . IDENT_20 ) ) + STRING_8 ) + ( IDENT_19 . name ( ) ) ) + STRING_9 ) + ( IDENT_19 . data ( ) ) ) ) ; IDENT_4 . METHOD_11 ( IDENT_5 . IDENT_20 ) . METHOD_12 ( com . stratio . IDENT_0 . unit . IDENT_1 . query . IDENT_2 . METHOD_13 ( IDENT_19 ) ) ; } }
org . junit . Assert . assertEquals ( 1 , count . get ( ) )