METHOD_0 ( ) { org . springframework . cloud . stream . schema . IDENT_0 client = mock ( org . springframework . cloud . stream . schema . IDENT_0 . class ) ; org . apache . avro . Schema schema = load ( STRING_0 ) ; when ( client . METHOD_1 ( any ( ) ) ) . thenReturn ( 10 ) ; when ( client . METHOD_2 ( eq ( 10 ) ) ) . thenReturn ( schema ) ; org . springframework . cloud . stream . codec . avro . IDENT_1 codec = new org . springframework . cloud . stream . codec . avro . METHOD_3 ( ) ; codec . METHOD_4 ( client ) ; codec . METHOD_5 ( new org . springframework . core . io . support . METHOD_6 ( new org . springframework . context . annotation . METHOD_7 ( ) ) ) ; codec . METHOD_8 ( new org . springframework . cloud . stream . codec . avro . METHOD_9 ( ) ) ; codec . init ( ) ; org . springframework . cloud . stream . IDENT_2 . Status status = new org . springframework . cloud . stream . IDENT_2 . Status ( "1" , STRING_1 , java . lang . System . currentTimeMillis ( ) ) ; byte [ ] results = codec . encode ( status ) ; org . springframework . cloud . stream . IDENT_2 . Status IDENT_3 = codec . decode ( results , org . springframework . cloud . stream . IDENT_2 . Status . class ) ; "<AssertPlaceHolder>" ; } getId ( ) { return id ; }
org . junit . Assert . assertEquals ( status . getId ( ) , IDENT_3 . getId ( ) )