diff --git a/gclc/src/main/java/net/bigeon/gclc/utils/ReadingRunnable.java b/gclc/src/main/java/net/bigeon/gclc/utils/ReadingRunnable.java
index d191c87..695de1a 100644
--- a/gclc/src/main/java/net/bigeon/gclc/utils/ReadingRunnable.java
+++ b/gclc/src/main/java/net/bigeon/gclc/utils/ReadingRunnable.java
@@ -146,6 +146,7 @@ public final class ReadingRunnable implements Runnable {
     public String getMessage() throws IOException {
         synchronized (lock) {
             if (!messages.isEmpty()) {
+                notifyMessage(messages.peek());
                 return messages.poll();
             }
             if (!running) {
@@ -168,6 +169,7 @@ public final class ReadingRunnable implements Runnable {
     public String getNextMessage(final long timeout) throws IOException {
         synchronized (lock) {
             if (!messages.isEmpty()) {
+                notifyMessage(messages.peek());
                 return messages.poll();
             }
             if (!running) {
@@ -179,6 +181,7 @@ public final class ReadingRunnable implements Runnable {
             if (messages.isEmpty()) {
                 return null;
             }
+            notifyMessage(messages.peek());
             return messages.poll();
         }
     }