public synchronized void removeUpdatesForQueue ( String queueName ) { Iterator < TransactionItem > entries = items . iterator ( ) ; while ( entries . hasNext ( ) ) { TransactionItem item = entries . next ( ) ; if ( item . getDestination ( ) . getName ( ) . equals ( queueName ) ) entries . remove ( ) ; } }
Remove all pending updates for the given queue