METHOD_0 ( ) { queue . METHOD_1 ( new com . mongodb . METHOD_2 ( STRING_0 , 0 ) ) ; "<AssertPlaceHolder>" ; } get ( com . mongodb . METHOD_2 , int , int , long ) { java . util . IDENT_0 . METHOD_3 ( query ) ; collection . update ( new com . mongodb . METHOD_2 ( STRING_1 , true ) . append ( STRING_2 , new com . mongodb . METHOD_2 ( STRING_3 0 , new java . util . Date ( ) ) ) , new com . mongodb . METHOD_2 ( STRING_4 , new com . mongodb . METHOD_2 ( STRING_1 , false ) ) , false , true ) ; final com . mongodb . METHOD_2 IDENT_1 = new com . mongodb . METHOD_2 ( STRING_1 , false ) ; for ( final java . util . Map . Entry < java . lang . String , java . lang . Object > field : query . entrySet ( ) ) { IDENT_1 . append ( ( STRING_5 + ( field . getKey ( ) ) ) , field . getValue ( ) ) ; } IDENT_1 . append ( STRING_6 , new com . mongodb . METHOD_2 ( STRING_3 0 , new java . util . Date ( ) ) ) ; final java . util . Calendar IDENT_2 = java . util . Calendar . getInstance ( ) ; IDENT_2 . add ( Calendar . IDENT_3 , IDENT_4 ) ; final java . util . Date IDENT_5 = IDENT_2 . getTime ( ) ; final com . mongodb . METHOD_2 IDENT_6 = new com . mongodb . METHOD_2 ( STRING_7 , 1 ) . append ( STRING_3 , 1 ) ; final com . mongodb . METHOD_2 update = new com . mongodb . METHOD_2 ( STRING_4 , new com . mongodb . METHOD_2 ( STRING_1 , true ) . append ( STRING_2 , IDENT_5 ) ) ; final com . mongodb . METHOD_2 fields = new com . mongodb . METHOD_2 ( STRING_8 , 1 ) ; IDENT_2 . METHOD_4 ( java . lang . System . currentTimeMillis ( ) ) ; IDENT_2 . add ( Calendar . IDENT_7 , IDENT_8 ) ; final java . util . Date end = IDENT_2 . getTime ( ) ; while ( true ) { final com . mongodb . METHOD_2 message = ( ( com . mongodb . METHOD_2 ) ( collection . METHOD_5 ( IDENT_1 , fields , IDENT_6 , false , update , true , false ) ) ) ; if ( message != null ) { final org . bson . types . IDENT_9 id = message . METHOD_6 ( STRING_9 ) ; return ( ( com . mongodb . METHOD_2 ) ( message . get ( STRING_8 ) ) ) . append ( STRING_10 , id ) ; } if ( ( new java . util . Date ( ) . compareTo ( end ) ) >= 0 ) { return null ; } try { java . lang . Thread . sleep ( IDENT_10 ) ; } catch ( final java . lang . IDENT_11 ex ) { throw new java . lang . RuntimeException ( ex ) ; } catch ( final java . lang . IllegalArgumentException ex ) { IDENT_10 = 0 ; } } }
org . junit . Assert . assertNull ( queue . get ( new com . mongodb . METHOD_2 ( STRING_0 , 1 ) , Integer . MAX_VALUE , 0 ) )