Slightly closer emulation of the BlockingQueue API.

Simon MacMullen · Simon MacMullen · commit f6e086cf5914 · 2014-10-01T13:36:55.000+01:00
diff --git a/src/com/rabbitmq/client/impl/WorkPool.java b/src/com/rabbitmq/client/impl/WorkPool.java
@@ -85,12 +85,12 @@ private WorkQueue(int maxLengthWhenLimited) {
             this.maxLengthWhenLimited = maxLengthWhenLimited;
         }
 
-        public boolean put(T t) throws InterruptedException {
+        public void put(T t) throws InterruptedException {
             if (limited && list.size() > maxLengthWhenLimited) {
                 assert !semaphore.hasQueuedThreads();
                 semaphore.acquire();
             }
-            return list.offer(t);
+            list.add(t);
         }
 
         public T poll() {

Original file line number	Diff line number	Diff line change
`@@ -85,12 +85,12 @@ private WorkQueue(int maxLengthWhenLimited) {`
`85`	`85`	`this.maxLengthWhenLimited = maxLengthWhenLimited;`
`86`	`86`	`}`
`87`	`87`
`88`		`- public boolean put(T t) throws InterruptedException {`
	`88`	`+ public void put(T t) throws InterruptedException {`
`89`	`89`	`if (limited && list.size() > maxLengthWhenLimited) {`
`90`	`90`	`assert !semaphore.hasQueuedThreads();`
`91`	`91`	`semaphore.acquire();`
`92`	`92`	`}`
`93`		`- return list.offer(t);`
	`93`	`+ list.add(t);`
`94`	`94`	`}`
`95`	`95`
`96`	`96`	`public T poll() {`