LOG.debug(String.format("Constructed new QueueState - %s", queueState));
}
return queueState;
}
@Override
<BUG>public void saveDequeueState(QueueConsumer consumer, QueueConfig config, QueueState queueState, ReadPointer readPointer) throws OperationException {
</BUG>
long entryId = queueState.getActiveEntryId();
table.put(makeRowKey(CONSUMER_META_PREFIX, consumer.getGroupId(), consumer.getInstanceId()),
new byte[][]{

LOG.debug(String.format("Constructed new QueueState - %s", queueState));
}
return queueState;
}
@Override
public void saveDequeueState(QueueConsumer consumer, QueueConfig config, QueueStateImpl queueState, ReadPointer readPointer) throws OperationException {
long entryId = queueState.getActiveEntryId();
table.put(makeRowKey(CONSUMER_META_PREFIX, consumer.getGroupId(), consumer.getInstanceId()),
new byte[][]{
