diff --git a/akka-actor/src/main/java/akka/dispatch/AbstractNodeQueue.java b/akka-actor/src/main/java/akka/dispatch/AbstractNodeQueue.java index 8e8ab38091..4f6f2a9706 100644 --- a/akka-actor/src/main/java/akka/dispatch/AbstractNodeQueue.java +++ b/akka-actor/src/main/java/akka/dispatch/AbstractNodeQueue.java @@ -74,18 +74,11 @@ public abstract class AbstractNodeQueue extends AtomicReference next = peekNode(); + final Node next = pollNode(); if (next == null) return null; - else { - final T ret = next.value; - next.value = null; - Unsafe.instance.putOrderedObject(this, tailOffset, next); - return ret; - } + else return next.value; } /* @@ -106,6 +99,7 @@ public abstract class AbstractNodeQueue extends AtomicReference