public DefaultQueueFactory(DefaultQueueManager queueManager, CompositeKeyUtil keyUtil, DataStore ds) {
this.queueManager = queueManager;
this.keyUtil = keyUtil;
// PriorityCompositeKeyUtil has the same length queueId for backwards compatibility
this.priorityKeyUtil = new PriorityCompositeKeyUtil(keyUtil.getQueueIdByteLength(), 8);
this.ds = ds;
}