METHOD_0 ( ) { org . apache . activemq . IDENT_0 IDENT_1 = METHOD_1 ( ) ; org . apache . flink . streaming . IDENT_2 . activemq . IDENT_3 < java . lang . String > IDENT_4 = new org . apache . flink . streaming . IDENT_2 . activemq . IDENT_3 . IDENT_5 < java . lang . String > ( ) . METHOD_2 ( IDENT_1 ) . METHOD_3 ( STRING_0 ) . METHOD_4 ( new org . apache . flink . api . common . serialization . METHOD_5 ( ) ) . build ( ) ; org . apache . flink . streaming . IDENT_2 . activemq . IDENT_6 < java . lang . String > IDENT_7 = new org . apache . flink . streaming . IDENT_2 . activemq . METHOD_6 ( IDENT_4 ) ; IDENT_7 . METHOD_7 ( new org . apache . flink . configuration . Configuration ( ) ) ; for ( int i = 0 ; i < ( org . apache . flink . streaming . IDENT_2 . activemq . IDENT_8 . IDENT_9 ) ; i ++ ) { IDENT_7 . invoke ( ( STRING_1 + i ) , null ) ; } org . apache . flink . streaming . IDENT_2 . activemq . IDENT_10 < java . lang . String > IDENT_11 = new org . apache . flink . streaming . IDENT_2 . activemq . IDENT_10 . IDENT_12 < java . lang . String > ( ) . METHOD_2 ( IDENT_1 ) . METHOD_3 ( STRING_0 ) . METHOD_8 ( new org . apache . flink . api . common . serialization . METHOD_5 ( ) ) . build ( ) ; final org . apache . flink . streaming . IDENT_2 . activemq . IDENT_13 < java . lang . String > source = new org . apache . flink . streaming . IDENT_2 . activemq . METHOD_9 ( IDENT_11 ) ; org . apache . flink . api . common . IDENT_14 . IDENT_15 IDENT_16 = METHOD_10 ( ) ; source . METHOD_11 ( IDENT_16 ) ; source . METHOD_7 ( new org . apache . flink . configuration . Configuration ( ) ) ; final org . apache . flink . streaming . IDENT_2 . activemq . IDENT_8 . IDENT_17 IDENT_18 = new org . apache . flink . streaming . IDENT_2 . activemq . IDENT_8 . METHOD_12 ( ) ; java . lang . Thread IDENT_19 = new java . lang . Thread ( new java . lang . METHOD_13 ( ) { @ org . apache . flink . streaming . IDENT_2 . activemq . Override public void run ( ) { try { source . run ( IDENT_18 ) ; } catch ( java . lang . Exception e ) { e . printStackTrace ( ) ; } } } ) ; IDENT_19 . start ( ) ; IDENT_20 . concurrent . IDENT_21 . IDENT_22 IDENT_23 = IDENT_20 . concurrent . IDENT_21 . IDENT_24 . apply ( 5 , STRING_2 ) . METHOD_14 ( ) ; while ( ( IDENT_23 . METHOD_15 ( ) ) && ( ( IDENT_18 . METHOD_16 ( ) ) < ( org . apache . flink . streaming . IDENT_2 . activemq . IDENT_8 . IDENT_9 ) ) ) { java . lang . Thread . sleep ( 100 ) ; java . util . IDENT_25 random = new java . util . METHOD_17 ( ) ; final long IDENT_26 = random . METHOD_18 ( ) ; MOD_0 ( IDENT_18 . METHOD_19 ( ) ) { source . METHOD_20 ( new org . apache . flink . runtime . state . METHOD_21 ( ) { @ org . apache . flink . streaming . IDENT_2 . activemq . Override public long METHOD_22 ( ) { return IDENT_26 ; } @ org . apache . flink . streaming . IDENT_2 . activemq . Override public long METHOD_23 ( ) { return java . lang . System . currentTimeMillis ( ) ; } } ) ; source . METHOD_24 ( IDENT_26 ) ; } } "<AssertPlaceHolder>" ; } METHOD_16 ( ) { MOD_0 ( IDENT_27 ) { return IDENT_28 . size ( ) ; } }
org . junit . Assert . assertEquals ( org . apache . flink . streaming . IDENT_2 . activemq . IDENT_8 . IDENT_9 , IDENT_18 . METHOD_16 ( ) )