From a1311d4a93decba54a14d5a22011fcde12dd3876 Mon Sep 17 00:00:00 2001
From: Nitsan Wakart <nitsanw@yahoo.com>
Date: Fri, 8 Aug 2014 15:27:12 +0200
Subject: [PATCH] Fixe documentation to state consumer only access is allowed
 to poll/peek/peekNode/pollNode

---
 .../java/akka/dispatch/AbstractNodeQueue.java     | 15 ++++++++++++---
 1 file changed, 12 insertions(+), 3 deletions(-)

diff --git a/akka-actor/src/main/java/akka/dispatch/AbstractNodeQueue.java b/akka-actor/src/main/java/akka/dispatch/AbstractNodeQueue.java
index 645542ee24..e6ca781886 100644
--- a/akka-actor/src/main/java/akka/dispatch/AbstractNodeQueue.java
+++ b/akka-actor/src/main/java/akka/dispatch/AbstractNodeQueue.java
@@ -24,7 +24,9 @@ public abstract class AbstractNodeQueue<T> extends AtomicReference<AbstractNodeQ
        set(n);
     }
 
-    /*
+    /**
+     * Use this method only from the consumer thread!
+     * 
      * !!! There is a copy of this code in pollNode() !!!
      */
     @SuppressWarnings("unchecked")
@@ -40,7 +42,9 @@ public abstract class AbstractNodeQueue<T> extends AtomicReference<AbstractNodeQ
         }
         return next;
     }
-
+    /**
+     * Use this method only from the consumer thread!
+     */
     public final T peek() {
         final Node<T> n = peekNode();
         return (n != null) ? n.value : null;
@@ -67,7 +71,9 @@ public abstract class AbstractNodeQueue<T> extends AtomicReference<AbstractNodeQ
         return count;
     }
 
-    /*
+    /**
+     * Use this method only from the consumer thread!
+     * 
      * !!! There is a copy of this code in pollNode() !!!
      */
     public final T poll() {
@@ -81,6 +87,9 @@ public abstract class AbstractNodeQueue<T> extends AtomicReference<AbstractNodeQ
         }
     }
     
+    /**
+     * Use this method only from the consumer thread!
+     */
     @SuppressWarnings("unchecked")
     public final Node<T> pollNode() {
       Node<T> tail;