- private static Long getExpiryTime(){
- return System.nanoTime() + TimeUnit.MILLISECONDS.toNanos(
- StatisticsProvider.STATS_COLLECTION_MILLIS*NUMBER_OF_WAIT_CYCLES);
+ public boolean isExpectedTransaction(TransactionAware transaction) {
+ Boolean more = null;
+ if (transaction instanceof MultipartTransactionAware) {
+ more = ((MultipartTransactionAware)transaction).isMoreReplies();
+ }
+
+ return isExpectedTransaction(transaction, more);
+ }
+
+ private Long getExpiryTime() {
+ return System.nanoTime() + lifetimeNanos;