StrictPartitionedQueue

constructor(queues: Array<MessageQueue<T>>)