<BUG>new QueueEntryPointer(entryId, shardMeta.getShardId()));</BUG><CONTEXT>}, cleanWriteVersion,new byte [][] {new EntryMeta(EntryState.VALID).getBytes(), data});return new EnqueueResult(EnqueueStatus.SUCCESS,<extra_id_0>}@Overridepublic void invalidate(QueueEntryPointer entryPointer,</CONTEXT>
new QueueEntryPointer(queueName, entryId, shardMeta.getShardId()));