METHOD_0 ( ) { IDENT_0 . METHOD_1 ( STRING_0 ) ; IDENT_0 . METHOD_2 ( STRING_1 ) ; IDENT_0 . METHOD_3 ( STRING_2 , new org . IDENT_1 . IDENT_2 . core . stream . output . METHOD_4 ( ) { @ com . stratio . IDENT_3 . unit . IDENT_2 . extension . IDENT_4 . Override public void METHOD_5 ( org . IDENT_1 . IDENT_2 . core . event . IDENT_5 [ ] events ) { for ( org . IDENT_1 . IDENT_2 . core . event . IDENT_5 event : events ) { if ( event instanceof org . IDENT_1 . IDENT_2 . core . event . in . IDENT_6 ) { count . METHOD_6 ( ) ; } } } } ) ; IDENT_0 . METHOD_7 ( STRING_3 ) . METHOD_8 ( new java . lang . Object [ ] { new java . lang . String ( STRING_4 ) , new java . lang . METHOD_9 ( 10 ) , new java . lang . Integer ( 20 ) } ) ; IDENT_0 . METHOD_7 ( STRING_3 ) . METHOD_8 ( new java . lang . Object [ ] { new java . lang . String ( STRING_4 ) , new java . lang . METHOD_9 ( 20 ) , new java . lang . Integer ( INT_0 ) } ) ; IDENT_0 . METHOD_7 ( STRING_3 ) . METHOD_8 ( new java . lang . Object [ ] { new java . lang . String ( STRING_4 ) , new java . lang . METHOD_9 ( INT_0 ) , new java . lang . Integer ( INT_1 ) } ) ; IDENT_0 . METHOD_7 ( STRING_3 ) . METHOD_8 ( new java . lang . Object [ ] { new java . lang . String ( STRING_5 ) , new java . lang . METHOD_9 ( INT_0 ) , new java . lang . Integer ( INT_1 ) } ) ; java . lang . Thread . sleep ( INT_2 ) ; "<AssertPlaceHolder>" ; } METHOD_2 ( com . stratio . IDENT_3 . commons . messages . IDENT_7 ) { this . IDENT_8 . add ( query ) ; }
org . junit . Assert . assertEquals ( 2 , count . get ( ) )