response = container.txnCommitOffer(itemId, data, false);
}
@Override
public void afterRun() throws Exception {
LocalQueueStatsImpl queueStats = getQueueService().getLocalQueueStatsImpl(name);
if (Boolean.TRUE.equals(response)) {
queueStats.incrementOffers();
publishEvent(ItemEventType.ADDED, data);
} else {
queueStats.incrementRejectedOffers();
}
}