try {
Invocation invocation = getNodeEngine().getOperationService().createInvocationBuilder(QueueService.SERVICE_NAME, operation, partitionId).build();
Future<Long> f = invocation.invoke();
Long itemId = f.get();
if (itemId != null){
<BUG>if(!itemIdSet.add(itemId)){
throw new TransactionException("Duplicate itemId: " + itemId);
}
tx.addTransactionLog(new QueueTransactionLog(itemId, name, partitionId, new TxnOfferOperation(name, itemId, data)));</BUG>
return true;

try {
Invocation invocation = getNodeEngine().getOperationService().createInvocationBuilder(QueueService.SERVICE_NAME, operation, partitionId).build();
Future<Long> f = invocation.invoke();
Long itemId = f.get();
if (itemId != null){
if(offerIdQueue.contains(itemId) || pollIdQueue.contains(itemId)){
throw new TransactionException("Duplicate itemId: " + itemId);
