class SaveEventQueue {

    public void removeAllPending(TransUnitId id) {
        Log.info("remove all pending for " + id);
        Collection<EventWrapper> pending =
                filter(eventQueue, new FindByTransUnitIdPredicate(id));
        eventQueue.removeAll(pending);
    }

}