Strolch
/
strolch
mirror of https://github.com/strolch-li/strolch.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[Minor] More logging in CommunicationConnection

This commit is contained in:
Robert von Burg 2018-03-01 15:18:18 +01:00
parent 5230b3ea52
commit 6063cd793a
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
li.strolch.utils/src/main/java/li/strolch/communication/CommunicationConnection.java
View File

@ -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<ConnectionObserver> observers;
synchronized (this.connectionObservers) {
List<ConnectionObserver> 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());