code: 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();
  		}
      }
docs: Remove all pending updates for the given queue
  @param queueName the queue name