improvement in ReplayMessageHandler

Author: sohan09

tracker-server/src/main/java/tracker/server/BrowserEvents.java

@@ -7,4 +7,5 @@
  */
 public interface BrowserEvents {
     String userPositionTracking = "user-position-tracking";
+    String replayUserPositions = "replay-user-positions";
 }

tracker-server/src/main/java/tracker/server/TrackerServer.java

@@ -375,6 +375,13 @@ static Router createRouter() {
             new PermittedOptions().setAddress(BrowserEvents.userPositionTracking)
         ));
 
+        options.setOutboundPermitted(ImmutableList.of(
+            new PermittedOptions().setAddress(BrowserEvents.replayUserPositions)
+        ));
+        options.setInboundPermitted(ImmutableList.of(
+            new PermittedOptions().setAddress(BrowserEvents.replayUserPositions)
+        ));
+
         sockJSHandler.bridge(options);
 
         router.route("/eventbus/*").handler(sockJSHandler);

tracker/src/main/java/tracker/Addresses.java

@@ -11,7 +11,7 @@ public interface Addresses {
 
     String authenticate = "authenticate";
     String findAllPositionsGroupByUserId = findAll(Entities.POSITION_ENTITY) + ".group-by-user-id";
-    String replayUserPositions = "replayUserPositions";
+    String replayUserPositions = "replay-user-positions";
 
     static String post(String address) {
         Objects.requireNonNull(address);

tracker/src/main/java/tracker/message/handlers/impl/ReplayMessageHandlerImpl.java

@@ -60,7 +60,7 @@ public void handle(Message<JsonObject> message) {
 
     private void reqReplyLoop(LoopContext context) {
 
-        final int reqSlots = context.getReqSlots();
+        final int reqSlots = Math.min(context.getReqSlots(), context.getTotalSlots() - context.getSlotsReturned());
         final Message<JsonObject> message = context.getMessage();
 
         new ReplayServiceImpl(