GH-1402: SMLC: Fix BlockingQueueConsumer#queue init

zysaaa · garyrussell · commit 8b18e9006043 · 2021-12-14T15:57:09.000-05:00
diff --git a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/listener/BlockingQueueConsumer.java b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/listener/BlockingQueueConsumer.java
@@ -295,7 +295,7 @@ public BlockingQueueConsumer(ConnectionFactory connectionFactory,
 		this.noLocal = noLocal;
 		this.exclusive = exclusive;
 		this.queues = Arrays.copyOf(queues, queues.length);
-		this.queue = new LinkedBlockingQueue<Delivery>(prefetchCount);
+		this.queue = new LinkedBlockingQueue<Delivery>(queues.length == 0 ? prefetchCount : prefetchCount * queues.length);
 	}
 
 	public Channel getChannel() {

Original file line number	Diff line number	Diff line change
`@@ -295,7 +295,7 @@ public BlockingQueueConsumer(ConnectionFactory connectionFactory,`
`295`	`295`	`this.noLocal = noLocal;`
`296`	`296`	`this.exclusive = exclusive;`
`297`	`297`	`this.queues = Arrays.copyOf(queues, queues.length);`
`298`		`- this.queue = new LinkedBlockingQueue<Delivery>(prefetchCount);`
	`298`	`+ this.queue = new LinkedBlockingQueue<Delivery>(queues.length == 0 ? prefetchCount : prefetchCount * queues.length);`
`299`	`299`	`}`
`300`	`300`
`301`	`301`	`public Channel getChannel() {`