METHOD_0 ( ) { try ( io . IDENT_0 . streaming . IDENT_1 IDENT_2 = new io . IDENT_0 . streaming . METHOD_1 ( io . IDENT_0 . streaming . IDENT_3 . IDENT_4 , false ) ) { io . IDENT_0 . streaming . IDENT_5 options = new io . IDENT_0 . streaming . IDENT_5 . Builder ( ) . METHOD_2 ( IDENT_2 . METHOD_3 ( ) ) . build ( ) ; try ( io . IDENT_0 . streaming . IDENT_6 IDENT_7 = io . IDENT_0 . streaming . IDENT_8 . connect ( io . IDENT_0 . streaming . IDENT_3 . IDENT_4 , io . IDENT_0 . streaming . IDENT_3 . IDENT_9 , options ) ) { io . IDENT_0 . streaming . IDENT_10 IDENT_11 = new io . IDENT_0 . streaming . IDENT_10 . Builder ( ) . build ( ) ; try ( io . IDENT_0 . streaming . IDENT_12 IDENT_13 = IDENT_7 . METHOD_4 ( "foo" , ( msg ) -> { } , IDENT_11 ) ) { "<AssertPlaceHolder>" ; } catch ( java . lang . Exception e ) { org . junit . Assert . fail ( ( STRING_0 + ( e . getMessage ( ) ) ) ) ; } } } } METHOD_4 ( java . lang . String , java . lang . String , io . IDENT_0 . streaming . io . IDENT_0 . streaming . IDENT_14 ) { return METHOD_4 ( subject , queue , cb , null ) ; }
org . junit . Assert . assertNotNull ( IDENT_13 )