METHOD_0 ( ) { final java . lang . String IDENT_0 = STRING_0 ; try ( final org . apache . kafka . IDENT_1 . IDENT_2 . IDENT_3 < ? , org . apache . rya . api . model . IDENT_4 > IDENT_2 = org . apache . rya . test . kafka . IDENT_5 . METHOD_1 ( rule , org . apache . kafka . common . serialization . IDENT_6 . class , org . apache . rya . streams . kafka . serialization . IDENT_7 . class ) ) { final org . apache . rya . streams . kafka . IDENT_8 . IDENT_9 command = new org . apache . rya . streams . kafka . IDENT_8 . METHOD_2 ( rule . METHOD_3 ( ) , IDENT_2 ) ; command . METHOD_4 ( org . apache . rya . streams . kafka . IDENT_8 . IDENT_10 . IDENT_11 , IDENT_0 ) ; } final java . util . List < org . apache . rya . api . model . IDENT_4 > read ; try ( org . apache . kafka . IDENT_1 . consumer . IDENT_12 < java . lang . String , org . apache . rya . api . model . IDENT_4 > consumer = org . apache . rya . test . kafka . IDENT_5 . METHOD_5 ( rule , org . apache . kafka . common . serialization . IDENT_13 . class , org . apache . rya . streams . kafka . serialization . IDENT_14 . class ) ) { consumer . METHOD_6 ( java . util . Arrays . asList ( rule . METHOD_3 ( ) ) ) ; read = org . apache . rya . test . kafka . IDENT_5 . METHOD_7 ( INT_0 , 6 , 3 , consumer ) ; } final java . util . List < org . apache . rya . api . model . IDENT_4 > original = new java . util . ArrayList ( ) ; final org . eclipse . IDENT_15 . model . IDENT_16 IDENT_17 = org . eclipse . IDENT_15 . model . impl . IDENT_18 . getInstance ( ) ; original . add ( new org . apache . rya . api . model . METHOD_8 ( IDENT_17 . METHOD_9 ( IDENT_17 . METHOD_10 ( STRING_1 ) , IDENT_17 . METHOD_10 ( STRING_2 ) , IDENT_17 . METHOD_10 ( STRING_3 ) ) , IDENT_0 ) ) ; original . add ( new org . apache . rya . api . model . METHOD_8 ( IDENT_17 . METHOD_9 ( IDENT_17 . METHOD_10 ( STRING_3 ) , IDENT_17 . METHOD_10 ( STRING_2 ) , IDENT_17 . METHOD_10 ( STRING_4 ) ) , IDENT_0 ) ) ; original . add ( new org . apache . rya . api . model . METHOD_8 ( IDENT_17 . METHOD_9 ( IDENT_17 . METHOD_10 ( STRING_4 ) , IDENT_17 . METHOD_10 ( STRING_5 ) , IDENT_17 . METHOD_10 ( STRING_6 ) ) , IDENT_0 ) ) ; "<AssertPlaceHolder>" ; } add ( java . io . IDENT_19 , java . lang . String , org . eclipse . IDENT_15 . IDENT_20 . IDENT_21 , org . eclipse . IDENT_15 . model . IDENT_22 [ ] ) { org . eclipse . IDENT_15 . IDENT_23 . METHOD_11 ( IDENT_24 ) ; final org . apache . rya . IDENT_25 . utils . IDENT_26 IDENT_27 = new org . apache . rya . IDENT_25 . utils . METHOD_12 ( this ) ; IDENT_27 . METHOD_13 ( IDENT_24 ) ; final boolean IDENT_28 = METHOD_14 ( ) ; try { final org . eclipse . IDENT_15 . repository . util . IDENT_29 loader = new org . eclipse . IDENT_15 . repository . util . METHOD_15 ( METHOD_16 ( ) , METHOD_17 ( ) ) ; loader . load ( reader , IDENT_30 , IDENT_31 , IDENT_27 ) ; METHOD_18 ( IDENT_28 ) ; } catch ( final org . eclipse . IDENT_15 . IDENT_20 . IDENT_32 e ) { METHOD_19 ( IDENT_28 ) ; throw ( ( org . eclipse . IDENT_15 . repository . IDENT_33 ) ( e . METHOD_20 ( ) ) ) ; } catch ( java . io . IOException | java . lang . RuntimeException e ) { METHOD_19 ( IDENT_28 ) ; throw e ; } }
org . junit . Assert . assertEquals ( original , read )