break;
}
}
if (tokensLoaded >= configuration.tokensToLoad()) {
logger.fine(String.format("Ending token loading transaction for %s variant (%s)", variant.getType().getTypeName(), variant.getVariantID()));
<BUG>nextBatchEvent.fire(new MessageHolderWithVariants(msg.getPushMessageInformation(), message, msg.getVariantType(), variants, lastTokenInBatch));
</BUG>
} else {
logger.fine(String.format("All batches for %s variant were loaded (%s)", variant.getType().getTypeName(), msg.getPushMessageInformation().getId()));
allBatchesLoaded.fire(new AllBatchesLoadedEvent(variant.getVariantID()));

break;
}
}
if (tokensLoaded >= configuration.tokensToLoad()) {
logger.fine(String.format("Ending token loading transaction for %s variant (%s)", variant.getType().getTypeName(), variant.getVariantID()));
nextBatchEvent.fire(new MessageHolderWithVariants(msg.getPushMessageInformation(), message, msg.getVariantType(), variants, serialId, lastTokenInBatch));
} else {
logger.fine(String.format("All batches for %s variant were loaded (%s)", variant.getType().getTypeName(), msg.getPushMessageInformation().getId()));
allBatchesLoaded.fire(new AllBatchesLoadedEvent(variant.getVariantID()));
