Update ExclamationTopology.java

dice-project · Mar 14, 2017 · 3bb25d3 · 3bb25d3
1 parent 5ca3ead
commit 3bb25d3
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/qt-lib/src/main/java/uk/ic/dice/qt/examples/ExclamationTopology.java b/qt-lib/src/main/java/uk/ic/dice/qt/examples/ExclamationTopology.java
@@ -133,15 +133,17 @@ public static void main(String[] args) throws Exception {
 			timeStampTime = new SimpleDateFormat("HH:mm:ss.000").format(new Date());
 			String tEnd = timeStampDate + "T"+ timeStampTime + "Z";		
 			int maxDMONRecords = 100;
-			String DMONurl = "http://109.231.122.229:5001"; // to configure as needed
-			curMaxBoltCapacity = DMONBoltCapacityMonitor.getMaxCapacity(DMONurl, tStart, tEnd, maxDMONRecords); 
+			String DMONurl = "http://0.0.0.0:5001"; // to configure as needed
+			// uncomment the next lines to enable DMON-based monitoring
+			/*curMaxBoltCapacity = DMONBoltCapacityMonitor.getMaxCapacity(DMONurl, tStart, tEnd, maxDMONRecords); 
 			System.out.println("Max Bolt Capacity (DMON," + "Topology: " + topologyId + " Start: " + tStart + " End: " + tEnd +"): "+curMaxBoltCapacity);			
 			
 			
 			if (curMaxBoltCapacity>=maxBoltCapacity) {
 				System.out.println("Current bolt capacity is "+ curMaxBoltCapacity + " and exceeds the maximum bolt capacity: " + maxBoltCapacity + " STOPPING experiment.");
 				return;
 			}
+			*/
 		}
 	}
 }