code: @Tick(delay = 200L, unit = TimeUnit.MILLISECONDS)
    protected void processGDATRecords() throws InvocationTargetException, IllegalAccessException {
      stopwatch.reset();
      stopwatch.start();
      while (!recordQueue.isEmpty()) {
        // Time since start of processing in Seconds
        long elapsedTime = stopwatch.elapsedTime(TimeUnit.SECONDS);
        if (elapsedTime >= Constants.TICKER_TIMEOUT) {
          break;
        }
        Map.Entry<String, GDATDecoder> record = recordQueue.getNext();
        methodsDriver.invokeMethods(record.getKey(), record.getValue());
      }
      stopwatch.stop();
    }
docs: This process method consumes the records queued in dataManager and invokes the associated "process" methods for
  each output query