METHOD_0 ( ) { org . apache . IDENT_0 . client . IDENT_1 . IDENT_2 IDENT_1 = new org . apache . IDENT_0 . client . IDENT_1 . METHOD_1 ( IDENT_3 ) ; IDENT_1 . METHOD_2 ( org . apache . IDENT_0 . IDENT_4 . IDENT_5 . source . IDENT_6 . IDENT_7 ) ; java . lang . String IDENT_8 = ( STRING_0 + STRING_1 ) + ( org . apache . commons . lang . time . IDENT_9 . format ( new java . util . Date ( ) , STRING_2 ) ) ; try { IDENT_1 . start ( ) ; org . apache . IDENT_0 . common . message . Message msg = new org . apache . IDENT_0 . common . message . Message ( org . apache . IDENT_0 . IDENT_4 . IDENT_5 . source . IDENT_10 . IDENT_11 , IDENT_12 , IDENT_8 . getBytes ( STRING_3 ) ) ; org . apache . IDENT_0 . client . IDENT_1 . IDENT_13 IDENT_14 = IDENT_1 . METHOD_3 ( msg ) ; org . apache . IDENT_0 . IDENT_4 . IDENT_5 . source . IDENT_6 . log . info ( STRING_4 , IDENT_8 , IDENT_14 ) ; } catch ( java . lang . Exception e ) { throw new org . apache . IDENT_0 . client . exception . METHOD_4 ( STRING_5 , e ) ; } finally { IDENT_1 . METHOD_5 ( ) ; } org . apache . IDENT_4 . Context context = new org . apache . IDENT_4 . Context ( ) ; context . put ( org . apache . IDENT_0 . IDENT_4 . IDENT_5 . source . IDENT_10 . IDENT_15 , org . apache . IDENT_0 . IDENT_4 . IDENT_5 . source . IDENT_6 . IDENT_7 ) ; context . put ( org . apache . IDENT_0 . IDENT_4 . IDENT_5 . source . IDENT_10 . IDENT_16 , IDENT_12 ) ; org . apache . IDENT_4 . IDENT_17 channel = new org . apache . IDENT_4 . channel . METHOD_6 ( ) ; org . apache . IDENT_4 . conf . IDENT_18 . METHOD_7 ( channel , context ) ; java . util . List < org . apache . IDENT_4 . IDENT_17 > IDENT_19 = new java . util . ArrayList ( ) ; IDENT_19 . add ( channel ) ; org . apache . IDENT_4 . IDENT_20 IDENT_21 = new org . apache . IDENT_4 . channel . METHOD_8 ( ) ; IDENT_21 . METHOD_9 ( IDENT_19 ) ; org . apache . IDENT_4 . channel . IDENT_22 IDENT_23 = new org . apache . IDENT_4 . channel . METHOD_10 ( IDENT_21 ) ; org . apache . IDENT_0 . IDENT_4 . IDENT_5 . source . IDENT_24 source = new org . apache . IDENT_0 . IDENT_4 . IDENT_5 . source . METHOD_11 ( ) ; source . METHOD_12 ( IDENT_23 ) ; org . apache . IDENT_4 . conf . IDENT_18 . METHOD_7 ( source , context ) ; source . start ( ) ; org . apache . IDENT_4 . IDENT_25 . Status status = source . process ( ) ; if ( status == ( IDENT_25 . Status . IDENT_26 ) ) { org . junit . Assert . fail ( STRING_6 ) ; } org . apache . IDENT_4 . IDENT_27 transaction = channel . METHOD_13 ( ) ; transaction . METHOD_14 ( ) ; org . apache . IDENT_4 . IDENT_28 event = channel . METHOD_15 ( ) ; if ( event == null ) { transaction . commit ( ) ; org . junit . Assert . fail ( STRING_6 ) ; } byte [ ] body = event . METHOD_16 ( ) ; java . lang . String IDENT_29 = new java . lang . String ( body , STRING_3 ) ; org . apache . IDENT_0 . IDENT_4 . IDENT_5 . source . IDENT_6 . log . info ( STRING_7 , IDENT_29 ) ; "<AssertPlaceHolder>" ; } fail ( java . lang . Object ) { java . lang . String id = IDENT_30 . toString ( ) ; IDENT_31 . fail ( id ) ; }
org . junit . Assert . assertEquals ( IDENT_8 , IDENT_29 )