METHOD_0 ( ) { final int IDENT_0 = 10 ; final java . lang . String IDENT_1 = STRING_0 ; long start = INT_0 ; for ( int i = 0 ; i < IDENT_0 ; i ++ ) { java . lang . String str = new java . lang . String ( ( "test" + i ) ) ; IDENT_2 . METHOD_1 ( ( IDENT_1 + i ) , new org . apache . activemq . util . METHOD_2 ( str . getBytes ( ) ) , "" , ( start + ( i * 1000 ) ) , ( INT_0 + i ) , 0 ) ; } start = java . lang . System . currentTimeMillis ( ) ; long IDENT_3 = ( start + INT_1 ) + ( IDENT_0 * 1000 ) ; IDENT_2 . METHOD_3 ( start , IDENT_3 ) ; "<AssertPlaceHolder>" ; } METHOD_4 ( ) { final java . util . List < org . apache . activemq . IDENT_4 . IDENT_2 . IDENT_5 > result = new java . util . ArrayList ( ) ; this . store . METHOD_5 ( ) ; try { this . store . METHOD_6 ( ) . tx ( ) . execute ( new org . apache . activemq . store . IDENT_6 . IDENT_7 . page . IDENT_8 . IDENT_9 < java . io . IOException > ( ) { @ java . lang . Override public void execute ( org . apache . activemq . store . IDENT_6 . IDENT_7 . page . IDENT_8 tx ) throws java . io . IOException { Iterator < Map . Entry < java . lang . Long , List < org . apache . activemq . store . IDENT_6 . IDENT_2 . IDENT_10 > > > IDENT_11 = index . iterator ( store . METHOD_6 ( ) . tx ( ) ) ; while ( IDENT_11 . hasNext ( ) ) { Map . Entry < java . lang . Long , List < org . apache . activemq . store . IDENT_6 . IDENT_2 . IDENT_10 > > next = IDENT_11 . next ( ) ; if ( next != null ) { for ( org . apache . activemq . store . IDENT_6 . IDENT_2 . IDENT_10 IDENT_12 : next . getValue ( ) ) { org . apache . activemq . util . METHOD_2 IDENT_13 = METHOD_7 ( IDENT_12 . METHOD_8 ( ) ) ; org . apache . activemq . IDENT_4 . IDENT_2 . IDENT_5 job = new org . apache . activemq . store . IDENT_6 . IDENT_2 . METHOD_9 ( IDENT_12 , IDENT_13 ) ; result . add ( job ) ; } } else { break ; } } } } ) ; } finally { this . store . METHOD_10 ( ) ; } return result ; }
org . junit . Assert . assertTrue ( IDENT_2 . METHOD_4 ( ) . isEmpty ( ) )