RD: Removed unneeded log messages (#40)

eu-nebulous · Nov 22, 2024 · 3b8920e · 3b8920e
1 parent d79877b
commit 3b8920e
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/resource-discovery/src/main/java/eu/nebulous/resource/discovery/common/BrokerUtil.java b/resource-discovery/src/main/java/eu/nebulous/resource/discovery/common/BrokerUtil.java
@@ -200,9 +200,11 @@ public void onMessage(Message message) {
                 Object obj = objectMapper.readerFor(typeRef).readValue(payload);
 
                 if (obj instanceof Map<?,?> dataMap) {
+                    log.warn("BrokerUtil: Received a new message:   topic: {}", ((ActiveMQTextMessage) message).getDestination().getPhysicalName());
+                    log.warn("BrokerUtil: Received a new message: payload: {}", dataMap);
                     handlePayload(((ActiveMQTextMessage) message).getDestination().getPhysicalName(), dataMap);
                 } else {
-                    log.debug("BrokerUtil: Message payload is not recognized. Expected Map but got: type={}, object={}", obj.getClass().getName(), obj);
+                    log.warn("BrokerUtil: Message payload is not recognized. Expected Map but got: type={}, object={}", obj.getClass().getName(), obj);
                 }
             } else {
                 log.debug("BrokerUtil: Message type is not supported: {}", message);

diff --git a/...c/main/java/eu/nebulous/resource/discovery/registration/RegistrationRequestProcessor.java b/...c/main/java/eu/nebulous/resource/discovery/registration/RegistrationRequestProcessor.java
@@ -302,7 +302,6 @@ private void processResponse(@NonNull Map<String, Object> response) {
 					log.warn("RegistrationRequestProcessor: processResponse: nodeInfo: ** PROBLEM: REGISTRATION REQUEST DOES NOT CONTAIN DEVICE INFO EITHER **");
 				}
 			}
-			log.warn("RegistrationRequestProcessor: processResponse: CHECK: ** NOT A REAL EXCEPTION **\n", new RuntimeException("NOT A REAL EXCEPTION"));
 
 			if (obj instanceof Map devInfo) {
 				// Update request info