emmanuel/gclc-core
emmanuel/gclc-core
1
0
Fork 0
Code Issues 2 Pull Requests Projects 1 Releases Wiki Activity

Added message notifications.

Browse Source 
Signed-off-by: Emmanuel Bigeon <emmanuel@bigeon.fr>
This commit is contained in:
Emmanuel Bigeon 2018-11-26 10:40:40 -05:00
parent 4c1e28b04f
commit 9374c5a681
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
gclc/src/main/java/net/bigeon/gclc/utils/ReadingRunnable.java
View File

@ -146,6 +146,7 @@ public final class ReadingRunnable implements Runnable {
public String getMessage() throws IOException { public String getMessage() throws IOException {
synchronized (lock) { synchronized (lock) {
if (!messages.isEmpty()) { if (!messages.isEmpty()) {
notifyMessage(messages.peek());
return messages.poll(); return messages.poll();
} }
if (!running) { if (!running) {
@ -168,6 +169,7 @@ public final class ReadingRunnable implements Runnable {
public String getNextMessage(final long timeout) throws IOException { public String getNextMessage(final long timeout) throws IOException {
synchronized (lock) { synchronized (lock) {
if (!messages.isEmpty()) { if (!messages.isEmpty()) {
notifyMessage(messages.peek());
return messages.poll(); return messages.poll();
} }
if (!running) { if (!running) {
@ -179,6 +181,7 @@ public final class ReadingRunnable implements Runnable {
if (messages.isEmpty()) { if (messages.isEmpty()) {
return null; return null;
} }
notifyMessage(messages.peek());
return messages.poll(); return messages.poll();
} }
} }