pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageConsumerSpec.java [511:524]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	@Override
	public Integer getReceiverQueueSize() {
		return this.receiverQueueSize;
	}

	/**
	 * Sets the size of the consumer receive queue.
	 * @param receiverQueueSize the size of the consumer receive queue
	 */
	public void setReceiverQueueSize(Integer receiverQueueSize) {
		this.receiverQueueSize = receiverQueueSize;
	}

	@Override
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageReaderSpec.java [129:142]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	@Override
	public Integer getReceiverQueueSize() {
		return this.receiverQueueSize;
	}

	/**
	 * Sets the size of the reader receive queue.
	 * @param receiverQueueSize the size of the reader receive queue
	 */
	public void setReceiverQueueSize(Integer receiverQueueSize) {
		this.receiverQueueSize = receiverQueueSize;
	}

	@Override
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -