diff --git a/akka-actor/src/main/java/akka/dispatch/AbstractNodeQueue.java b/akka-actor/src/main/java/akka/dispatch/AbstractNodeQueue.java index 4f6f2a9706..0c887faf28 100644 --- a/akka-actor/src/main/java/akka/dispatch/AbstractNodeQueue.java +++ b/akka-actor/src/main/java/akka/dispatch/AbstractNodeQueue.java @@ -78,7 +78,11 @@ public abstract class AbstractNodeQueue extends AtomicReference next = pollNode(); if (next == null) return null; - else return next.value; + else { + T value = next.value; + next.value = null; + return value; + } } /*