Moved load stats under the load subtopic.

moscajs · Feb 17, 2014 · cbc7a2a · cbc7a2a
1 parent 88a811f
commit cbc7a2a
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/lib/stats.js b/lib/stats.js
@@ -141,10 +141,10 @@ Stats.prototype.wire = function wire(server) {
 
     doPublish("connectedClients", stats.connectedClients);
     doPublish("publishedMessages", stats.publishedMessages);
-    doPublish("15m/connectedClients", stats.load.m15.connectedClients);
-    doPublish("15m/publishedMessages", stats.load.m15.publishedMessages);
-    doPublish("1m/connectedClients", stats.load.m1.connectedClients);
-    doPublish("1m/publishedMessages", stats.load.m1.publishedMessages);
+    doPublish("load/15m/connectedClients", stats.load.m15.connectedClients);
+    doPublish("load/15m/publishedMessages", stats.load.m15.publishedMessages);
+    doPublish("load/1m/connectedClients", stats.load.m1.connectedClients);
+    doPublish("load/1m/publishedMessages", stats.load.m1.publishedMessages);
   }, 60 * 1000);
 
   events.forEach(function(event) {

diff --git a/test/stats_spec.js b/test/stats_spec.js
@@ -134,7 +134,7 @@ describe("mosca.Stats", function() {
             var count = 0;
 
             server.on("testPublished", function(packet) {
-              if (packet.topic === "/$SYS/42/15m/" + events[event]) {
+              if (packet.topic === "/$SYS/42/load/15m/" + events[event]) {
                 count++;
 
                 if (++count % 15 === 0) {
@@ -178,7 +178,7 @@ describe("mosca.Stats", function() {
             server.emit(event);
 
             server.on("testPublished", function(packet) {
-              if (packet.topic === "/$SYS/42/1m/" + events[event]) {
+              if (packet.topic === "/$SYS/42/load/1m/" + events[event]) {
                 expect(packet.payload).to.eql("2");
                 done();
               }