code: private final void pollProgress() {
  
          final String pollUrl = this.httpPollerProcessor
                  .getPollerRequestUrl(pollerData.getJobId());
  
          final HttpMethod pollerHttpMethod = HttpMethod.GET;
          final String postBodyForPoller = "";
          final ActorRef pollerWorker = getContext().actorOf(
                  Props.create(HttpWorker.class, actorMaxOperationTimeoutSec,
                          client, String.format("%s://%s:%d%s", request
                                  .getProtocol().toString(), trueTargetNode,
                                  request.getPort(), pollUrl), pollerHttpMethod,
                          postBodyForPoller, request.getHttpHeaderMap(), request.getResponseHeaderMeta()));
  
          logger.info("POLL_REQ_SEND" + pollUrl + " "
                  + PcDateUtils.getNowDateTimeStrStandard());
  
          pollerData
                  .getPollingHistoryMap()
                  .put("POLL_REQ_SEND_"
                          + PcDateUtils.getNowDateTimeStrConciseNoZone(), pollUrl);
  
          pollerWorker.tell(RequestWorkerMsgType.PROCESS_REQUEST, getSelf());
  
          // reschedule cancel
          cancelExistingIfAnyAndScheduleTimeoutCall();
  
      }
docs: Poller.