Невозможность доступа к функции успеха при вызове рекурсивного ajax

Question

Я создаю систему, которая имеет функцию уведомления о нажатиях и использует Джерси для создания API.
Я прочитал article о кометной подходе и в конечном итоге с помощью следующего кода:

index.js

function checkExamNotification() { 
    $.ajax({ 
     url: contextPath + '/api/notification/checkExamNotification', 
     type: 'get', 
     data: { 
      accountId: accountId, 
      sessionId: sessionId 
     }, 
     success: function (res) { 
      console.log("success"); 
      displayNumberOfNotification(); 
      checkExamNotification(); 
     }, 
     error: function (jqXHR, textStatus, errorThrown) { 
      if (textStatus === "timeout") { 
       checkExamNotification(); 
      } 
     } 
    }); 
} 

$(document).ready(function() { 
    $.ajaxSetup({ 
     timeout: 1000*60*3 
    }); 
    checkExamNotification(); 
}); 

Проверка уведомления экзамен API

@GET 
@Path("/checkExamNotification") 
public Response checkExamNotification(@QueryParam("accountId") int accountId, @QueryParam("sessionId") String sessionId) throws InterruptedException { 
    if (memCachedClient.checkSession(sessionId, accountId)) { 
     while (!examNotificationQueue.hasItems()) { 
      Thread.sleep(5000); 
     } 

     ExamNotificationQueueItemModel examNotificationQueueItemModel = examNotificationQueue.dequeue(); 
     if (examNotificationQueueItemModel.getAccountId() == accountId) { 
      LOGGER.info("[START] Check exam notification API"); 
      LOGGER.info("Account ID: " + accountId); 
      LOGGER.info("Get notification with exam ID: " + examNotificationQueueItemModel.getExamId()); 

      ExamEntity exam = examDAO.findById(examNotificationQueueItemModel.getExamId()); 
      NotificationEntity notification = notificationDAO.findByExamId(exam.getExamid()); 
      notification.setSend(1); 
      notificationDAO.getEntityManager().getTransaction().begin(); 
      notificationDAO.update(notification); 
      notificationDAO.getEntityManager().getTransaction().commit(); 

      LOGGER.info("[END]"); 
      String result = gson.toJson(examNotificationQueueItemModel); 
      return Response.status(200).entity(result).build(); 
     } else { 
      examNotificationQueue.enqueue(examNotificationQueueItemModel); 
      Thread.sleep(5000); 
      checkExamNotification(accountId, sessionId); 
     } 

    } 
    return Response.status(200).entity(gson.toJson("timeout")).build(); 
} 

С моей отладки, API завершил возврат, но событие успеха SOMETIMES не срабатывало.
Да, иногда успех в консольном журнале, но иногда это не так.
Может ли кто-нибудь объяснить мне этот случай?
Заранее спасибо. Любая помощь будет оценена по достоинству.

Answer 1

Хорошо после следующего комментария @peeskillet. Вот мой окончательный код.

уведомление Проверка экзамена API

@GET 
@Produces(SseFeature.SERVER_SENT_EVENTS) 
@Path("/checkExamNotification") 
public EventOutput checkExamNotification(@QueryParam("accountId") final int accountId, @QueryParam("sessionId") final String sessionId) { 
    final EventOutput eventOutput = new EventOutput(); 
    if (memCachedClient.checkSession(sessionId, accountId)) { 
     new Thread(new Runnable() { 
      public void run() { 
       try { 
        if (examNotificationQueue.hasItems()) { 
         ExamNotificationQueueItemModel examNotificationQueueItemModel = examNotificationQueue.dequeue(); 
         if (examNotificationQueueItemModel.getAccountId() == accountId) { 
          LOGGER.info("[START] Check exam notification API"); 
          LOGGER.info("Account ID: " + accountId); 
          LOGGER.info("Get notification with exam ID: " + examNotificationQueueItemModel.getExamName()); 
          String result = gson.toJson(examNotificationQueueItemModel); 
          final OutboundEvent.Builder eventBuilder 
            = new OutboundEvent.Builder(); 
          eventBuilder.data(result); 
          final OutboundEvent event = eventBuilder.build(); 
          eventOutput.write(event); 
          LOGGER.info("[END]"); 
         } else { 
          examNotificationQueue.enqueue(examNotificationQueueItemModel); 
         } 
        } 

       } catch (IOException e) { 
        throw new RuntimeException(
          "Error when writing the event.", e); 
       } finally { 
        try { 
         eventOutput.close(); 
        } catch (IOException ioClose) { 
         throw new RuntimeException(
           "Error when closing the event output.", ioClose); 
        } 
       } 
      } 
     }).start(); 
    } 

    return eventOutput; 
} 

index.js

function checkExamNotification() { 
    var url = contextPath + '/api/notification/checkExamNotification?accountId=' + accountId + '&sessionId=' + sessionId; 
    var source = new EventSource(url); 
    source.onmessage = function (event) { 
     displayNumberOfNotification(); 
    }; 
}