undeliveredMessageIDs.add(query.getMessageId());
localSession.rollbackUndelivered(undeliveredMessageIDs);
LocalMessageConsumer consumer = (LocalMessageConsumer)localSession.lookupRegisteredConsumer(query.getConsumerId());
if (consumer != null)
consumer.restorePrefetchCapacity(1);
}
return new RollbackMessageResponse();
}