METHOD_0 ( ) { java . util . ArrayList < java . lang . String > data = new java . util . ArrayList ( ) ; for ( int i = 0 ; i < 100 ; i ++ ) { data . add ( ( STRING_0 + i ) ) ; } pipeline . apply ( org . apache . beam . sdk . IDENT_0 . IDENT_1 . of ( data ) ) . apply ( org . apache . beam . sdk . io . jms . IDENT_2 . write ( ) . METHOD_1 ( IDENT_3 ) . METHOD_2 ( org . apache . beam . sdk . io . jms . IDENT_4 . IDENT_5 ) . METHOD_3 ( org . apache . beam . sdk . io . jms . IDENT_4 . IDENT_6 ) . METHOD_4 ( org . apache . beam . sdk . io . jms . IDENT_4 . IDENT_7 ) ) ; pipeline . run ( ) ; javax . jms . IDENT_8 connection = IDENT_3 . METHOD_5 ( org . apache . beam . sdk . io . jms . IDENT_4 . IDENT_6 , org . apache . beam . sdk . io . jms . IDENT_4 . IDENT_7 ) ; connection . start ( ) ; javax . jms . IDENT_9 session = connection . METHOD_6 ( false , IDENT_9 . IDENT_10 ) ; javax . jms . IDENT_11 consumer = session . METHOD_7 ( session . METHOD_8 ( org . apache . beam . sdk . io . jms . IDENT_4 . IDENT_5 ) ) ; int count = 0 ; while ( ( consumer . METHOD_9 ( 1000 ) ) != null ) { count ++ ; } "<AssertPlaceHolder>" ; } METHOD_7 ( org . apache . beam . sdk . io . IDENT_12 ) { return METHOD_7 ( source , 1 ) ; }
org . junit . Assert . assertEquals ( 100 , count )