dequeueStrategy = new FifoDequeueStrategy();
} else {
throw new IllegalStateException(
String.format("Cannot figure out the dequeue strategy to use for partitioner %s", queuePartitioner.getClass()));
}
<BUG>QueueState queueState = consumer.getQueueState();
</BUG>
if(queueState == null) {
queueState = dequeueStrategy.constructQueueState(consumer, config, readPointer);
consumer.setQueueState(queueState);

dequeueStrategy = new FifoDequeueStrategy();
} else {
throw new IllegalStateException(
String.format("Cannot figure out the dequeue strategy to use for partitioner %s", queuePartitioner.getClass()));
}
QueueStateImpl queueState = getQueueStateImpl(consumer.getQueueState());
if(queueState == null) {
queueState = dequeueStrategy.constructQueueState(consumer, config, readPointer);
consumer.setQueueState(queueState);
