Searched refs:txnTimeMillis (Results 1 – 1 of 1) sorted by relevance
407 long txnTimeMillis = 0; in processBackgroundResponse() local414 txnTimeMillis = endTimeMillis - startTimeMillis; in processBackgroundResponse()417 + "(took " + txnTimeMillis + " ms). Added " in processBackgroundResponse()446 txnTimeMillis); in processBackgroundResponse()511 private static int nextBatchSize(final int messagesUpdated, final long txnTimeMillis) { in nextBatchSize() argument517 if (txnTimeMillis <= 0) { in nextBatchSize()523 return (int) ((double) (messagesUpdated) / (double) txnTimeMillis in nextBatchSize()