From 6063cd793a6b63a02fa5967cffe7530bfddd4307 Mon Sep 17 00:00:00 2001 From: Robert von Burg Date: Thu, 1 Mar 2018 15:18:18 +0100 Subject: [PATCH] [Minor] More logging in CommunicationConnection --- .../communication/CommunicationConnection.java | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/li.strolch.utils/src/main/java/li/strolch/communication/CommunicationConnection.java b/li.strolch.utils/src/main/java/li/strolch/communication/CommunicationConnection.java index ed632568c..5e6b3d5da 100644 --- a/li.strolch.utils/src/main/java/li/strolch/communication/CommunicationConnection.java +++ b/li.strolch.utils/src/main/java/li/strolch/communication/CommunicationConnection.java @@ -250,6 +250,7 @@ public class CommunicationConnection implements Runnable { */ public void handleNewMessage(IoMessage message) { ConnectionMessages.assertConfigured(this, "Can not be notified of new message yet!"); //$NON-NLS-1$ + logger.info("Received new message " + message.getKey() + " " + message.getId() + " " + message.getState()); // if the state of the message is already later than ACCEPTED // then an underlying component has already set the state, so @@ -262,19 +263,21 @@ public class CommunicationConnection implements Runnable { public void notifyObservers(IoMessage message) { - logger.info( - "Notifying observers for key " + message.getKey() + " with message " + message.getId() + " / " + message - .getState()); - List observers; synchronized (this.connectionObservers) { List list = this.connectionObservers.getList(message.getKey()); - if (list == null) + if (list == null) { + logger.info("No observers waiting for key " + message.getKey()); return; + } observers = new ArrayList<>(list); } + logger.info( + "Notifying " + observers.size() + " observers for key " + message.getKey() + " with message " + message + .getId() + " / " + message.getState()); + for (ConnectionObserver observer : observers) { try { logger.info("Notifying observer " + observer.getClass().getSimpleName());