ExceptionUtil.rethrow(t);
}
return false;
}
public Data pollInternal(long timeout){
<BUG>TxnReservePollOperation operation = new TxnReservePollOperation(name, timeout);
try {</BUG>
Invocation invocation = getNodeEngine().getOperationService().createInvocationBuilder(QueueService.SERVICE_NAME, operation, partitionId).build();
Future<QueueItem> f = invocation.invoke();
QueueItem item = f.get();

ExceptionUtil.rethrow(t);
}
return false;
}
public Data pollInternal(long timeout){
QueueItem reservedOffer = offerIdQueue.peek();
TxnReservePollOperation operation = new TxnReservePollOperation(name, timeout, reservedOffer == null ? -1 : reservedOffer.getItemId());
try {
Invocation invocation = getNodeEngine().getOperationService().createInvocationBuilder(QueueService.SERVICE_NAME, operation, partitionId).build();
Future<QueueItem> f = invocation.invoke();
QueueItem item = f.get();
