Skip to content

Instantly share code, notes, and snippets.

@xathien
Created June 24, 2015 20:04
Show Gist options
  • Save xathien/ec9ca35224868a524873 to your computer and use it in GitHub Desktop.
Save xathien/ec9ca35224868a524873 to your computer and use it in GitHub Desktop.
UnregisterKey Patch
diff --git a/src/com/rabbitmq/client/impl/WorkPool.java b/src/com/rabbitmq/client/impl/WorkPool.java
index 1c8adc3..0377f52 100644
--- a/src/com/rabbitmq/client/impl/WorkPool.java
+++ b/src/com/rabbitmq/client/impl/WorkPool.java
@@ -123,6 +123,7 @@ public class WorkPool<K, W> {
this.pool.remove(key);
this.ready.remove(key);
this.inProgress.remove(key);
+ this.unlimited.remove(key);
}
}
@@ -134,6 +135,7 @@ public class WorkPool<K, W> {
this.pool.clear();
this.ready.clear();
this.inProgress.clear();
+ this.unlimited.clear();
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment