diff --git a/monitoringagent/src/main/java/io/github/cloudiator/monitoring/domain/MonitorQueueConsumer.java b/monitoringagent/src/main/java/io/github/cloudiator/monitoring/domain/MonitorQueueConsumer.java index 2d67885..60b9c23 100644 --- a/monitoringagent/src/main/java/io/github/cloudiator/monitoring/domain/MonitorQueueConsumer.java +++ b/monitoringagent/src/main/java/io/github/cloudiator/monitoring/domain/MonitorQueueConsumer.java @@ -8,7 +8,7 @@ public class MonitorQueueConsumer extends Thread /*implements Runnable*/ { - private static final Logger LOGGER = LoggerFactory.getLogger(MonitorQueueConsumer.class); + private static final Logger LOGGER = LoggerFactory.getLogger(MonitorQueueController.class); private final MonitorQueueController monitorQueueController; private final String nodeId; private final MonitorHandler monitorHandler; diff --git a/monitoringagent/src/main/java/io/github/cloudiator/monitoring/domain/MonitorQueueController.java b/monitoringagent/src/main/java/io/github/cloudiator/monitoring/domain/MonitorQueueController.java index e4df88f..55e32a3 100644 --- a/monitoringagent/src/main/java/io/github/cloudiator/monitoring/domain/MonitorQueueController.java +++ b/monitoringagent/src/main/java/io/github/cloudiator/monitoring/domain/MonitorQueueController.java @@ -35,11 +35,11 @@ public MonitorQueueController(MonitorHandler monitorHandler) { } private Queue createNewQueue(String nodeId, DomainMonitorModel request) { - LOGGER.debug("add new Queue"); + LOGGER.debug("add new Queue "); Queue result = new LinkedList<>(); result.add(request); queueMap.put(nodeId, result); - LOGGER.debug("QueueMapSize: " + queueMap.size()); + LOGGER.debug("new QueueMapSize: " + queueMap.size()); return result; } @@ -56,9 +56,7 @@ private Queue getQueue(String nodeId) { } public void removeQueue(String nodeId) { - LOGGER.debug("removing MapEntry"); queueMap.remove(nodeId); - LOGGER.debug("remaining Map: " + queueMap.size()); } private synchronized void handleQueueMap(QueueAction action, @@ -72,16 +70,16 @@ public int getQueueMapSize() { public synchronized boolean handleMonitorRequest(String nodeId, DomainMonitorModel domainMonitorModel) { - LOGGER.debug("QueueController handling Monitor"); + LOGGER.debug("QueueController handling Monitor "+domainMonitorModel.getMetric()); Queue usedQueue; if (existingQueue(nodeId)) { - LOGGER.debug("adding Monitor to existing Queue"); + LOGGER.debug("found existing Queue, adding Monitor"); usedQueue = getQueue(nodeId); usedQueue.add(domainMonitorModel); - LOGGER.debug("QueueSize: " + usedQueue.size()); + LOGGER.debug("QueueSize now: " + usedQueue.size()); } else { usedQueue = createNewQueue(nodeId, domainMonitorModel); - LOGGER.debug("QueueMapEntries: " + queueMap.size() + " - running newConsumer"); + LOGGER.debug("created new Queue with size: " + queueMap.size() + " - starting new QueueConsumer"); queueExecutor.submit(new MonitorQueueConsumer(nodeId, usedQueue, this, monitorHandler)); } diff --git a/monitoringagent/src/main/java/io/github/cloudiator/monitoring/messaging/NodeEventListener.java b/monitoringagent/src/main/java/io/github/cloudiator/monitoring/messaging/NodeEventListener.java index 211d9e2..8227f5f 100644 --- a/monitoringagent/src/main/java/io/github/cloudiator/monitoring/messaging/NodeEventListener.java +++ b/monitoringagent/src/main/java/io/github/cloudiator/monitoring/messaging/NodeEventListener.java @@ -43,7 +43,7 @@ public void accept(String id, NodeEvent nodeEvent) { try { TargetState targetState; LOGGER.debug( - "Got NodeEvent: " + nodeEvent.getNode().getId() + ": " + nodeEvent.getFrom() + "Got NodeEvent: " + nodeEvent.getFrom() + " to " + nodeEvent.getTo()); switch (nodeEvent.getTo()) { case NODE_STATE_PENDING: @@ -63,7 +63,6 @@ public void accept(String id, NodeEvent nodeEvent) { } monitorManagementService .handleEvent(TypeEnum.NODE, nodeEvent.getNode().getId(), targetState); - } catch (Exception e) { LOGGER.error("Error while receiving NodeEvent. ", e); diff --git a/monitoringagent/src/main/java/io/github/cloudiator/monitoring/messaging/ProcessEventListener.java b/monitoringagent/src/main/java/io/github/cloudiator/monitoring/messaging/ProcessEventListener.java index d3bebeb..fc627d0 100644 --- a/monitoringagent/src/main/java/io/github/cloudiator/monitoring/messaging/ProcessEventListener.java +++ b/monitoringagent/src/main/java/io/github/cloudiator/monitoring/messaging/ProcessEventListener.java @@ -42,7 +42,7 @@ public void run() { public void accept(String id, ProcessEvent processEvent) { try { LOGGER.debug( - "Got ProcessEvent: " + processEvent.getProcess().getId() + ": " + processEvent + "Got ProcessEvent: " + processEvent .getFrom() + " to " + processEvent.getTo()); TargetState targetState;