public int removeMessages ( String queueName , String filter ) { try { return getQueueControl ( queueName ) . removeMessages ( filter ) ; } catch ( Exception e ) { throw new AsyncException ( e ) ; } }
Removes messages from queue .