From 9374c5a681fce8d1a8fb2afe3e0e5646035c49ef Mon Sep 17 00:00:00 2001
From: Emmanuel Bigeon <emmanuel@bigeon.fr>
Date: Mon, 26 Nov 2018 10:40:40 -0500
Subject: [PATCH] Added message notifications.

Signed-off-by: Emmanuel Bigeon <emmanuel@bigeon.fr>
---
 gclc/src/main/java/net/bigeon/gclc/utils/ReadingRunnable.java | 3 +++
 1 file changed, 3 insertions(+)

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();
         }
     }