Commit 8735b939 authored by afreyssin's avatar afreyssin
Browse files

Minor changes.

parent b7d3f184
...@@ -155,9 +155,9 @@ public class DistributionTopic extends Topic { ...@@ -155,9 +155,9 @@ public class DistributionTopic extends Topic {
* @see Destination#preProcess(AgentId, ClientMessages) * @see Destination#preProcess(AgentId, ClientMessages)
*/ */
public ClientMessages preProcess(AgentId from, ClientMessages cm) { public ClientMessages preProcess(AgentId from, ClientMessages cm) {
if (logger.isLoggable(BasicLevel.DEBUG)) { if (logger.isLoggable(BasicLevel.DEBUG))
logger.log(BasicLevel.DEBUG, "DistributionTopic. preProcess(" + from + ", " + cm + ')'); logger.log(BasicLevel.DEBUG, "DistributionTopic. preProcess(" + from + ", " + cm + ')');
}
List msgs = cm.getMessages(); List msgs = cm.getMessages();
// This method return null so the counter will not be updated in processMessage method // This method return null so the counter will not be updated in processMessage method
nbMsgsReceiveSinceCreation = nbMsgsReceiveSinceCreation + msgs.size(); nbMsgsReceiveSinceCreation = nbMsgsReceiveSinceCreation + msgs.size();
......
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