return exception in case of the eTransl error callback

europeana · May 15, 2024 · 8560834 · 8560834
1 parent ca8a33b
commit 8560834
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/...ava/eu/europeana/api/translation/service/etranslation/ETranslationTranslationService.java b/...ava/eu/europeana/api/translation/service/etranslation/ETranslationTranslationService.java
@@ -166,7 +166,11 @@ private void createRedisMessageListenerAndWaitForResults(List<TranslationObj> tr
       if(LOGGER.isDebugEnabled()) {
         LOGGER.debug("Received message from redis message listener is: {}", response);
       }
-      if(response!=null) {
+      if(response.contains(ETranslationTranslationService.eTranslationErrorCallbackIndicator)) {
+        //eTtransl error callback received
+        throw new TranslationException(response);
+      }
+      else if(response!=null) {
         //extractTranslationsFromETranslationHtmlResponse(translationObjs, redisMessageListenerAdapter, response);
         extractTranslationsFromETranslationResponse(translationObjs, redisMessageListenerAdapter, response);
       }

diff --git a/...src/main/java/eu/europeana/api/translation/service/etranslation/RedisMessageListener.java b/...src/main/java/eu/europeana/api/translation/service/etranslation/RedisMessageListener.java
@@ -23,7 +23,7 @@ public void onMessage(Message message, byte[] pattern) {
         String messageBody=new String(message.getBody(), StandardCharsets.UTF_8);
         if(messageBody.contains(ETranslationTranslationService.eTranslationErrorCallbackIndicator)) {
           //if we enter here, means the eTranslation error callback is called
-          this.message=null;
+          this.message=messageBody;
         }
         else {
           /*