StrictPartitionedQueue

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