Commit c123bb34 authored by afreyssin's avatar afreyssin
Browse files

Adds a particular logger allowing to follow the messages flows with a limited amount of traces.

parent 7d1b89bd
......@@ -196,6 +196,7 @@ public class AcquisitionQueue extends Queue implements AcquisitionQueueMBean {
if (acquisitionModule == null) {
acquisitionModule = new AcquisitionModule(this, acquisitionClassName, properties);
}
logmsg.log(BasicLevel.DEBUG, getName() + "initialize with lastMessageId=" + lastMessageId);
}
/**
......@@ -318,6 +319,8 @@ public class AcquisitionQueue extends Queue implements AcquisitionQueueMBean {
if (lastMessageId != null && lastMessageId.equals(not.getId())) {
if (logger.isLoggable(BasicLevel.DEBUG))
logger.log(BasicLevel.DEBUG, "Message already received, drop the message " + not);
if (logmsg.isLoggable(BasicLevel.WARN))
logmsg.log(BasicLevel.WARN, getName() + ": drops already received message " + not.getId());
return;
}
lastMessageId = not.getId();
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment