open fun setWriteQueueMaxSize(maxSize: Int): MessageProducer<T>
Overrides WriteStream.setWriteQueueMaxSize