Remove WorkPool memory leak

Zack · Zack · commit 3291399a46ae · 2015-06-24T14:19:47.000-06:00
diff --git a/src/com/rabbitmq/client/impl/WorkPool.java b/src/com/rabbitmq/client/impl/WorkPool.java
@@ -123,6 +123,7 @@ public void unregisterKey(K key) {
             this.pool.remove(key);
             this.ready.remove(key);
             this.inProgress.remove(key);
+            this.unlimited.remove(key);
         }
     }
 
@@ -134,6 +135,7 @@ public void unregisterAllKeys() {
             this.pool.clear();
             this.ready.clear();
             this.inProgress.clear();
+            this.unlimited.clear();
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -123,6 +123,7 @@ public void unregisterKey(K key) {`
`123`	`123`	`this.pool.remove(key);`
`124`	`124`	`this.ready.remove(key);`
`125`	`125`	`this.inProgress.remove(key);`
	`126`	`+ this.unlimited.remove(key);`
`126`	`127`	`}`
`127`	`128`	`}`
`128`	`129`
`@@ -134,6 +135,7 @@ public void unregisterAllKeys() {`
`134`	`135`	`this.pool.clear();`
`135`	`136`	`this.ready.clear();`
`136`	`137`	`this.inProgress.clear();`
	`138`	`+ this.unlimited.clear();`
`137`	`139`	`}`
`138`	`140`	`}`
`139`	`141`