return newEntryIds;
}
}
class RoundRobinDequeueStrategy extends AbstractDisjointDequeueStrategy implements DequeueStrategy {
@Override
<BUG>public List<Long> fetchNextEntries(QueueConsumer consumer, QueueConfig config, QueueState queueState, ReadPointer readPointer) throws OperationException {
</BUG>
long entryId = queueState.getConsumerReadPointer();
QueuePartitioner partitioner=config.getPartitionerType().getPartitioner();
List<Long> newEntryIds = new ArrayList<Long>();

return newEntryIds;
}
}
class RoundRobinDequeueStrategy extends AbstractDisjointDequeueStrategy implements DequeueStrategy {
@Override
public List<Long> fetchNextEntries(QueueConsumer consumer, QueueConfig config, QueueStateImpl queueState, ReadPointer readPointer) throws OperationException {
long entryId = queueState.getConsumerReadPointer();
QueuePartitioner partitioner=config.getPartitionerType().getPartitioner();
List<Long> newEntryIds = new ArrayList<Long>();
